MongoDB - 一次聚合多个变量的最大值/最小值/平均值

Question

我正在以下列格式将数据记录到 MongoDB 中:

{ "_id" : ObjectId("54f2393f80b72b00079d1a53"), "outT" : 10.88, "inT3" : 22.3, "light" : 336, "humidity" : 41.4, "pressure" : 990.31, "inT1" : 22.81, "logtime" : ISODate("2015-02-28T21:55:11.838Z"), "inT2" : 21.5 }
{ "_id" : ObjectId("54f2394580b72b00079d1a54"), "outT" : 10.88, "inT3" : 22.3, "light" : 338, "humidity" : 41.4, "pressure" : 990.43, "inT1" : 22.75, "logtime" : ISODate("2015-02-28T21:55:17.690Z"), "inT2" : 311.72 }
...

如您所见，有一个时间元素和多个记录的读数。我想汇总所有读数，为按一天中的小时分组的每个变量提供最大最小值和平均值。我已经设法使用以下聚合脚本对单个变量执行此操作:

db.logs.aggregate(
    [ 
        { 
            $match: { 
                logtime: { 
                    $gte: ISODate("2015-03-01T00:00:00.000Z"), 
                    $lt: ISODate("2015-03-03T00:00:00.000Z") 
                }
            }
        }, 
        { 
            $project: {_id: 0, logtime: 1, outT: 1}
        }, 
        {
            $group: {
                _id: {
                    day: {$dayOfYear: "$logtime"},
                    hour: {$hour: "$logtime"}
                }, 
                average: {$avg: "$outT"}, 
                max: {$max: "$outT"}, 
                min:{$min: "$outT"} 
            }
        }
    ]
)

产生:

{ "_id" : { "day" : 61, "hour" : 22 }, "average" : 3.1878750000000116, "max" : 3.44, "min" : 3 }
{ "_id" : { "day" : 61, "hour" : 14 }, "average" : 13.979541666666638, "max" : 17.81, "min" : 8.81 }
...

我想生成如下所示的输出:

{"outT": { output from working aggregation above },
 "inT1": { ... },
 ...
}

我尝试的所有操作似乎都会在 mongo 控制台中引发错误。谁能帮忙？

谢谢

Answer 1

您可以通过将每个统计数据包含在您的 $group 中并使用不同的名称，然后使用 $project 阶段将其 reshape 为您想要的格式来实现此目的:

db.logs.aggregate([
    { 
        $match: { 
            logtime: { 
                $gte: ISODate("2015-02-28T00:00:00.000Z"), 
                $lt: ISODate("2015-03-03T00:00:00.000Z") 
            }
        }
    }, 
    { 
        $project: {_id: 0, logtime: 1, outT: 1, inT1: 1}
    }, 
    {
        $group: {
            _id: {
                day: {$dayOfYear: "$logtime"},
                hour: {$hour: "$logtime"}
            }, 
            outT_average: {$avg: "$outT"}, 
            outT_max: {$max: "$outT"}, 
            outT_min:{$min: "$outT"},
            inT1_average: {$avg: "$inT1"}, 
            inT1_max: {$max: "$inT1"}, 
            inT1_min:{$min: "$inT1"}
        }
    },
    {
        $project: {
            outT: {
                average: '$outT_average',
                max: '$outT_max',
                min: '$outT_min'
            },
            inT1: {
                average: '$inT1_average',
                max: '$inT1_max',
                min: '$inT1_min'
            }
        }
    }        
])

这会为您提供如下所示的输出:

{
    "_id" : {
        "day" : 59,
        "hour" : 21
    },
    "outT" : {
        "average" : 10.88,
        "max" : 10.88,
        "min" : 10.88
    },
    "inT1" : {
        "average" : 22.78,
        "max" : 22.81,
        "min" : 22.75
    }
}