douxu5845 2019-03-01 21:36
浏览 81
已采纳

mgo将mapreduce转换为聚合命令

I am trying to convert this function here from mapreduce to aggregation.

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

The result from above function will be [{pending 1}].

When I run my match group I get [{pending 0}] from the following code below:

    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)

But the same I think command in mongo shell gives [{pending 1}].

db.getCollection("auth_sets").aggregate([
{
    $match: {
        device_id:"5c79601d152ece00012f5831"
    }
},
{
    $group: {
        _id:"$status",
        count: {
            $sum: 1
        }
     }
},
]);

How can I get it so my pipe will return [{pending 1}]?

I am changing it so I can use Mongo Atlas with does not allow mapreduce.

  • 写回答

1条回答 默认 最新

  • dongtangu6889 2019-03-02 07:07
    关注

    Your mgo query structure is OK, the problem is the name of the count field. The model expects Value:

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

    So change the $group stage to this:

    grp := bson.M{
            "$group": bson.M{
                    "_id": "$status",
                    "value": bson.M{   // Note lowercased "value"!
                            "$sum": 1,
                    },
            },
    }
    

    And it should work. Or change the model if you can:

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

    Only one of them needs to be changed, to be aligned with the other.

    One last thing: If you use Query.One(), then the result must not be a slice (One() expects one document exactly).

    Use a slice type for result if you use e.g. Query.All().

    So if you're going to use Query.One(), use result:

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

    Also Query.One() and Query.All() return an error, do check it!

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥15 请问各位,如何在Jetson nano主控板的Ubuntu系统中安装PyQt5
  • ¥15 MAC安装佳能LBP2900驱动的网盘提取码
  • ¥400 微信停车小程序谁懂的来
  • ¥15 ATAC测序到底用什么peak文件做Diffbind差异分析
  • ¥15 安装ubantu过程中第一个vfat 文件挂载失败
  • ¥20 GZ::CTF如何兼容一些靶机?
  • ¥15 etcd集群部署问题
  • ¥20 谁可以帮我一下问一下各位
  • ¥15 为何重叠加权后love图的SMD与svyCreateTableOne函数绘制基线表的不一致
  • ¥150 求 《小魔指》街机游戏机整合模拟软件