0

PythonでMongoEnginemap_reduce機能を使用しています。

ここにあるMongoDBのドキュメントによると、削減されたデータの処理方法を指定することができます。具体的には、「置換」、「マージ」、「リデュース」のいずれかに引数を指定するか、「インライン」でマッピング/リダクションを実行することができます。

MongoEnginemap_reduce関数と同様のパラメーターを指定する方法についての説明が見つかりません。関数のドキュメントはここにあります。

map_reduce操作の結果を既存のコレクションにマージする方法を誰かが説明できますか？map_reduce操作をインラインで実行できません。

次のコードを使用してmap_reduce操作を実行しています。

map_f = """
    #javascript code
"""

reduce_f = """
    #javascript code
"""

for i in FOO.objects.map_reduce(map_f, reduce_f, "FOOResult"):
    pass

上記の「FOOResult」は、mapreduce操作が発生するたびに特定のキーが上書きされる新しいコレクションです。むしろ、既存のコレクションに同じキーを挿入できるようなものを指定したいと思います。

ご協力ありがとうございました。

4

1 に答える 1

3

さて、これを認識しないのは少しばかげています。

解決：

for i in FOO.objects.map_reduce(map_f, reduce_f, {"merge":"COLLECTION_NAME"}):
    pass
于 2012-08-06T22:53:08.213 に答える