golang mongodb 聚合(Aggregate) github.com/qiniu/qmgo框架
项目场景:最近使用golang 来访问mongodb 出了点问题github.com/qiniu/qmgo对于数据聚合踩了坑 官方的demo给的太少没有多分支的场景问题描述:网上对于golang 来调用mongodb 的文章少之又少几乎没有 下面是我反复试验规范的使用mongodb 聚合的规范代码APP 中接收数据代码:matchStage := bson.D{{"$match", []bson.
·
项目场景:
最近使用golang 来访问mongodb 出了点问题 github.com/qiniu/qmgo对于数据聚合踩了坑 官方的demo给的太少没有多分支的场景
问题描述:
网上对于golang 来调用mongodb 的文章少之又少几乎没有 下面是我反复试验规范的使用mongodb 聚合的规范代码
APP 中接收数据代码:
matchStage := bson.D{
{"$match", []bson.E{
{"type_id", 9},
{"timestamp", bson.D{{"$gte", 0}, {"$lte", msg.EndTimeStamp}}},
},
},
}
groupStage := bson.D{
{"$group", bson.D{
{"_id", "$type_id"},
{"send_flux", bson.D{{"$avg", "$send_flux"}}},
{"recv_flux", bson.D{{"$avg", "$recv_flux"}}},
},
},
}
var showsWithInfo []bson.M
// aggregate ALL()
err := cli.Aggregate(context.Background(), mongo.Pipeline{matchStage, groupStage}).All(&showsWithInfo)
if err != nil {
mqttlog.WriteInfoLog("%s", err)
}
length = len(showsWithInfo)
for i := 0; i < length; i++ {
fmt.Println(showsWithInfo[i])
}
原因分析:
之前是个人对于qmgo框架 还有对mongodb的驱动,缺乏理解, mongodb的大括号匹配也着实坑,注意逗号的使用
解决方案:
按照上述标准代码来进行过滤最为合适 。
更多推荐
已为社区贡献2条内容
所有评论(0)