Leituras secundárias de longa duração em clusters fragmentados

Monitoramento

Você pode monitorar leituras secundárias encerradas devido à limpeza órfã das seguintes maneiras:

• Verifique o status do servidor do seu nó secundário com o seguinte comando mongosh:

  db.serverStatus().metrics.operation.killedDueToRangeDeletion

• Revise seus registros do mongod. Cada encerramento resulta em uma entrada de registro como o exemplo a seguir:

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

Implementar mecanismo de retomada

Um mecanismo de retomada permite que seu aplicação crie uma nova operação de leitura que começa onde termina sua operação de leitura anterior.

Para implementar um mecanismo de retomada eficaz, seu aplicação deve usar uma ordem de classificação consistente para os resultados da consulta. Considere os seguintes fatores ao selecionar uma ordem de classificação para seu mecanismo de retomada:

• A operação de classificação deve utilizar um campo indexado para execução eficiente da query.

• O campo de classificação deve conter valores únicos.

  • Se os valores do campo de classificação não forem exclusivos, seu aplicação deverá implementar lógica adicional para lidar com documentos que compartilham o mesmo valor de classificação.

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

Aumentar orphanCleanupDelaySecs

O parâmetro de servidor orphanCleanupDelaySecs controla o tempo que o MongoDB espera antes de excluir um chunk migrado do shard de origem.

O aumento do orphanCleanupDelaySecs permite que as operações de leitura secundária sejam executadas por um longo período de tempo. Você pode definir o orphanCleanupDelaySecs na inicialização e no tempo de execução.

O seguinte comando define orphanCleanupDelaySecs para 2 horas:

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

Desabilitar encerramento de leitura secundária

O parâmetro de servidor terminateSecondaryReadsOnOrphanCleanup controla se as leituras secundárias de longa duração terminam automaticamente antes da exclusão do documento órfão.

Você pode desabilitar a terminação secundária de leitura configurando terminateSecondaryReadsOnOrphanCleanup para false. Você pode definir este parâmetro na inicialização ou em tempo de execução.

O seguinte comando define terminateSecondaryReadsOnOrphanCleanup para false:

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

Desabilitar o balancer

Você pode evitar o encerramento automático de leituras secundárias de longa duração desativando o balanceador e não realizando migrações manuais.

Para desabilitar o balanceador para coleções específicas, use o comando configureCollectionBalancing do campo enableBalancing.

Para restringir as operações do balanceador a horários específicos, consulte Agendar a janela de balanceamento.