MongoDBのcursorで出てくるdocumentは、読み出し時点で古い内容になっている可能性がある

前提知識

code:js

let cursor

try {

cursor = model.find(condition).cursor();

for await (const { _id } of cursor) {

const doc = await model.findOne({ _id }); // _idを使ってもう一度読み出す

}

} catch (err) {

// 例外処理

} finally {

cursor?.close();

}

理由

cursor作成時点で条件にマッチしていたdocumentだけが返る

途中で他のプロセスがdocumentを変更し、条件にマッチするdocumentが新たに発生した場合

今回のcursorが返すdocumentには含まれない

途中で他のプロセスがdocumentを変更し、マッチしていたdocumentが条件から外れてしまった場合

これはタイミングによる

MongoDBサーバーがBSONをfetchし、アプリケーションに返す処理がある

BSONをfetchした後、他のプロセスが変更した場合

BSON fetch時点の内容のdocumentがアプリケーションに返る

BSONをまだfetchしていない位置にあるdocumentが変更された場合

それによって条件にマッチしなくなった場合

documentはアプリケーションに送信されない

BSON fetch時点でもう一度条件チェックが行われるため

変更後も条件にマッチする場合

documentはアプリケーションに送信される（当然）

まとめ

新しいdocumentが返る事もあるし、古いdocumentが返る事もある

少なくとも、アプリケーション側に現れるdocumentは、find queryの条件にはマッチする

しかしMongoDBのストレージ内の最新データとは食い違っている可能性がある

どうするか

cursor回してるループの中で、_idを使ってもう一度最新のdocumentを読み直すのが安全

現在のスナップショット (shard_role_details::getRecoveryUnit(opCtx)->getSnapshotId()) を取り直し、

resetDocument() でその時点の BSON を再取得、

さらに、保持している index key が今でもそのドキュメントに対応しているかを検証し、合わなければ false を返してそのエントリを捨てる

という流れです。つまり途中でドキュメントが条件から外れるように更新されていた場合はこの検証で弾かれ、カーソルからは出てこなくなります。

答え：変わらない

MongoDBサーバー内で、BSONを一度にfetchする件数を制御するパラメータではない