Jeg antager, at du har en gyldig forbindelse til MongoDB i Python.
Følgende kodestykke vil returnere en MongoDB-markør i result.
pipeline = [
{"$unwind": "$COL"},
{"$group": {"_id": "$LOC", "sum": {"$sum": "$COL.amount"}}}
]
cursor = collection.aggregate(pipeline)
Nu kan du konvertere cursor
til listen
result = list(cursor)
og hvis du udskriver resultatets værdi, får du nøjagtig det samme resultat som i din Shell-forespørgsel.
[{u'sum': 200.0, u'_id': u'User001'}]
Opdater :
Jeg kan se, at du kalder aggregate
funktion i python-kode som db.docs.aggregate(pipeline)
.Du skal kalde det som docs.aggregate...
uden db
. Se eksemplet ovenfor.