我是mongodbs-mapreduce的新手,当然我现在还没有完全理解它。我有一个问题,我试着解决了好几天都没有成功。
我有一个集合,比方说带有标签字段的帖子。现在我想映射一个新的标签集合。其中,每个标签都有一个所有帖子ID的数组,这些帖子ID分配了一个特定的标签。
我的一次尝试(做得不对)
m = function() {
for (var i in this.tags) {
emit(this.tags[i], {"ids" : [this._id]});
};
}
r = function(key, emits) {
var total = {ids : []}
for (var i in emits) {
emits[i].ids.forEach(function(id) {
total.ids.push(id);
}
}
return total;
};
我知道,我必须调整一下日期,但我就是想不起来。
我认为您的reduce函数中缺少一个")"来关闭emits[I].ids.forEach()。这就是您想要做的吗?
r = function (key, values) {
var total = {ids:[]};
for (var i in values) {
values[i].ids.forEach(
function (id){
total.ids.push(id);
}
);
}
return total;
}
输入
{_id:2, tags: ["dog", "Jenna"]}
{_id:1, tags: ["cat", "Jenna"]}
结果:
{"results" : [
{"_id" : "Jenna",
"value" : {"ids" : [2,1]}
},
{"_id" : "cat",
"value" : {"ids" : [1]}
},
{"_id" : "dog",
"value" : {"ids" : [2]}
}
],
"timeMillis" : 1,
"counts" : {
"input" : 2,
"emit" : 4,
"reduce" : 1,
"output" : 3
},
"ok" : 1,
}