1

我还没有问另一个 Map/Reduce 问题。

我有一个集合“ example”，看起来像这样：

{
"userid" : "somehash",
"channel" : "Channel 1"
}

我的 Map/Reduce 函数如下所示：

var map = function () {
    emit(this.channel, {user:this.userid, count: 1});
}

var reduce = function (key, values) {
    var result = {total:0, unique:0};
    var temp = [];
    values.forEach(function (value) {
        result.total += value.count;

        if (temp.indexOf(value.user) == -1) {
            temp.push(value.user);
        }
    });

    result.unique += temp.length;

    return result;
}

不幸的是，它给了我一些非常奇怪的结果：

{ "_id" : "Channel 1", "value" : { "total" : NaN, "unique" : 47 } }
{ "_id" : "Channel 2", "value" : { "total" : NaN, "unique" : 12 } }
{ "_id" : "Channel 3", "value" : { "total" : 6, "unique" : 6 } }

似乎value.count解析为null，似乎“唯一”也不是正确的值。我想要做的是计算每个通道的所有值，并以我可以看到每个用户的唯一值的方式计算它。这意味着，此集合中的一个文档example, 可能会出现多次。我想知道所有时间和独特的时间。

我遵循了本指南：http ://www.mongodb.org/display/DOCS/MapReduce#MapReduce-ReduceFunction ，我不知道为什么我会null被扔在脸上？很奇怪，关于这个主题有什么好的想法吗？

感谢您的建议和更好的智慧。

4

2 回答 2

4

发生这种情况的原因是因为map/reduce 有时会触发自身，即reduce 会触发reduce 的结果。但是reduce的结果没有count字段。您必须始终确保 map 发出和 reduce 结果具有相同的格式。在文档中阅读有关此内容的更多信息。

编辑这是一个简单的演示如何解决这个问题：

var map = function () {
    emit(this.channel, { user: [this.userid], count: 1 });
}

var reduce = function (key, values) {
    var result = { user: [], count: 0 };
    values.forEach(function (value) {
        result.count += value.count;

        value.user.forEach(function(usr) {
            if (result.user.indexOf( usr ) == -1) {
                result.user.push( usr );
            }
        });
    });

    return result;
}

现在result.user.length应该给你独特的用户。没有测试它，但它应该工作。

编辑 2它应该很慢，.indexOf是一个相当昂贵的功能。您可以通过制作两个 map/reduce 作业来加快速度。首先，您像这样映射/减少集合：

var map = function() {
    // make a key unique per channel and userid
    emit( this.channel + '_' + this.userid,
        { count: 1, channel: this.channel }
    );
}

var reduce = function(key, values) {
    var result = { count: 0, channel: null };
    values.forEach(function( value ) {
        result.count += value.count;
        // Don't worry about these substitutions,
        // these values can't change anyway per key.
        result.channel = value.channel;
    });
    return result;
}

现在count，这个集合会给你一些独特的条目。要获得总数，您可以对这样的结果进行第二次 map/reduce：

var map = function() {
    // Note the key!!!
    emit( this.value.channel, { count: this.value.count } );
}

var reduce = function(key, values) {
    var result = { count: 0 };
    values.forEach(function( value ) {
        result.count += value.count;
    });
    return result;
}

这应该快很多。

于 2012-08-02T13:44:47.307 回答
3

从文档：

因为reduce函数可能会为同一个键多次调用，reduce函数返回的对象的结构必须与map函数发出的值的结构相同

你不这样做，你的 reduce 返回一个带有totalandunique而不是countand的对象user。要么将格式更改为代表按用户分组的格式，要么使用finalize 函数。

于 2012-08-02T13:54:56.763 回答