Saya berasumsi Anda memiliki koneksi yang valid ke MongoDB dengan Python.
Cuplikan kode berikut akan mengembalikan kursor MongoDB di result.
pipeline = [
{"$unwind": "$COL"},
{"$group": {"_id": "$LOC", "sum": {"$sum": "$COL.amount"}}}
]
cursor = collection.aggregate(pipeline)
Sekarang Anda dapat mengonversi cursor
ke daftar
result = list(cursor)
dan jika Anda mencetak nilai hasil, Anda akan mendapatkan hasil yang sama persis seperti dalam kueri Shell Anda.
[{u'sum': 200.0, u'_id': u'User001'}]
Perbarui :
Saya melihat bahwa Anda memanggil aggregate
berfungsi dalam kode python sebagai db.docs.aggregate(pipeline)
.Anda perlu menyebutnya sebagai docs.aggregate...
tanpa db
. Lihat contoh di atas.