今回は、一括入れ替え処理を行います。
一括入れ替え
順次処理で一括入れ替えを行います。
(並列処理で実行したい場合は、initializeOrderedBulkOp()の代わりにinitializeUnorderedBulkOp()を使います。)
処理の詳細は以下の通りです。
- Bulk実行タイプを設定。(1行目)
- replaceクエリーを設定。(3~5行目)
- 一括実行(Bulk実行)。(7行目)
[Mongoシェル]
1 | > var bulk = db.member.initializeOrderedBulkOp() |
問題なく3つのドキュメントの入れ替えを行うことができました。
Pythonで操作
上記の処理をPythonで行うと、次のようになります。
[ソースコード]
1 | import pymongo |
ReplaceOneの第1引数には検索条件を指定し、第2引数には入れ替えるドキュメントの内容を設定します。
次回は、一括登録/一括更新処理(upsert)を行います。