pymongo mapreduce db聲明失敗

Question

我剛剛開始使用mongo和map/reduce，並且我在使用pymongo時遇到了以下錯誤，我沒有在直接使用mongo命令行時獲得（我意識到是這個問題的一個類似的問題，但我的看起來更基本）。

我使用的是例如直接從pymongo文檔：http://api.mongodb.org/python/1.3%2B/examples/map_reduce.html

from pymongo import Connection 
from pymongo.code import Code 

db = Connection().map_reduce_example 
db.things.insert({"x": 1, "tags": ["dog", "cat"]}) 
db.things.insert({"x": 2, "tags": ["cat"]}) 
db.things.insert({"x": 3, "tags": ["mouse", "cat", "dog"]}) 
db.things.insert({"x": 4, "tags": []}) 


m = Code("function() {this.tags.forEach(function(z) {emit('d, 1);});}") 
m = Code("function() {emit('dog', 1);}") 

r = Code("function (key, values) {var total = 0;for (var i = 0; i < values.length; i++) {total += values[i];}return total;}") 


result = db.things.map_reduce(m, r) 

這給了我下面的錯誤：

Traceback (most recent call last): 
    File "demo.py", line 17, in <module> 
    result = db.things.map_reduce(m, r) 
    File "/usr/local/lib/python2.6/dist-packages/pymongo-1.9-py2.6-linux-i686.egg/pymongo/collection.py", line 943, in map_reduce 
    map=map, reduce=reduce, **kwargs) 
    File "/usr/local/lib/python2.6/dist-packages/pymongo-1.9-py2.6-linux-i686.egg/pymongo/database.py", line 293, in command 
    msg, allowable_errors) 
    File "/usr/local/lib/python2.6/dist-packages/pymongo-1.9-py2.6-linux-i686.egg/pymongo/helpers.py", line 119, in _check_command_response 
    raise OperationFailure(msg % response["errmsg"]) 
pymongo.errors.OperationFailure: command SON([('mapreduce', u'things'), ('map', Code("function() {emit('dog', 1);}", {})), ('reduce', Code('function (key, values) {var total = 0;for (var i = 0; i < values.length; i++) {total += values[i];}return total;}', {}))]) failed: db assertion failure 

然而，定義的map/reduce在蒙戈和運行功能以下命令的工作原理如下：

db.things.mapReduce(mm,r,{out:{inline:1}}) 

定義d似乎是{out：{inline：1}}選項。有沒有辦法讓pymongo進入電話會議？

感謝，

亞當。

Answer 1

該問題與「out」參數有關。從MongoDB 1.7.4開始，'out'參數是必需的，您在調用map_reduce時必須始終指定輸出集合的名稱。

result = db.things.map_reduce(m, r, "output_collection_name") 

如果要在內存中執行整個MapReduce操作，請調用inline_map_reduce。

result = db.things.inline_map_reduce(m, r) 

以上例子僅pymongo的最新版本從Git倉庫中直接得到工作。對於MongoDB 1.7.4或更高版本，pymongo 1.9並不適用。