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

你可以使用

sets

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

Answer 4

我不明白为什么有人必须使用

$group

两次。

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

Answer 5

此方法不使用 $unwind 和其他额外操作。另外，如果将新事物添加到聚合中，这不会影响任何事情。已接受的答案存在缺陷。如果您在 $group 中有其他累积字段，它会导致接受答案的 $unwind 阶段出现问题。

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

Answer 6

识别使用多个支付来源的账户：

1. 使用分组统计多个账户记录的数据，并用count按账户对结果进行分组
2. 使用match case是为了只过滤具有多种支付方式的账户

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

这会很好用，

Answer 7

db.UserModule.aggregate(
{ $group : { _id : { "companyauthemail" : "$companyauthemail", "email" : "$email" }, number : { $sum : 1 } } },
{ $group : { _id : "$_id.companyauthemail", number : { $sum : 1 } } }
);

Answer 8

一个例子

db.collection.distinct("example.item").forEach( function(docs) {
    print(docs + "==>>" + db.collection.count({"example.item":docs}))
});