0

我是 mongodbs mapreduce 的新手,当然我现在还没有完全理解它。我有一个问题,我试图解决几天但没有成功。

我收集了一些带有标签字段的帖子。现在我想 mapreduce 一个新的标签集合。每个标签都有一组分配了这个特定标签的所有帖子 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;
};

我知道,我必须以某种方式调整日期,但我就是无法理解它。

4

1 回答 1

0

我认为您在 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,
}
于 2012-07-31T20:35:58.723 回答