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 ...

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)