Това е така, защото в 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
.