mgo 将 mapreduce 转换为聚合命令

Question

我正在尝试将此函数从 mapreduce 转换为聚合。

上述函数的结果将是[{pending 1}]。

当我运行我的匹配组时，我[{pending 0}]从下面的代码中得到：

  mat := bson.M{

            "$match": bson.M{"device_id": devId},

    }

    grp := bson.M{

            "$group": bson.M{

                    "_id": "$status",

                    "count": bson.M{

                            "$sum": 1,

                    },

            },

    }

    pipe := c.Pipe([]bson.M{mat,grp})

    pipe.One(&result)

但我认为 mongo shell 中的命令也一样[{pending 1}]。

db.getCollection("auth_sets").aggregate([

{

    $match: {

        device_id:"5c79601d152ece00012f5831"

    }

},

{

    $group: {

        _id:"$status",

        count: {

            $sum: 1

        }

     }

},

]);

我怎样才能得到它，以便我的管道返回[{pending 1}]？

我正在更改它，以便我可以使用 Mongo Atlas 不允许 mapreduce。

Answer 1

您的mgo查询结构没问题，问题是字段名称count。该模型期望Value：var result []struct {    Status string `bson:"_id"`    Value  int}所以把$group舞台改成这样：grp := bson.M{        "$group": bson.M{                "_id": "$status",                "value": bson.M{   // Note lowercased "value"!                        "$sum": 1,                },        },}它应该有效。或者，如果可以，请更改模型：var result []struct {    Status string `bson:"_id"`    Value  int    `bson:"count"`}只有其中一个需要更改，才能与另一个保持一致。最后一件事：如果您使用Query.One()，则result不能是切片（One()恰好需要一个文档）。result如果您使用 eg ，请使用切片类型Query.All()。因此，如果您要使用Query.One()，请使用结果：var result struct {    Status string `bson:"_id"`    Value  int    `bson:"count"`}另外Query.One()并Query.All()返回错误，请检查它！