Presumo che tu abbia una connessione valida a MongoDB in Python.
Il seguente frammento di codice restituirà un cursore MongoDB in result.
pipeline = [
{"$unwind": "$COL"},
{"$group": {"_id": "$LOC", "sum": {"$sum": "$COL.amount"}}}
]
cursor = collection.aggregate(pipeline)
Ora puoi convertire cursor
elencare
result = list(cursor)
e se stampi il valore del risultato, otterrai esattamente lo stesso risultato della query Shell.
[{u'sum': 200.0, u'_id': u'User001'}]
Aggiorna :
Vedo che stai chiamando l'aggregate
funzione nel codice Python come db.docs.aggregate(pipeline)
.Devi chiamarlo come docs.aggregate...
senza db
. Vedi esempio sopra.