मुझे लगता है कि आपके पास Python में MongoDB से एक वैध कनेक्शन है।
निम्न कोड स्निपेट परिणाम में एक MongoDB कर्सर लौटाएगा।
pipeline = [
{"$unwind": "$COL"},
{"$group": {"_id": "$LOC", "sum": {"$sum": "$COL.amount"}}}
]
cursor = collection.aggregate(pipeline)
अब आप कर्सर
को कन्वर्ट कर सकते हैं सूची के लिए
result = list(cursor)
और यदि आप परिणाम का मान प्रिंट करते हैं, तो आपको ठीक वैसा ही परिणाम मिलेगा जैसा आपकी शेल क्वेरी में है।
[{u'sum': 200.0, u'_id': u'User001'}]
अपडेट करें :
मैं देख रहा हूं कि आप एग्रीगेट
. को कॉल कर रहे हैं अजगर कोड में db.docs.aggregate(पाइपलाइन)
. के रूप में कार्य करता है .आपको इसे docs.aggregate...
. के रूप में कॉल करना होगा बिना डीबी
. ऊपर उदाहरण देखें।