我有这个收藏

{
    "_id" : ObjectId("54f46f18c36dcc206d0cec38"),
    "project" : 23123,
    "title" : "Change of windows",
    "description": "Change to better windows on building A"
    "costs":[
      {
        category: 'Produktionskostnad',
        value: 3000
      },
      {
        category: 'Projekteringskostnad',
        value: 2000
      },
      {
        category: 'Overhead',
        value: 1000
      }
    ],
    "energySaving" : [ 
        {
            "energy" : "electricity",
            "type" : "lighting",
            "value" : 24324
        }, 
        {
            "energy" : "electricity",
            "type" : "equipment",
            "value" : 24324
        }, 
        {
            "energy" : "electricity",
            "type" : "fans",
            "value" : 24324
        }, 
        {
            "energy" : "electricity",
            "type" : "distribution",
            "value" : 24324
        }, 
        {
            "energy" : "electricity",
            "type" : "chiller",
            "value" : 24324
        }, 
        {
            "energy" : "electricity",
            "type" : "other",
            "value" : 24324
        }
    ]
}

我需要一个计算总成本和总节能的聚合。

为了节省开支，我有以下查询:

db.collection.aggregate( [
    { $unwind: "$energySaving" },
    { 
       $group: {
          _id: {
             title: '$title',
             description: '$description' 
          },
          totalEnergySaving: { $sum: '$energySaving.value' } 
       } 
    }
]);

但是如何计算同一查询中的总成本？我不能在同一个查询中添加 $unwind 成本。我可以以某种方式“重置” $group 并再次查询吗？

最佳答案

TLDR;

在现代 MongoDB 版本中，我们只需执行一个 $group因为我们可以将数组项直接传递给 $sum “数组总和”和“累加器”连续使用“双”表示法:

db.collection.aggregate([
    { "$group": {
        "_id": {
            "title": "$title",
            "description": "$description"
        },
        "totalCosts": { "$sum": { "$sum": "$costs.value" } },
        "totalEnergySaving": { "$sum": { "$sum": "$energySaving.value" } }
     }}
 ])

2015 年原始答案

这需要一些杂耍才能正确完成，但描述它的最佳方式是“首先处理每个文档的分组”，然后“稍后对总数进行分组”:

db.collection.aggregate([
    // Do cost per document
    { "$unwind": "$costs" },
    { "$group": {
        "_id": "$_id",
        "title": { "$first": "$title" },
        "description": { "$first": "$description" },
        "totalCosts": { "$sum": "$costs.value" },
        "energySaving": { "$first": "$energySaving" }
    }},

    // Do energy saving per document
    { "$unwind": "$energySaving" },
    { "$group": {
        "_id": "$_id",
        "title": { "$first": "$title" },
        "description": { "$first": "$description" },
        "totalCosts": { "$first": "$totalCosts" },
        "totalEnergySaving": { "$sum": "$energySaving.value" }
    }},

    // Now sum the real grouping
    { "$group": {
        "_id": {
            "title": "$title",
            "description": "$description"
        },
        "totalCosts": { "$sum": "$totalCosts" },
        "totalEnergySaving": { "$sum": "$totalEnergySaving" }
    }}
])

通过从数组值中计算出每个文档的奇异值，并通过展开和分组“一次一个数组”以避免复制每个数组成员的项目，您可以形成实际的奇异分组的基础想要。

所以当你 $unwind一个数组，您可以获得文档的多个副本，每个数组成员现在在每个文档副本中表示为一个奇异值。您不想在这里做的是 $unwind 另一个数组，而您已经有一个未缠绕的数组，因为根据该数组在同样的方式。

使用 $group回到文档 _id 值此时确保我们只处理最初“解开”的文档的原始部分。普通分组运算符，如 $sum仍然适用，但 $first可用于仅提取“数组外”复制的字段值中的“一个”，并将文档返回到您要保留的字段的“原始形式”以及您有意从数组中聚合的任何内容内容。

对您想要的每个数组重复，然后继续执行另一个 $group 语句，这一次将不止一个文档与您之前创建的新奇异总和值相加。

这是在任何级别的分组中添加多个数组项的过程。当然，如果无论如何只在文档级别进行分组，您可以在对每个数组进行分组后放弃，或者确实接受在客户端代码中进行可能更好。

关于mongodb - 聚合来自两个数组的 $sum 值，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/28827516/