mongodb - 按 ObjectId 日期聚合 MongoDB 结果

标签 mongodb pymongo aggregation-framework

如何按 ObjectId 日期聚合我的 MongoDB 结果。示例:

默认光标结果:

cursor = [
    {'_id': ObjectId('5220b974a61ad0000746c0d0'),'content': 'Foo'},
    {'_id': ObjectId('521f541d4ce02a000752763a'),'content': 'Bar'},
    {'_id': ObjectId('521ef350d24a9b00077090a5'),'content': 'Baz'},
]

预计结果:

projected_cursor = [
    {'2013-09-08':
        {'_id': ObjectId('5220b974a61ad0000746c0d0'),'content': 'Foo'},
        {'_id': ObjectId('521f541d4ce02a000752763a'),'content': 'Bar'}
    },
    {'2013-09-07':
        {'_id': ObjectId('521ef350d24a9b00077090a5'),'content': 'Baz'}
    }
]

这是我目前在 PyMongo 中使用来实现这些结果的方法,但它很困惑,我想看看如何使用 MongoDB 的聚合框架(甚至 MapReduce)来做到这一点:

cursor = db.find({}, limit=10).sort("_id", pymongo.DESCENDING)
messages = [x for x in cursor]
this_date = lambda x: x['_id'].generation_time.date()
dates = set([this_date(message) for message in messages])
dates_dict = {date: [m for m in messages if this_date(m) == date] for date in dates}

是的,我知道最简单的方法是简单地为每条记录添加一个新的日期字段,然后按此聚合,但这不是我现在想要做的。

谢谢!

最佳答案

更新:现在有一种内置方法可以做到这一点,请参阅 https://stackoverflow.com/a/51766657/295687

没有办法用 mongodb 完成你的要求 聚合框架,因为没有聚合运算符 可以将 ObjectId 变成类似日期的东西(不过有一个 JIRA ticket )。你 应该能够使用 map-reduce 完成您想要的,但是:

// map function
function domap() {
    // turn ObjectId --> ISODate
    var date = this._id.getTimestamp();
    // format the date however you want
    var year = date.getFullYear();
    var month = date.getMonth();
    var day = date.getDate();

    // yields date string as key, entire document as value
    emit(year+"-"+month+"-"+day, this);
}

// reduce function
function doreduce(datestring, docs) {
    return {"date":datestring, "docs":docs};
}

关于mongodb - 按 ObjectId 日期聚合 MongoDB 结果,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/18691689/

相关文章:

node.js - 不在特定时间段内聚合数据

mongodb 多个组在一个结果中

mongodb - Mongodb 将值拆分为 5 分钟间隔并返回间隔组内的最新值

mongodb - pymongo - TypeError : document must be an instance of dict, bson.son.SON,或从collections.MutableMapping继承的其他类型

ruby-on-rails - 在 Mongo 数据库中克隆文档

scala - 如何检索 Mongodb 集合中的所有对象,包括 id?

javascript - 如何求和数据库中的字段

python - Django MongoDB 引擎 DebugCursor "not JSON serializable"

python - pymongo: ImportError: 没有名为 pymongo 的模块

MongoDB 初始部署和索引