使用 MongoDB 聚合计算多个平均值

Question

我的任务是为 MongoDB 中相当大的一组文档生成日、周、月和年的平均值。

所有作业都有一个created 字段，我需要基于outputs 数组的平均值...

这是文档的样子：

{
  __v: 0,
  _id: ObjectId("535837911393fd0200d8e1eb"),
  created: ISODate("2014-04-23T21:58:41.446Z"),
  output: [
    {
      ref: {
        img: false
      },
      type: "image/png",
      methods: [
        {
          options: {
            height: 200,
            width: 200
          },
          method: "resize"
        }
      ]
    },
    {
      ref: {
        img: false
      },
      type: "image/png",
      methods: [
        {
          options: {
            height: 400,
            width: 400
          },
          method: "resize"
        }
      ]
    }
  ]
}

这是我当前脚本的样子：

JobModel.aggregate([
    {
        $unwind: '$output'
    },
    {
        $group: {
            _id: { $dayOfYear: '$created' },
            day: { $sum: 1 }
        }
},
{
    $group: {
        _id: null,
        avgDay: { $avg: '$day' }
    }
},
{
        $project: {
            _id: 0,
            average: {
                day: '$avgDay'
            }
        }
    }
],
function(err, data) {

    if (err) {
        console.log(err);
        return;
    }

    res.send(data);
    next();

});

我似乎无法找出正确的顺序。有什么建议吗？

Answer 1

真的不知道你在这里追求什么。您说您想要“多个”平均值，但这提出了“多个”基于什么基础的问题？一天中的平均“输出”条目将不同于每月的平均输出条目，甚至不同于每月的每日平均输出条目。所以规模随着每次选择而变化，并不是真正的“每日”、“每月”和“每年”的单个查询

我认为您确实是“离散”总计，最好通过首先找到输出条目的“大小”然后应用每个比例的平均值来接近：

JobModel.aggregate(
    [
        { "$unwind": "$output" },

        // Count the array entries on the record
        { "$group": {
            "_id": "$_id",
            "created": { "$first": "$created" },
            "count": { "$sum": 1 }
        }},

        // Now get the average per day
        { "$group": {
            "_id": { "$dayOfYear": "$created" },
            "avg": { "$avg": "$count" }
        }}
    ],
    function(err,result) {

    }
);

或者实际上使用 MongoDB 2.6 及更高版本，您可以在数组上使用 $size 运算符：

JobModel.aggregate(
    [
        // Now get the average per day
        { "$group": {
            "_id": { "$dayOfYear": "$created" },
            "avg": { "$avg": { "$size": "$output" } }
        }}
    ],
    function(err,result) {

    }
);

因此，合乎逻辑的事情是在您所需的$match 范围内运行每一个，而不是您的“日”、“月”或“年”的聚合键

您可以通过将结果组合到数组中来执行诸如将每天的每日平均值与每月的每日平均值组合起来，然后将每年的每日平均值组合成数组，否则您只会扔掉物品，如果您“只是" 想要当年的日平均值，但要得到完整的结果：

JobModel.aggregate(
    [
        // Now get the average per day
        { "$group": {
            "_id": { 
                "year": { "$year": "$created" },
                "month": { "$month": "$created" },
                "day": { "$dayOfYear": "$created" }
            },
            "dayAvg": { "$avg": { "$size": "$output" } }
        }},

        // Group for month
        { "$group": {
            "_id": {
                "year": "$_id.year",
                "month": "$_id.month"
            },
            "days": { 
                "$push": {
                    "day": "$_id.day",
                    "avg": "$dayAvg"
                }
            },
            "monthAvg": { "$avg": "$dayAvg" }
        }},

        // Group for the year
        { "$group": {
            "_id": "$_id.year",
            "daily": { "$avg": "$monthAvg" },
            "months": {
                "$push": {
                    "month": "$_id.month",
                    "daily": "$monthAvg",
                    "days": "$days"
                }
           }
        }}
    ],
    function(err,result) {

    }
);

但是您想应用它，但您的示例中缺少的主要内容是找到每个文档的原始“输出”数组的“大小”或“计数”，从中获得平均值。