Remover fragmentos de um cluster fragmentado

Verifique se o balanceador está habilitado

Para migrar dados de um shard, o processo do balanceador deve estar habilitado. Para verificar o estado do balanceador , use o método sh.getBalancerState() :

sh.getBalancerState()

Se a operação retornar true, o balanceador estará habilitado.

Se a operação retornar false, consulte Habilitar o Balancer.

Determine o nome do shard a ser removido

Para localizar o nome do shard, execute o comando listShards :

db.adminCommand( { listShards: 1 } )

O campo shards._id contém o nome do fragmento.

Remova chunks do fragmento

Execute o comando removeShard para o shard que você deseja remover:

db.adminCommand( { removeShard: "<shardName>" } )

A operação removeShard retorna:

{
   "msg" : "draining started successfully",
   "state" : "started",
   "shard" : "<shardName>",
   "note" : "you need to drop or movePrimary these databases",
   "dbsToMove" : [
      "db1",
      "db2"
   ],
   "ok" : 1,
   "operationTime" : Timestamp(1575398919, 2),
   "$clusterTime" : {
      "clusterTime" : Timestamp(1575398919, 2),
      "signature" : {
         "hash" : BinData(0,"Oi68poWCFCA7b9kyhIcg+TzaGiA="),
         "keyId" : NumberLong("6766255701040824328")
      }
   }
}

O fragmento entra no estado draining e o balanceador começa a migrar blocos do fragmento removido para outros fragmentos no cluster. Essas migrações ocorrem lentamente para evitar um impacto grave no cluster geral. Dependendo da capacidade da rede e da quantidade de dados, essa operação pode levar de alguns minutos a vários dias para ser concluída.

Listar namespaces de collection fragmentados

Para retornar uma lista de namespaces de collections fragmentadas, use o estágio $shardedDataDistribution e projeto o campo ns :

use admin
db.aggregate(
   [
      { $shardedDataDistribution: { } },
      { $project: { ns: 1 } }
   ]
)

Registre a saída para fazer referência mais tarde neste tutorial.

Listar todos os bancos de dados no cluster

db.adminCommand( { listDatabases: 1, nameOnly: true } )

Mover coleções para fora do fragmento

Para cada banco de dados de dados no cluster, exceto admin e config, execute estas etapas:

1. Listar as collections de banco de dados de dados

   Liste as collections no banco de banco de dados, omitindo os seguintes tipos de collections:

   • Collections internas que suportam CSFLE

   • Collections do sistema

   • Coleções de séries temporais

   • Visualizações

   use <databaseName>
   db.getCollectionInfos(
      {
         $and: [
            { type: { $nin: [ "view", "timeseries" ] } },
            { name: { $not: { $regex: "^system\." } } },
            { name: { $not: { $regex: "^enxcol_\..*(\.esc|\.ecc|\.ecoc|\.ecoc\.compact)$" } } }
         ]
      },
      { nameOnly: true }
   )

2. Mover collections necessárias

   Para cada collection retornada por getCollectionInfos() , execute as etapas a seguir.

   Observação

   Somente uma operação moveCollection pode estar em andamento por vez. Conclua todas as subetapas antes de passar para a próxima collection.

   1. Determine se a coleção precisa ser movida.

      Execute o estágio de agregação $collStats e projeto os campos ns e shard :

      db.<collName>.aggregate(
         [
            {
               $collStats: { }
            },
            {
               $project: {
                  ns: 1,
                  shard: 1
               }
            }
         ]
      )

      Se algum dos critérios a seguir for atendido, pule a collection e retorne à etapa i para a próxima collection no banco de banco de dados:

      • O campo ns está presente na saída $shardedDataDistribution da etapa 4.

      • O campo shard não é o shard que está sendo removido.

      Se nenhum dos critérios anteriores for atendido, continue para a etapa ii para a collection atual.

   2. Mova a collection.

      Para mover a coleção, execute sh.moveCollection() na coleção:

      sh.moveCollection( "<namespace>.<collection>", "<ID of recipient shard>" )

      Observação

      moveCollection falhará se você executar o comando em um namespace fragmentado. Se você receber esta mensagem de erro, ignore-a e retorne à etapa i para a próxima coleção.

   3. Retorne à etapa i para cada coleção no banco de banco de dados.

3. Repetir o procedimento para outros bancos de dados

   Repita a etapa 6, Move collections off of the shard (e subetapas) para cada banco de dados de dados no cluster.

Alterar fragmento primário

Execute o método db.printShardingStatus() :

db.printShardingStatus()

Na seção databases da saída de comando, marque o campo database.primary . Se o campo primary for o fragmento removido, você deverá mover o primário desse banco de dados para um fragmento diferente.

Para alterar o fragmento primário de um banco de dados, execute o comando movePrimary .

db.adminCommand(
   {
      movePrimary: <dbName>,
      to: <shardName>
   }
)

Verificar o status da migração

Para verificar o progresso da migração, execute removeShard do banco de banco de dados admin novamente:

db.adminCommand( { removeShard: "<shardName>" } )

Na saída, o campo remaining inclui estes campos:

Continue verificando o status do comando removeShard até que o número de blocos restantes seja 0.

db.adminCommand( { removeShard: "<shardName>" } )

Finalize a remoção de fragmentos

Para finalizar o processo de remoção de shard, execute novamente o comando removeShard :

db.adminCommand( { removeShard: <shardName> } )

Se o fragmento for removido, a saída do comando será semelhante ao seguinte:

{
   msg: 'removeshard completed successfully',
   state: 'completed',
   shard: '<shardName>',
   ok: 1,
   '$clusterTime': {
      clusterTime: Timestamp({ t: 1721941519, i: 7 }),
      signature: {
         hash: Binary.createFromBase64('AAAAAAAAAAAAAAAAAAAAAAAAAAA=', 0),
         keyId: Long('0')
      }
   },
   operationTime: Timestamp({ t: 1721941519, i: 7 })
}