我正在尝试在mongodb
中运行一个map/reduce
函数,其中我按集合中对象中包含的 3 个不同字段进行分组。 我可以让map/reduce函数运行,但所有发出的字段在输出集合中一起运行。 我不确定这是否正常,但输出数据进行分析需要更多的工作来清理。 有没有办法将它们分开,然后使用mongoexport
?
让我告诉你我的意思:
我尝试分组的字段是日期、用户 ID(或 uid(和目的地。
我运行这些功能:
map = function() {
day = (this.created_at.getFullYear() + "-" + (this.created_at.getMonth()+1) + "-" + this.created_at.getDate());
emit({day: day, uid: this.uid, destination: this.destination}, {count:1});
}
/* Reduce Function */
reduce = function(key, values) {
var count = 0;
values.forEach(function(v) {
count += v['count'];
}
);
return {count: count};
}
/* Output Function */
db.events.mapReduce(map, reduce, {query: {destination: {$ne:null}}, out: "TMP"});
输出如下所示:
{ "_id" : { "day" : "2012-4-9", "uid" : "1234456", "destination" : "Home" }, "value" : { "count" : 1 } }
{ "_id" : { "day" : "2012-4-9", "uid" : "2345678", "destination" : "Home" }, "value" : { "count" : 1 } }
{ "_id" : { "day" : "2012-4-9", "uid" : "3456789", "destination" : "Login" }, "value" : { "count" : 1 } }
{ "_id" : { "day" : "2012-4-9", "uid" : "4567890", "destination" : "Contact" }, "value" : { "count" : 1 } }
{ "_id" : { "day" : "2012-4-9", "uid" : "5678901", "destination" : "Help" }, "value" : { "count" : 1 } }
当我尝试使用 mongoexport
时,我无法按列分隔日期、uid 或目的地,因为地图将字段组合在一起。
我想要的看起来像这样:
{ { "day" : "2012-4-9" }, { "uid" : "1234456" }, { "destination" : "Home"}, { "count" : 1 } }
这可能吗?
顺便说一句 - 我能够通过将sed
应用于文件并清理 CSV 来使输出工作。 更多的工作,但它奏效了。 如果我能以正确的格式将其从mongodb
中取出,那将是理想的。
MapReduce只返回表单{_id:some_id, value:some_value}
参见:如何更改MongoDB的map-reduce结果的结构?