需要在MongoDB中对数组对象的值进行求和

Question

需要在MongoDB中对数组对象的值进行求和

5

我正在尝试计算总值，如果该值存在的话。但是查询并没有完全成功。所以有人能帮助我解决这个问题吗？这是我的样本文件。我已经附上了两个文档，请查看这些文档并找出最佳解决方案。文档：1

{
    "_id" : 1"),
    "message_count" : 4,
    "messages" : {
        "data" : [ 
            {
                "id" : "11",
                "saleValue": 1000
            }, 
            {
                "id" : "112",
                "saleValue": 1400
            }, 
            {
                "id" : "22",

            }, 
            {
                "id" : "234",
                "saleValue": 111
            }
        ],

    },
    "createdTime" : ISODate("2018-03-18T10:18:48.000Z")
}

文档：2

 {
        "_id" : 444,
        "message_count" : 4,
        "messages" : {
            "data" : [ 
                {
                    "id" : "444",
                    "saleValue" : 2060
                }, 
                {
                    "id" : "444",
                }, 
                {
                    "id" : 234,
                    "saleValue" : 260
                }, 
                {
                    "id" : "34534",
                }
            ]
        },

        "createdTime" : ISODate("2018-03-18T03:11:50.000Z")
    }

需要的输出：

{
   total : 4831
}

我的查询：

db.getCollection('myCollection').aggregate([
    {
        "$group": {
            "_id": "$Id",

            "totalValue": {
                $sum: {
                    $sum: "$messages.data.saleValue"
                }
            }

        }
    }
])

如果可能的话，请帮忙解决这个问题。非常感谢。

- Nazmul

1

使用unwind函数对 data 数组展开，并累加 data.value。 - Clement Amarnath

5个回答

1

你可以在 $group 前添加 $unwind，这样你就可以将数据数组解构，然后正确地进行分组：

db.myCollection.aggregate([
{
    "$unwind": "$messages.data"
},
{
    "$group": {
        "_id": "tempId",
        "totalValue": {
            $sum: {
                $sum: "$messages.data.value"
            }
        }
    }
}
])

输出：

{ "_id" : "tempId", "totalValue" : 1320 }

- Alejandro Montilla

1

db.getCollection('myCollection').aggregate([
   {
     $unwind: "$messages.data",
     $group: {
        "_id": "tempId",
        "totalValue": { $sum: "$messages.data.value" }
     }
   }
])

$unwind

，这段代码与编程有关。

- Clement Amarnath

1

根据上述问题描述，作为解决方案，请尝试执行以下聚合查询。

db.myCollection.aggregate(

    // Pipeline
    [
        // Stage 1
        {
            $unwind: {
                path: '$messages.data'
            }
        },

        // Stage 2
        {
            $group: {
                _id: {
                    pageId: '$pageId'
                },
                total: {
                    $sum: '$messages.data.saleValue'
                }
            }
        },

        // Stage 3
        {
            $project: {
                pageId: '$_id.pageId',
                total: 1,
                _id: 0
            }
        }

    ]


);

- Rubin Porwal

1

您可以不使用$group。分组会使其他数据变得更加复杂，难以管理和处理。因此，我更喜欢使用下面所示的$sum和$map：

db.getCollection('myCollection').aggregate([
 {
   $addFields: {
      total: {
          $sum: {
            $map: {
              input: "$messages.data",
              as: "message",
              in: "$$message.saleValue",
            },
          },
        },
      },
    }, 
  } 
])

- Sudip Bhujel

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- chridam · Accepted Answer

它没有正确运行，因为它正在聚合集合中的所有文档；您正在对一个常量"_id": "tempId"进行分组，您只需要通过添加$引用正确的键：

db.getCollection('myCollection').aggregate([
    { "$group": {
        "_id": "$tempId",
        "totalValue": { 
            "$sum": { "$sum": "$messages.data.saleValue" } 
        }
    } }
])

本质上，这是聚合操作的单阶段管道版本，其中有一个额外的字段来保存组管道之前的求和表达式，并将该字段作为组中的$sum运算符调用。

以上工作是因为MongoDB 3.2+中的$sum在$project和$group阶段都可用，当在$project阶段中使用时，$sum返回表达式列表的总和。表达式"$messages.data.value"返回数字列表[120, 1200]，然后将其用作$sum表达式：

db.getCollection('myCollection').aggregate([
    { "$project": {
        "values": { "$sum": "$messages.data.value" },
        "tempId": 1,
    } },
    { "$group": {
        "_id": "$tempId",
        "totalValue": { "$sum": "$values" }
    } }
])