Предполагам, че имате валидна връзка към MongoDB в Python.
Следният кодов фрагмент ще върне MongoDB курсор в result.
pipeline = [
{"$unwind": "$COL"},
{"$group": {"_id": "$LOC", "sum": {"$sum": "$COL.amount"}}}
]
cursor = collection.aggregate(pipeline)
Сега можете да конвертирате cursor към списък
result = list(cursor)
и ако отпечатате стойността на резултата, ще получите точно същия резултат като във вашата заявка за Shell.
[{u'sum': 200.0, u'_id': u'User001'}]
Актуализация :
Виждам, че извиквате aggregate функция в кода на Python като db.docs.aggregate(pipeline) .Трябва да го извикате като docs.aggregate... без db . Вижте примера по-горе.
