ऐसा इसलिए है क्योंकि PyMongo v3.6 में Collection.aggregate()
बदल दिया गया है। session
. के लिए एक वैकल्पिक पैरामीटर जोड़ा गया है। अब विधि हस्ताक्षर है:
aggregate(pipeline, session=None, **kwargs)
इसे अपने कोड उदाहरण में लागू करते हुए, आप निर्दिष्ट कर सकते हैं allowDiskUse
नीचे के रूप में:
node = db.way.aggregate(pipeline=[
{'$unwind': '$node'},
{'$group': {
'_id': '$node',
'appear_count': {'$sum': 1}
}
},
{'$sort': {'appear_count': -1}},
{'$limit': 10}
],
allowDiskUse=True
)
यह भी देखें pymongo.client_session
यदि आप session
के बारे में अधिक जानना चाहते हैं .