これは、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
について詳しく知りたい場合 。