MongoDB按小时聚合每日记录答案

【问题标题】：MongoDB aggregation of daily records hourly basisMongoDB按小时聚合每日记录
【发布时间】：2021-07-21 14:33:31
【问题描述】：

我有以下格式的集合或订单：

"createTime" : ISODate("2021-04-16T08:01:39.000Z"),
"statusDetails" : [ 
    {
        "createTime" : ISODate("2021-04-16T08:01:39.000Z"),
        "createUser" : "FOP-SYSTEM",
        "stateOccurTimeStr" : "2021-04-16 15:01:39",
        "status" : 27,
        "statusDesc" : "Shipped"
    }
]

createTime 显示订单的创建时间
statusDetails.status = 27 显示订单已发货
statusDetails.createTime 显示订单何时发货

我需要的结果是这样的：

Order Date	0-4 Hours	4-8 Hours	8-12 Hours	12-24 Hours	> 24 Hours	Total Orders
01-Jan-21	15	10	4	1	1	31

这表明在订单创建后的“2021 年 1 月 1 日”，

15 orders shipped between 0-4 hours, 
10 orders shipped between 4-8 hours, 
4 orders shipped between  8-12 hours

等等。

到目前为止我所做的是：

db.orders.aggregate([
   { $unwind : "$statusDetails"},
   {$match: {"statusDetails.status": { "$exists": true, "$eq": 24 }}},
   {$project : { createTime: 1,statusDetails:1, 
      dateDiff: {"$divide" : [{ $subtract: ["$statusDetails.createTime","$createTime" ] },3600000]}}},
   {$sort:{"createTime":-1}}
   ])

但这显示了每条记录的时间差，但我需要分组

编辑我更新了我的查询，现在它使用 $group 显示记录，但我仍然需要添加另一个管道来对当前数据进行分组。

db.orders.aggregate([
   
   { $unwind : "$statusDetails"},
   {$match: {"statusDetails.status": { "$exists": true, "$eq": 27 }}},
   {$project : { createTime: 1,statusDetails:1, dateDiff:{"$floor": {"$divide" : [{ $subtract: ["$statusDetails.createTime","$createTime" ] },3600000]}}}},
    { 
        $group: 
        { _id: {  year : { $year : "$createTime" }, month : { $month : "$createTime" }, day : { $dayOfMonth : "$createTime" }},
        shippedTime: { $push: "$dateDiff" },
        count: { $sum: 1 }
        } 
    },
   
   
   
   {$sort:{"createTime":-1}}
])

【问题讨论】：

您可以在管道末尾添加一个 $group 阶段 - 并按订单日期分组。
是的，我在项目 { $group: { _id: { year : { $year : "$createTime" }, month : { $month : "$createTime" }, day : { $dayOfMonth : "$createTime" }}, avgTime: { $avg: "$dateDiff" } } }，但这并不能解决问题

标签： database mongodb data-science aggregation

【解决方案1】：

$unwind解构statusDetails数组
$match你的条件
$addFields 在您的日期计算时间段的基础上添加 slot 字段并从公式中获取总数
$group date 根据您的格式使用 $dateToString 和 slot
$sort slot 按升序排列
$group 仅通过 date 并构造插槽数组并获得总订单

db.collection.aggregate([
  { $unwind: "$statusDetails" },
  { $match: { "statusDetails.status": 27 } },
  {
    $addFields: {
      slot: {
        $multiply: [
          {
            $floor: {
              $divide: [
                {
                  $abs: {
                    "$divide": [
                      { $subtract: ["$statusDetails.createTime", "$createTime"] },
                      3600000
                    ]
                  }
                },
                4
              ]
            }
          },
          4
        ]
      }
    }
  },
  {
    $group: {
      _id: {
        date: {
          $dateToString: {
            date: "$createTime",
            format: "%d-%m-%Y"
          }
        },
        slot: "$slot"
      },
      total: {
        $sum: 1
      }
    }
  },
  { $sort: { "_id.slot": 1 } },
  {
    $group: {
      _id: "$_id.date",
      hours: {
        $push: {
          slot: "$_id.slot",
          total: "$total"
        }
      },
      totalOrders: { $sum: "$total" }
    }
  }
])

Playground

结果是：

[
  {
    "_id": "16-04-2021",
    "hours": [
      { "slot": 0, "total": 1 }, // from 0 to 4
      { "slot": 4, "total": 1 }, // from 4 to 8
      { "slot": 8, "total": 2 } // from 8 to 12
    ],
    "totalOrders": 4
  }
]

【讨论】：