Předpokládám, že máte platné připojení k MongoDB v Pythonu.
Následující fragment kódu vrátí kurzor MongoDB ve result.
pipeline = [
{"$unwind": "$COL"},
{"$group": {"_id": "$LOC", "sum": {"$sum": "$COL.amount"}}}
]
cursor = collection.aggregate(pipeline)
Nyní můžete převést cursor do seznamu
result = list(cursor)
a pokud vytisknete hodnotu výsledku, získáte přesně stejný výsledek jako v dotazu Shell.
[{u'sum': 200.0, u'_id': u'User001'}]
Aktualizovat :
Vidím, že voláte aggregate fungovat v kódu pythonu jako db.docs.aggregate(pipeline) .Musíte to nazvat jako docs.aggregate... bez db . Viz příklad výše.