将mapreduce转换成聚合操作

大家好，今天本人给大家带来文章《将mapreduce转换成聚合操作》，文中内容主要涉及到，如果你对Golang方面的知识点感兴趣，那就请各位朋友继续看下去吧~希望能真正帮到你们，谢谢！

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

https://github.com/mendersoftware/deviceauth/blob/be2f9745e14bbe87121d99ac6c396f41ca7438e2/store/mongo/datastore_mongo.go#l826

上述函数的结果将是 [{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。

解决方案

您的 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，请使用切片类型query.all()。

因此，如果您要使用 query.one()，请使用结果：

var result struct {
    Status string `bson:"_id"`
    Value  int    `bson:"count"`
}

另外 query.one() 和 query.all() 返回错误，请检查它！

好了，本文到此结束，带大家了解了《将mapreduce转换成聚合操作》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！