MongoDB：通过拆分id进行聚合和分组

Question

我的模式实现受到了mongo官方网站上这篇教程的影响

{  
  _id: String,
  data:[
        {
         point_1: Number,
         ts: Date
        }
  ]
}

这基本上是为时间序列数据设计的模式，我将每个设备每小时的数据存储在单个文档中的数组中。我创建_id字段组合发送数据和时间的设备id。例如，如果id为xyz1234的设备在2018-09-11 12:30:00发送数据，则我的 字段将变为 xyz123 4:2018091112

如果该设备的那一小时的文档不存在，我会创建新文档，否则我会将数据推送到data数组。

client.db('iot')
.collection('iotdata')
.update({_id:id},{$push:{data:{point_1,ts:date}}},{upsert:true});

现在我在做聚合时遇到了问题。我试图得到这些类型的值

• 过去 24 小时内许多设备的最小point_1值，按设备 ID 分组
• 过去 24 小时内许多设备的最大point_1值，按设备 ID 分组
• 过去 24 小时内按设备 ID 分组的多个设备的平均point_1

我认为这是非常简单的聚合，然后我意识到设备ID不是直接的，而是与时间数据混合在一起的，所以按设备ID分组数据不是那么直接。我如何根据设备ID拆分_id和组？我尽力把问题写得尽可能清楚，所以如果问题的任何部分不清楚，请在评论中提问。




Answer 1

您可以在3.6中使用下面的查询。

db.colname.aggregate([
  {"$project":{
    "deviceandtime":{"$split":["$_id", ":"]},
    "minpoint":{"$min":"$data.point_1"},
    "maxpoint":{"$min":"$data.point_1"},
    "sumpoint":{"$sum":"$data.point_1"},
    "count":{"$size":"$data.point_1"}
  }},
  {"$match":{"$expr":{"$gte":[{"$arrayElemAt":["$deviceandtime",1]},"2018-09-10 00:00:00"]}}},
  {"$group":{
    "_id":{"$arrayElemAt":["$deviceandtime",0]},
    "minpoint":{"$min":"$minpoint"},
    "maxpoint":{"$max":"$maxpoint"},
    "sumpoint":{"$sum":"$sumpoint"},
    "countpoint":{"$sum":"$count"}
  }},
  {"$project":{
    "minpoint":1,
    "maxpoint":1,
    "avgpoint":{"$divide":["$sumpoint","$countpoint"]}
  }}
])

Answer 2

匿名用户

您可以从对数据的$unwind开始，以获得每个条目的单个文档。然后，您可以使用substr和indexOfBytes操作符获取< code>deviceId。然后，您可以应用您的过滤条件(过去< code>24小时)并使用< code>$group获取< code>min 、< code>max和< code>avg

db.col.aggregate([
    {
        $unwind: "$data"
    },
    {
        $project: {
            point_1: "$data.point_1",
            deviceId: { $substr: [ "$_id", 0, { $indexOfBytes: [ "$_id", ":" ] } ] },
            dateTime: "$data.ts"
        }
    },
    {
        $match: {
            dateTime: { $gte: ISODate("2018-09-10T12:00:00Z") }
        }
    },
    {
        $group: {
            _id: "$deviceId",
            min: { $min: "$point_1" },
            max: { $max: "$point_1" },
            avg: { $avg: "$point_1" }
        }
    }
])