mongodb - pymongo map-reduce 无法根据查询工作

Question

我有一个收藏：

{sentiment: "some_sentiment",
words: Array_of_words
}

我有这个地图功能：

function () {
        for (var w=0; w < this.words.length; w++) {
            emit(this.words[w], 1)
        }
        
    }

这是我的减少功能：

function (word, values) {
        return Array.sum(values)
    }

这是我的电话：

collection_obj.map_reduce(map_func, reduce_func, output_collection, query={'sentiment': "some_sentiment"})

目标是根据情绪将文档分成不同的集合，并计算 words_array 中的单词在具有相同情绪的文档中出现的次数。

这必须通过 MAP_REDUCE 完成，不要建议聚合。

我是通过pymongo做的，map函数和reduce函数的代码是由bson的代码类编译的，我认为问题可能出在我的调用上，idk ...

标签： mongodbmapreducepymongo

Answer 1

好的，我知道了，它的query=query，不仅仅是查询