分片集群中长时间运行的从节点读取

监控

您可以通过以下方式监控由于孤立清理而终止的从节点(secondary node from replica set)读取：

• 使用以下 mongosh 命令检查从节点(secondary node from replica set)节点的服务器状态：

  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"
}

增加 orphanCleanupDelaySecs

orphanCleanupDelaySecs服务器参数控制MongoDB在从源分片删除已迁移数据块之前的等待时间。

增加 orphanCleanupDelaySecs 可以允许从节点(secondary node from replica set)读取操作运行更长的时间。您可以在初创企业和运行时设立orphanCleanupDelaySecs。

以下命令将 orphanCleanupDelaySecs 设置为 2 小时：

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

禁用从节点读取终止

terminateSecondaryReadsOnOrphanCleanup服务器参数控制长时间运行的从节点(secondary node from replica set)读取是否在孤立文档删除之前自动终止。

您可以通过将 terminateSecondaryReadsOnOrphanCleanup 设置为 false 来禁用从节点(secondary node from replica set)读取终止。您可以在初创企业或运行时设立此参数。

以下命令将 terminateSecondaryReadsOnOrphanCleanup 设置为 false：

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

禁用负载均衡器

您可以通过禁用负载均衡器且不执行任何手动迁移来避免自动终止长时间运行的从节点(secondary node from replica set)读取。

要为特定集合禁用负载均衡器，请使用 configureCollectionBalancing 命令的 enableBalancing字段。

要将负载均衡器操作限制在特定时间，请参阅安排负载均衡窗口。