我有一些日志数据存储在一个 mongo 集合中，其中包括作为 request_id 的基本信息以及它被添加到集合中的时间，例如:

{
    "_id" : ObjectId("55ae6ea558a5d3fe018b4568"),
    "request_id" : "030ac9f1-aa13-41d1-9ced-2966b9a6g5c3",
    "time" : ISODate("2015-07-21T16:00:00.00Z")
}

我想知道是否可以使用聚合框架来聚合一些统计数据。我想获取过去 X 小时内每个 N 分钟间隔内创建的对象的计数。

所以我在过去 1 小时内每隔 10 分钟需要的输出应该如下所示:

{ "_id" : 0, "time" : ISODate("2015-07-21T15:00:00.00Z"), "count" : 67 }
{ "_id" : 0, "time" : ISODate("2015-07-21T15:10:00.00Z"), "count" : 113 }
{ "_id" : 0, "time" : ISODate("2015-07-21T15:20:00.00Z"), "count" : 40 }
{ "_id" : 0, "time" : ISODate("2015-07-21T15:30:00.00Z"), "count" : 10 }
{ "_id" : 0, "time" : ISODate("2015-07-21T15:40:00.00Z"), "count" : 32 }
{ "_id" : 0, "time" : ISODate("2015-07-21T15:50:00.00Z"), "count" : 34 }

我会用它来获取图表数据。

感谢任何建议!

最佳答案

根据哪种输出格式最适合您的需求，有多种方法可以解决这个问题。主要注意事项是 "aggregation framework"就其本身而言，您实际上不能将某些“转换”为日期的内容返回，但您可以获得在 API 中处理结果时轻松重构为 Date 对象的值。

第一种方法是使用 "Date Aggregation Operators"可用于聚合框架:

db.collection.aggregate([
    { "$match": {
        "time": { "$gte": startDate, "$lt": endDate }
    }},
    { "$group": {
        "_id": {
            "year": { "$year": "$time" },
            "dayOfYear": { "$dayOfYear": "$time" },
            "hour": { "$hour": "$time" },
            "minute": {
                "$subtract": [
                    { "$minute": "$time" },
                    { "$mod": [ { "$minute": "$time" }, 10 ] }
                ]
            }
        },
        "count": { "$sum": 1 }
    }}
])

它返回 _id 的复合键，其中包含您想要的“日期”的所有值。或者，如果总是在“小时”之内，则只需使用“分钟”部分并根据范围选择的 startDate 计算出实际日期。

或者您可以只使用简单的“日期数学”来获取自“纪元”以来的毫秒数，这可以再次直接馈送到日期构造器。

db.collection.aggregate([
    { "$match": {
        "time": { "$gte": startDate, "$lt": endDate }
    }},
    { "$group": {
        "_id": {
            "$subtract": [
               { "$subtract": [ "$time", new Date(0) ] },
               { "$mod": [
                   { "$subtract": [ "$time", new Date(0) ] },
                   1000 * 60 * 10
               ]}
            ]
        },
        "count": { "$sum": 1 }
    }}
])

在所有情况下，您不想做的是使用 $project在实际申请之前 $group .作为“管道阶段”，$project 必须“循环”所有选定的文档并“转换”内容。

这需要时间，并且会增加查询的执行总数。您可以直接向 $group 申请，如图所示。

或者，如果您真的“纯粹”地希望在没有进行后处理的情况下返回一个 Date 对象，那么您始终可以使用 "mapReduce" ，因为 JavaScript 函数实际上允许重铸为日期，但比聚合框架慢，当然没有游标响应:

db.collection.mapReduce(
   function() {
       var date = new Date(
           this.time.valueOf() 
           - ( this.time.valueOf() % ( 1000 * 60 * 10 ) )
       );
       emit(date,1);
   },
   function(key,values) {
       return Array.sum(values);
   },
   { "out": { "inline": 1 } }
)

你最好的选择是使用聚合，因为转换响应非常容易:

db.collection.aggregate([
    { "$match": {
        "time": { "$gte": startDate, "$lt": endDate }
    }},
    { "$group": {
        "_id": {
            "year": { "$year": "$time" },
            "dayOfYear": { "$dayOfYear": "$time" },
            "hour": { "$hour": "$time" },
            "minute": {
                "$subtract": [
                    { "$minute": "$time" },
                    { "$mod": [ { "$minute": "$time" }, 10 ] }
                ]
            }
        },
        "count": { "$sum": 1 }
    }}
]).forEach(function(doc) {
    doc._id = new Date(doc._id);
    printjson(doc);
})

然后您将获得包含真实 Date 对象的间隔分组输出。

关于mongodb - 时间间隔内的Mongo聚合，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/31550552/