根据条件计数并除以时间间隔的记录数

Question

我已经为这个问题准备了 mongoplayground 示例。

https://mongoplayground.net/p/m_G-yBuX6uk

目前它在某些字段上显示基于 15 分钟时间间隔的数据聚合。 有一个名为“presenceStatus”的字段，其值为 0 或 1。

当前结果

 {
        "accountId": ObjectId("5e1fe45cd05bfb0cc549297d"),
        "applicationNumber": 30,
        "area": "area2",
        "avgZoneCountNumber": 0,
        "avgZoneCountNumberInstant": 0,
        "buildingId": ObjectId("5e1fe5e3d05bfb0cc5494146"),
        "createdAt": ISODate("1970-01-01T00:00:00Z"),
        "dateHour": "2020-03-19T18:15:00.000Z",
        "deviceId": ObjectId("5e1fe7a9d05bfb0cc5495cdf"),
        "gatewayId": ObjectId("5e1fe651d05bfb0cc54947f0"),
        "serialNumber": "129300000012",
        "spaceType": null
      },

预期： 我需要找到每个时间间隔的 occupancyRate。

对于 15 分钟间隔，公式是 count presenceStatus = 1 并除以该时间范围内的总记录数。 occupancyRate 字段的预期值应为 % 格式，如下所示。

预期结果：

{
    "accountId": ObjectId("5e1fe45cd05bfb0cc549297d"),
    "applicationNumber": 30,
    "area": "area2",
    "avgZoneCountNumber": 0,
    "avgZoneCountNumberInstant": 0,
    "buildingId": ObjectId("5e1fe5e3d05bfb0cc5494146"),
    "createdAt": ISODate("1970-01-01T00:00:00Z"),
    "dateHour": "2020-03-19T18:15:00.000Z",
    "deviceId": ObjectId("5e1fe7a9d05bfb0cc5495cdf"),
    "gatewayId": ObjectId("5e1fe651d05bfb0cc54947f0"),
    "serialNumber": "129300000012",
    "spaceType": null,
    "occupancyRate": 80%
  },

在 Mongo 操场示例（totalPresent 字段）中，我尝试显示存在状态 = 1 的计数，但它显示为 0。

感谢您的帮助。

Answer 1

如果我理解您的问题，这里是使用$group 的解决方案：

db.sensingresults.aggregate([
  {
    "$lookup": {
      "from": "accounts",
      "localField": "accountId",
      "foreignField": "_id",
      "as": "accountInfo"
    }
  },
  {
    "$unwind": "$accountInfo"
  },
  {
    $addFields: {
      "dateHour": {
        "$dateToString": {
          "format": "%Y-%m-%dT%H",
          "date": "$updatedAt"
        }
      },
      "minuteBucket": {
        "$trunc": {
          "$divide": [
            {
              "$minute": "$updatedAt"
            },
            15.0
          ]
        }
      },
      "device": {
        "$let": {
          "vars": {
            "building": {
              "$arrayElemAt": [
                {
                  "$filter": {
                    "input": "$accountInfo.buildings",
                    "cond": {
                      "$eq": [
                        "$$this._id",
                        "$buildingId"
                      ]
                    }
                  }
                },
                0
              ]
            }
          },
          "in": {
            "$let": {
              "vars": {
                "gateway": {
                  "$arrayElemAt": [
                    {
                      "$filter": {
                        "input": "$$building.gateways",
                        "cond": {
                          "$eq": [
                            "$$this._id",
                            "$gatewayId"
                          ]
                        }
                      }
                    },
                    0
                  ]
                }
              },
              "in": {
                "$arrayElemAt": [
                  {
                    "$filter": {
                      "input": "$$gateway.devices",
                      "cond": {
                        "$eq": [
                          "$$this._id",
                          "$deviceId"
                        ]
                      }
                    }
                  },
                  0
                ]
              }
            }
          }
        }
      }
    }
  },
  {
    $group: {
      _id: {
        area: "$device.area",
        applicationNumber: "$device.applicationNumber",
        accountId: "$accountId",
        dateHour: "$dateHour",
        minuteBucket: "$minuteBucket",
        buildingId: "$buildingId"
      },
      avgZoneCountNumberInstant: {
        $avg: "$zoneCountNumberInstant"
      },
      avgZoneCountNumber: {
        $avg: "$zoneCountNumber"
      },
      total: {
        $sum: 1
      },
      "spaceType": {
        "$first": "$device.spaceType"
      },
      presences: {
        $sum: "$presenceStatus"
      }
    }
  },
  {
    $addFields: {
      occupancyRate: {
        $concat: [
          {
            $toString: {
              $multiply: [
                100,
                {
                  $divide: [
                    "$presences",
                    "$total"
                  ]
                }
              ]
            }
          },
          "%"
        ]
      }
    }
  }
])

结果将是

[
  {
    "_id": {
      "accountId": ObjectId("5e1fe45cd05bfb0cc549297d"),
      "applicationNumber": 30,
      "area": "area2",
      "buildingId": ObjectId("5e1fe5e3d05bfb0cc5494146"),
      "dateHour": "2020-03-19T18",
      "minuteBucket": 1
    },
    "avgZoneCountNumber": 0,
    "avgZoneCountNumberInstant": 0,
    "occupancyRate": "0%",
    "presences": 0,
    "spaceType": null,
    "total": 1
  },
  {
    "_id": {
      "accountId": ObjectId("5e1fe45cd05bfb0cc549297d"),
      "buildingId": ObjectId("5e1fe5e3d05bfb0cc5494146"),
      "dateHour": "2020-03-19T18",
      "minuteBucket": 1
    },
    "avgZoneCountNumber": 0,
    "avgZoneCountNumberInstant": 0,
    "occupancyRate": "0%",
    "presences": 0,
    "spaceType": null,
    "total": 2
  },
  {
    "_id": {
      "accountId": ObjectId("5e1fe45cd05bfb0cc549297d"),
      "buildingId": ObjectId("5e1fe5e3d05bfb0cc5494146"),
      "dateHour": "2020-03-20T18",
      "minuteBucket": 1
    },
    "avgZoneCountNumber": 0.5,
    "avgZoneCountNumberInstant": 0,
    "occupancyRate": "100%",
    "presences": 2,
    "spaceType": null,
    "total": 2
  }
]