MongoDB kruszywo zapytanie/grupy/suma tłumaczona na pymongo zapytanie

Question

Mam zestaw wpisów w kolekcji goals który wygląda tak:

{"user": "adam", "position": "attacker", "goals": 8} 
{"user": "bart", "position": "midfielder", "goals": 3} 
{"user": "cedric", "position": "goalkeeper", "goals": 1} 

chcę, aby obliczyć sumę wszystkich celów. W MongoDB skorupy robię to tak:

> db.goals.aggregate([{$group: {_id: null, total: {$sum: "$goals"}}}]) 
{ "_id" : null, "total" : 12 } 

Teraz chcę zrobić to samo w Pythonie przy użyciu pymongo. Próbowałem używać zarówno db.goals.aggregate() i db.goals.group(), ale jak dotąd nie udało się.

Non zapytań robocze:

> query = db.goals.aggregate([{"$group": {"_id": None, "total": {"$sum": "$goals"}}}]) 
{u'ok': 1.0, u'result': []} 

> db.goals.group(key=None, condition={}, initial={"sum": "goals"}, reduce="") 
SyntaxError: Unexpected end of input at $group reduce setup 

Wszelkie pomysły jak to zrobić?

Answer 1

Po prostu użyj rurki z agregatu.

pipe = [{'$group': {'_id': None, 'total': {'$sum': '$goals'}}}] 
db.goals.aggregate(pipeline=pipe) 

Out[8]: {u'ok': 1.0, u'result': [{u'_id': None, u'total': 12.0}]}