シャーディングされたクラスターで長時間実行されているセカンダリ読み取り

モニタリング

孤立したクリーンアップによって終了したセカンダリ読み取りは、次の方法で監視できます。

• 次の mongosh コマンドを使用して、セカンダリノードのサーバーステータスを確認します。

  db.serverStatus().metrics.operation.killedDueToRangeDeletion

• mongod ログを確認します。終了のたびに、次の例のようなログエントリが作成されます。

{
   "t": {
         "$date": "2025-06-11T12:11:43.361+02:00"
   },
   "s": "I",
   "c": "SHARDING",
   "id": 10016300,
   "svc": "S",
   "ctx": "conn93",
   "msg": "Read has been terminated due to orphan range cleanup",
   "attr": {
         "type": "command",
         ...
         "workingMillis": 0,
         "durationMillis": 0,
         "orphanCleanupDelaySecs": 3600
   }
}

再開メカニズムの実装

再開メカニズムを使用すると、アプリケーションは新しい読み取り操作を作成し、前の読み取り操作が終了した場所から開始できます。

効果的な再開メカニズムを実装するには、アプリケーションでクエリ結果に対して一貫したソート順序を使用する必要があります。再開メカニズムでソート順序を選択する際には、次の要素を考慮してください。

• クエリを効率的に実行するために、ソート操作ではインデックス付きフィールドを利用する必要があります。

• ソートフィールドには一意の値を含める必要があります。

  • ソートフィールドの値が一意でない場合、アプリケーションは、同じソート値を共有するドキュメントを処理するための追加のロジックを実装する必要があります。

{
        "state": "NY",
        "city": "NEW YORK",
        "zipcode": "00501"
}

let readDoc;
let latestZip;
let cursor = db.getSiblingDB("cities").zipcodes.find({
   state: "NY"
})
.sort({zipcode: 1})
.readPref("secondary");
while(cursor.hasNext()) {
   try {
      readDoc = cursor.next();
      // process `readDoc` here
      latestZip = readDoc.zipcode;
   } catch (err) {
      if (err.code === 175 &&
         err.errmsg.includes("Read has been terminated due to orphan range cleanup")) {
         console.log("Query terminated, resuming from zipcode:", latestZip);
         cursor = db.getSiblingDB("cities").zipcodes.find({
               state: "NY",
               zipcode: {$gt: latestZip}
         })
         .sort({zipcode: 1})
         .readPref("secondary");
      } else {
         throw err; // Rethrow non-termination errors
      }
   }
}

{
   code: 175,
   name: QueryPlanKilled,
   categories: [CursorInvalidatedError],
   errmsg: "Read has been terminated due to orphan range cleanup"
}

orfhanCreanupDelaySecs を増やす

orphanCleanupDelaySecsサーバーパラメータは、移行された チャンク をソース シャードから削除するまでにMongoDB が待機する時間を制御します。

orphanCleanupDelaySecs を増やすと、セカンダリ読み取り操作がより長時間実行できるようになります。orphanCleanupDelaySecs は、スタートアップと実行時に設定できます。

次のコマンドは、orphanCleanupDelaySecs を 2 時間に設定します。

db.adminCommand({
        setParameter: 1,
        orphanCleanupDelaySecs: 7200
})

セカンダリ読み取りの終了を無効化

terminateSecondaryReadsOnOrphanCleanupサーバーパラメータは、孤立したドキュメントが削除される前に、長時間実行されているセカンダリ読み取りを自動的に終了するかどうかを制御します。

terminateSecondaryReadsOnOrphanCleanup を false に設定することで、セカンダリ読み取りの終了を無効にすることができます。このパラメーターは、スタートアップ時に設定できます。

次のコマンドは、terminateSecondaryReadsOnOrphanCleanup を false に設定します。

db.adminCommand({
        setParameter: 1,
        terminateSecondaryReadsOnOrphanCleanup: false
})

バランサーを無効にする

バランサーを無効にして手動移行を実行しないことで、実行時間の長いセカンダリ読み取りが自動的に終了しないようにできます。

特定のコレクションのバランサーを無効にするには、configureCollectionBalancing コマンドの enableBalancingフィールドを使用します。

バランサー操作を特定の時間に制限するには、バランシング ウィンドウのスケジュールを参照してください。