PythonでMongoDBへの有効な接続があると仮定します。
次のコードスニペットは、result.
pipeline = [
{"$unwind": "$COL"},
{"$group": {"_id": "$LOC", "sum": {"$sum": "$COL.amount"}}}
]
cursor = collection.aggregate(pipeline)
これで、cursor
を変換できます リストする
result = list(cursor)
結果の値を出力すると、シェルクエリとまったく同じ結果が得られます。
[{u'sum': 200.0, u'_id': u'User001'}]
更新 :
あなたがaggregate
を呼んでいるようです Pythonコードでdb.docs.aggregate(pipeline)
として機能します 。docs.aggregate...
と呼ぶ必要があります db
なし 。上記の例を参照してください。