按名称分组时拆分为时间段

Question

我有一个 MongoDB 集合，division_entry。

我希望按标签过滤，然后按时间和独特的不同值进行存储。 最后，我想要在给定时间跨度内所有不同的唯一值。

目前，我必须在代码中存储并按时间跨度进行调用。这会导致调用过多。 现在 -

db.division_entry.aggregate([{ $match : { $and : [ { "division.label" : “ABCD”}，{“时间戳”：{$gt：1495448249635，$lt：1495448249641}} ] } } , {$group : { _id : "$unique"} } , {$count : "value" }])

非常感谢您对实际结果的帮助。

编辑： 更多详情：

{
            "_id" : "1",
            "timestamp" : NumberLong("1495448249640"),
            "unique" : "One",
            "division" : [
                    {
                            "label" : "ABCD"
                    }
            ]
    }
    {
            "_id" : "3",
            "timestamp" : NumberLong("1495448249636"),
            "unique" : "Two",
            "division" : [
                    {
                            "label" : "ABCD"
                    }
            ]
    }
    {
            "_id" : "2",
            "timestamp" : NumberLong("1495448249650"),
            "unique" : "Two",
            "division" : [
                    {
                            "label" : "ABCD"
                    }
            ]
    }

db.division_entry.aggregate([{ $match : { $and : [ { "division.label": "ABCD"}, { "timestamp" : { $gt: 1495448249635, $lt: 1495448249651 }} ] } } , {$group : { _id : "$unique"} }])
         { "_id" : "Two" }
         { "_id" : "One" }

db.division_entry.aggregate([{ $match : { $and : [ { "division.label" : "ABCD"}, { "timestamp" : { $gt: 1495448249635, $lt: 1495448249651 } } ] } } , {$group : { _id : "$unique"} } , {$count : "value" }])
        { "value" : 2 }

这是在匹配查询中指定的特定时间范围内完成的。假设我想要一天数据的一分钟粒度，我将不得不进行 1440 次这样的调用，其中每次调用的时间戳范围将涵盖一分钟。

我需要帮助来同时为“唯一”字段存储和查找不同的值。

Answer 1

对于定期间隔，最好的办法是执行一些“日期数学”以将文档中的当前"timestamp" 值四舍五入为一个公共间隔值以进行分组。执行此操作的最佳方法是使用标准匹配减去应用于所需间隔的毫秒值的模数（余数）。

在我们提供的聚合框架中，使用$subtract 和$mod 与_id 键中$group@ 中的当前文档"unique" 字段值一起构成复合键的一方：

db.division_entry.aggregate([
  // Sanely restrict to a range of dates to analyse - here is one day
  { "$match": { 
    "timestamp": { "$gte": 1495670400000, "$lt": 1495756800000 }
  }},

  // Group by interval - example of 1 hour ( 1000ms * 60sec * 60min )
  { "$group": {
    "_id": {
      "time": {
        "$subtract": [
          "$timestamp",
          { "$mod": [ "$timestamp", ( 1000 * 60 * 60 ) ] }
        ]
      },
      "unique": "$unique"
    },
    "count": { "$sum": 1 }
  }}
])

因此，对于不同的间隔，您只需提供所需间隔的数学运算：

• 1分钟（1000 * 60）
• 1小时（1000 * 60 * 60）
• 1天（1000*60*60*24）

---

仅供参考，有一个新引入的$bucket 运算符，但它的目的是用于不统一的“切点”。即 0-5 分钟、6-20 分钟、20-50 分钟和超过 50 分钟作为示例用例。

对于任何“统一”的东西，基于数学的方法是最有效的实现方法。

Answer 2

这是基于/启发自 Neil 的回答。

我还想要的是不同的时间间隔和其中唯一 uuid 的数量。他提供的答案给出了，对于每个唯一的 uuid，它在一个时间间隔内出现的次数，也就是在 q 中。

db.divisive_entry.aggregate([
  { "$match": { 
    "timestamp": { "$gte": 1395448852351, "$lt": 1497428775000 }
  }},

  { "$group": {
    "_id": {
      "time": {
        "$subtract": [
          "$timestamp",
          { "$mod": [ "$timestamp", ( 1000 * 60 * 60 ) ] }
        ]
      },
      "unique": "$unique"
    },
  }},

  { "$group": 
    {
        "_id": "$_id.time",
        "count" : { "$sum": 1 }
    }
  }
])