0

我正在尝试汇总来自不同设备的一些信息。给定一组设备 ID，我想计算值出现的次数。我正在努力解决的问题是我们只想处理每台设备的最后一份报告。

例如，4 台设备在报告集合中存储了数十万份报告。报告告诉我们是否存在 networkDown 事件（布尔值）。我想在 4 个设备的最后报告中计算 networkDown 是真还是假的次数。

我正在使用 mongoDB 2.4.4

一份报告与此类似：

{
  "_id":ObjectId("52571500fa1fc70437000001"),
  "device_id" : ObjectId("51f14f9f9809c4404f00000a"),
  "payload":{
    "name":"Status",
    "properties":{
      "property":{
        "deviceIdentifier":"My Device",
        "networkDown":"false"
      }
    }
  },
  "updated_at":ISODate("2013-10-10T20:58:40.674Z"),
  "created_at":ISODate("2013-10-10T20:58:40.674Z")
}

我可以对所有 4 台设备的所有记录执行的组。说，

  db.report.aggregate(
  [
    { $match: { device_id: 
        {
          $in:         
          [
            ObjectId("51f14f9f9809c4404f00000a"),
            ObjectId("523ab68a9809c4e490000059"),
            ObjectId("522f37b89809c4e8cf000033"),
            ObjectId("522f38019809c4ae070000d3")        
          ]
        }
      }
    },    
    { $group: { _id: "$payload.properties.property.networkDown", total: { $sum: 1 } } }                     
  ])


{
    "result" : [
        {
            "_id" : "true",
            "total" : 2
        },
        {
            "_id" : "false",
            "total" : 278539
        }
    ],
    "ok" : 1
}

但是如何将查询限制为仅对每个设备的最后一个报告起作用？

感谢您的关注！

4

1 回答 1

0

您将首先根据 .The 进行排序，{updated_at:1}然后按 device_id 分组并使用$last运算符仅获取最后一个 networkDown 字段，因为文档已排序。然后在 networkDown 属性上做另一组。我知道它有点复杂，但这是查询：

db.reports.aggregate(
[
 { $match: { device_id: 
        {
          $in:         
          [
            ObjectId("51f14f9f9809c4404f00000a"),
            ObjectId("523ab68a9809c4e490000059"),
            ObjectId("522f37b89809c4e8cf000033"),
            ObjectId("522f38019809c4ae070000d3")        
          ]
        }
      }
    },
    {$sort:{updated_at:1}},
    {$group:
       {_id:"$device_id",
        networkDown:{$last:"$payload.properties.property.networkDown"}
       }
    },
    {$group:{_id:"$networkDown",count:{$sum:1}}}
])

我没有正确尝试过，但它应该可以工作。如果有任何问题，请告诉我

于 2013-10-11T07:36:40.887 回答