最近使用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的大括号匹配也着实坑,注意逗号的使用
按照上述标准代码来进行过滤最为合适 。