Zakładam, że masz prawidłowe połączenie z MongoDB w Pythonie.
Poniższy fragment kodu zwróci kursor MongoDB w result.
pipeline = [
{"$unwind": "$COL"},
{"$group": {"_id": "$LOC", "sum": {"$sum": "$COL.amount"}}}
]
cursor = collection.aggregate(pipeline)
Teraz możesz przekonwertować cursor do listy
result = list(cursor)
a jeśli wypiszesz wartość wyniku, otrzymasz dokładnie taki sam wynik, jak w zapytaniu Shell.
[{u'sum': 200.0, u'_id': u'User001'}]
Aktualizacja :
Widzę, że dzwonisz do aggregate funkcja w kodzie Pythona jako db.docs.aggregate(pipeline) .Musisz nazwać to jako docs.aggregate... bez db . Zobacz przykład powyżej.
