【发布时间】:2015-03-04 04:11:28
【问题描述】:
我收到如下错误: Traceback(最近一次调用最后一次):
pymongo.errors.OperationFailure: 命令 SON([('mapreduce', u'tweets'), ('map', Code('function() { emit(this.via, 1); }', {})), ('reduce', Code(' function(key,value) {\n var res = 0;\n values.forEach(function(v) {res += 1 })\n return {count: res};\n }\n ', {})), ('out', 'via_count')]) 在命名空间 Corpus.$cmd 失败:ns 不存在
代码是:
from pymongo import MongoClient
from bson.code import Code
con = MongoClient()
db = con.Corpus
tweets = db.tweets
map = Code("function() { emit(this.via, 1); }")
reduce = Code(""" function(key,value) {
var res = 0;
values.forEach(function(v) {res += 1 })
return {count: res};
}
""")
result = tweets.map_reduce(map, reduce, "via_count")
for doc in db.via_count.find():
print(doc)
【问题讨论】:
-
这有什么更新吗?我遇到了同样的错误
标签: mapreduce