如何解决pymongo map-reduce无法根据查询运行
我有一个收藏集:
{sentiment: "some_sentiment",words: Array_of_words
}
我有这个地图功能:
function () {
for (var w=0; w < this.words.length; w++) {
emit(this.words[w],1)
}
}
这是我的reduce函数:
function (word,values) {
return Array.sum(values)
}
这是我的电话:
collection_obj.map_reduce(map_func,reduce_func,output_collection,query={'sentiment': "some_sentiment"})
目标是按照情感将文档分为不同的集合,并计算相同情感的文档中wordsarray中的单词出现的次数。
这必须通过MAP_REDUCE完成,不要建议汇总。
我正在通过pymongo来执行此操作,map函数和reduce函数的代码是由bson的代码类编译的,我认为问题可能出在我的调用idk ...
解决方法
好吧,我明白了它的query=query
,而不仅仅是查询
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。