Ik neem aan dat je een geldige verbinding hebt met MongoDB in Python.
Het volgende codefragment retourneert een MongoDB-cursor in result.
pipeline = [
{"$unwind": "$COL"},
{"$group": {"_id": "$LOC", "sum": {"$sum": "$COL.amount"}}}
]
cursor = collection.aggregate(pipeline)
Nu kunt u cursor
. converteren naar lijst
result = list(cursor)
en als u de waarde van het resultaat afdrukt, krijgt u precies hetzelfde resultaat als in uw Shell-query.
[{u'sum': 200.0, u'_id': u'User001'}]
Bijwerken :
Ik zie dat je de aggregate
. aanroept functie in python-code als db.docs.aggregate(pipeline)
.Je moet het aanroepen als docs.aggregate...
zonder db
. Zie voorbeeld hierboven.