MongoDB聚合:计算不同的字段

Question

我正在尝试编写一个聚合来识别使用多个支付来源的帐户.典型的数据是.

{
 account:"abc",
 vendor:"amazon",
}
 ...
{
 account:"abc",
 vendor:"overstock",
}

现在,我想制作一个类似于此的帐户列表

{
 account:"abc",
 vendorCount:2
}

我将如何在Mongo的聚合框架中编写它

Answer 1

我通过使用$ addToSet和$ unwind运算符来解决这个问题.

Mongodb聚合计数数组/集大小

db.collection.aggregate([
{
    $group: { _id: { account: '$account' }, vendors: { $addToSet: '$vendor'} }
},
{
    $unwind:"$vendors"
},
{
    $group: { _id: "$_id", vendorCount: { $sum:1} }
}
]);

希望它可以帮助某人

Answer 2

我认为如果你执行下面的查询会更好,这将避免放松

db.t2.insert({_id:1,account:"abc",vendor:"amazon"});
db.t2.insert({_id:2,account:"abc",vendor:"overstock"});


db.t2.aggregate(
{ $group : { _id : { "account" : "$account", "vendor" : "$vendor" }, number : { $sum : 1 } } },
{ $group : { _id : "$_id.account", number : { $sum : 1 } } }
);

这将显示以下预期的结果.

{ "_id" : "abc", "number" : 2 }

Answer 3

我不明白为什么有人必须两次使用$ group

db.t2.aggregate([ { $group: {"_id":"$account" , "number":{$sum:1}} } ])

这将完美无缺.

Answer 4

您可以使用 sets

db.test.aggregate([
    {$group: { 
      _id: "$account", 
      uniqueVendors: {$addToSet: "$vendor"}
    }},
    {$project: {
      _id: 1, 
      vendorsCount: {$size: "$uniqueVendors"}
    }}
]);

Answer 5

此方法不使用 $unwind 和其他额外操作。另外，如果将新内容添加到聚合中，这不会影响任何内容。接受的答案有一个缺陷。如果 $group 中有其他累积字段，则会在接受答案的 $unwind 阶段导致问题。

db.collection.aggregate([{
    "$group": {
        "_id": "$account",
        "vendors": {"$addToSet": "$vendor"}
    }
},
{
    "$addFields": {
        "vendorCount": {
            "$size": "$vendors"
        }
    }
}])