Mongo聚合:将值分区为组(按分区)

问题描述 投票:1回答:1

使用this approach,我可以按时间对一组事件文档进行分组。此解决方案返回相同的输入文档,但添加了分区号。

我怎样才能做同样的事情而是返回分区呢?示例输出文档将是:

{
  partition: 0,
  startDate: ISODate("1900-04-12T18:30:00.000Z"),
  endDate: ISODate("2019-04-12T18:30:00.000Z"),
  numEvents: 27
}
mongodb aggregation-framework
1个回答
1
投票

假设这是您聚合的当前输出:

{
    "_id" : null,
    "datesWithPartitions" : [
        {
            "date" : ISODate("2019-04-12T18:30:00Z"),
            "partition" : 0
        },
        {
            "date" : ISODate("2019-04-12T20:00:00Z"),
            "partition" : 1
        },
        {
            "date" : ISODate("2019-04-12T20:10:00Z"),
            "partition" : 1
        },
        {
            "date" : ISODate("2019-04-12T21:00:00Z"),
            "partition" : 2
        },
        {
            "date" : ISODate("2019-04-12T21:15:00Z"),
            "partition" : 2
        },
        {
            "date" : ISODate("2019-04-12T21:45:00Z"),
            "partition" : 3
        },
        {
            "date" : ISODate("2019-04-12T23:00:00Z"),
            "partition" : 4
        }
    ]
}

要以您需要的格式获取数据,您需要附加以下聚合步骤:

db.col.aggregate([
    {
        $unwind: "$datesWithPartitions"
    },
    {
        $group: {
            _id: "$datesWithPartitions.partition",
            numEvents: { $sum: 1 },
            startDate: { $min: "$datesWithPartitions.date" },
            endDate: { $max: "$datesWithPartitions.date" }
        }
    },
    {
        $project: {
            _id: 0,
            partition: "$_id",
            startDate: 1,
            endDate: 1,
            numEvents: 1
        }
    }
])

$unwind将返回每个文档的单个日期,然后您可以应用$group$min$max来获取分区边界和$sum来计算分区元素

© www.soinside.com 2019 - 2024. All rights reserved.