使用 $in 查询时如何获取 mongoDB 中每个唯一 id 的 n 个文档？

Question

我有一个集合，可以为每个UID（这是主要键）存储每2秒钟的数据。现在，我想对每个UID查询最后30个文档，并根据其索引编号将其分组。在这种情况下如何进行？如果我申请$限制，则仅返回所有UID的30个文档。

db.getCollection("devices").aggregate(
    [
        { 
            "$match" : { 
                "uID" : { 
                    "$in" : [
                        "20200308", 
                        "20200306", 
                        "12345678"
                    ]
                }
            }
        }
    ], 
    { 
        "allowDiskUse" : false
    }
);

以上查询将返回所有文档，如何将查询限制为每个UID的30个文档？同样，如果查询成功，如何将所有不同文档的数组索引分组，以便我得到一个字段的价值之和，该字段的价值将30个文档分组在一起。示例：

[
    {
        _id: 0,  // index value of all array after grouping them.
        sumOfValuesFoundInArrayIndex: 100,
    },
    {
        _id: 1,
        sumOfValuesFoundInArrayIndex: 600,
    }
    .
    .
    .
    .
    {
        _id: 29,
        sumOfValuesFoundInArrayIndex: 600,
    }
]

JSON示例：

[
  {
    "timeStamp": 1644962269,
    "uID": "20200308",
    "capacityLeft": 500
  },
  {
    "timeStamp": 1644962272,
    "uID": "20200308",
    "capacityLeft": 499
  },
  {
    "timeStamp": 1644962275,
    "uID": "20200306",
    "capacityLeft": 300
  },
  {
    "timeStamp": 1644962277,
    "uID": "20200308",
    "capacityLeft": 499
  },
  {
    "timeStamp": 1644962277,
    "uID": "20200306",
    "capacityLeft": 300
  },
  {
    "timeStamp": 1644962279,
    "uID": "12345678",
    "capacityLeft": 753
  },
  {
    "timeStamp": 1644962281,
    "uID": "12345678",
    "capacityLeft": 752
  },
  {
    "timeStamp": 1644962283,
    "uID": "12345678",
    "capacityLeft": 751
  }
]

现在根据JSON，我需要为每个UID找到30个文档，并使用时间戳对其进行排序，以便当我查询所有提到的设备时，我会为上述UID提供最后30个文档阵列索引，然后总和剩下的所有容量。

Answer 1

在我看来是这样的：

db.collection.aggregate([
{
 $match: {
  uID: {
    $in: [
      "20200308",
      "20200306"
    ]
  }
 }
},
{
 $sort: {
  uID: 1,
  "timeStamp": -1
 }
},
{
 $group: {
  _id: "$uID",
  ts: {
    $push: "$ROOT"
  }
 }
},
{
 $project: {
  ts: {
    $slice: [
      "$ts",
      30
    ]
  }
 }
},
{
  $unwind: "$ts"
},
{
 $group: {
  _id: "$_id",
  sumcapLast30: {
    $sum: "$ts.capacityLeft"
  }
 }
}
])

解释：

1. 匹配所有需要的 uID
2. 按 uID 排序并按时间戳
3. 组按 uID
4. 拼接进行降序，并仅保留 ts 数组中的前 30 个元素。
5. 展开 ts 数组
6. Group 并对每个 uID 的前 30 个元素求和

playground