当前位置: 首页 > 工具软件 > Qmgo > 使用案例 >

golang mongodb 聚合(Aggregate) github.com/qiniu/qmgo框架

韩彦君
2023-12-01

项目场景:

最近使用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的大括号匹配也着实坑,注意逗号的使用


解决方案:

按照上述标准代码来进行过滤最为合适 。

 类似资料: