MongoDB 根据 _id 统计每分钟新文档数

我想创建每分钟存储多少新文档的统计数据。

由于具有标准 ObjectID 的 _id 字段已经包含文档创建的时间戳，我认为应该可以以某种方式使用它。

在 Stackoverflow 上，我发现了以下映射归约代码，可以在有用于创建数据的专用字段时完成它

Map-Reduce 统计 MongoDB 每分钟的文档数量 https://stackoverflow.com/questions/3879371/map-reduce-count-number-of-documents-in-each-minute-mongodb

map = function() {

var created_at_minute = new Date(this.created_at.getFullYear(),
                                 this.created_at.getMonth(), 
                                 this.created_at.getDate(), 
                                 this.created_at.getHours(), 
                                 this.created_at.getMinutes());
    emit(created_at_minute, {count: 1});
}

reduce = function(key, values) { 
         var total = 0;
         for(var i = 0; i < values.length; i++) { total += values[i].count; }
         return {count: total};
}

根据 Mongo DB 文档（http://docs.mongodb.org/manual/reference/object-id/ http://docs.mongodb.org/manual/reference/object-id/）应该可以通过调用 ObjectId("507f191e810c19729de860ea").getTimestamp() 从 _id 获取时间戳。

现在我不知道是否可以在地图函数内部使用这个 getTimestamp() 。

有人知道如何做到这一点或者有更好的方法吗？

我需要它可以在 python 或 php 中实现

您确实可以使用 M/R 来做到这一点。getTimestamp()在 M/R 中工作就像在服务器上以 JavaScript 运行一样，无论您的客户端语言是 PHP 还是 Python：

map = function() {
    var datetime = this._id.getTimestamp();

    var created_at_minute = new Date(datetime.getFullYear(),
                                     datetime.getMonth(),
                                     datetime.getDate(),
                                     datetime.getHours(),
                                     datetime.getMinutes());
    emit(created_at_minute, {count: 1});
}

reduce = function(key, values) {
    var total = 0;
    for(var i = 0; i < values.length; i++) { total += values[i].count; }
    return {count: total};
}

db.so.mapReduce( map, reduce, { out: 'inline' } );
db.inline.find();

输出如下：

{ "_id" : ISODate("2013-08-05T15:24:00Z"), "value" : { "count" : 9 } }
{ "_id" : ISODate("2013-08-05T15:26:00Z"), "value" : { "count" : 2 } }

不过，我建议你不要使用 M/R而是转向聚合框架，因为它更快，因为可以使用索引并同时运行。目前，A/F 没有运算符可以从时间戳中获取时间戳ObjectID田野虽然如此你will还必须存储插入时的时间。 F.e.与这样的文件：

db.so.drop();
db.so.insert( { date: new ISODate( "2013-08-05T15:24:15" ) } );
db.so.insert( { date: new ISODate( "2013-08-05T15:24:19" ) } );
db.so.insert( { date: new ISODate( "2013-08-05T15:24:25" ) } );
db.so.insert( { date: new ISODate( "2013-08-05T15:24:32" ) } );
db.so.insert( { date: new ISODate( "2013-08-05T15:24:45" ) } );
db.so.insert( { date: new ISODate( "2013-08-05T15:25:15" ) } );
db.so.insert( { date: new ISODate( "2013-08-05T15:25:15" ) } );

db.so.aggregate( [
    { $group: {
        _id: {
            y: { '$year': '$date' },
            m: { '$month': '$date' },
            d: { '$dayOfMonth': '$date' },
            h: { '$hour': '$date' },
            i: { '$minute': '$date' },
        },
        count: { $sum : 1 }
    } } 
] );

哪个输出：

{
    "result" : [
        {
            "_id" : {
                "y" : 2013,
                "m" : 8,
                "d" : 5,
                "h" : 15,
                "i" : 25
            },
            "count" : 2
        },
        {
            "_id" : {
                "y" : 2013,
                "m" : 8,
                "d" : 5,
                "h" : 15,
                "i" : 24
            },
            "count" : 5
        }
    ],
    "ok" : 1
}