sh.reshardCollection() (método mongosh)

Fase de inicialización

Durante la fase de inicialización, el coordinador de fragmentación determina la nueva distribución de datos para la colección fragmentada.

Fase de índice

Durante la fase de índice:

• Cada destinatario de un fragmento crea una nueva colección fragmentada vacía con las mismas opciones que la colección existente. Esta nueva colección fragmentada es el destino donde los fragmentos del destinatario escriben los nuevos datos.

• Cada destinatario de particiones construye los nuevos índices necesarios. Estos incluyen todos los índices existentes en la colección particionada y un índice compatible con el nuevo patrón de clave de partición si no existe dicho índice en la colección particionada.

Clonar, Aplicar y Fase de puesta al día

Durante la clonación, la aplicación y la fase de actualización:

• Cada destinatario de partición clona una copia inicial de los documentos que poseería bajo la nueva clave de partición.

• Cada destinatario de la partición comienza a aplicar entradas del oplog de operaciones que sucedieron después de que el destinatario clonara los datos.

• Cuando la estimación para el tiempo restante para completar la operación de resegmentación sea inferior a dos segundos, el coordinador de resegmentación bloqueará los guardados para la colección.

  Nota

  Si es necesario, puedes forzar manualmente la operación de resharding para que se complete utilizando el método sh.commitReshardCollection(). Esto es útil si la estimación actual de tiempo para completar la operación de resharding es una duración aceptable para el bloqueo de escrituras de tu colección. El método sh.commitReshardCollection() bloquea los guardados temprano y fuerza a que la operación de redistribución se complete. Durante el periodo en el que los guardados están bloqueados, tu aplicación experimenta un aumento en la latencia.

Fase de Compromiso

• Después de que el proceso de resharding alcance la fase de confirmación, el proceso no podrá finalizar con sh.abortReshardCollection().

• Cuando todas las particiones han alcanzado una coherencia estricta, el coordinador de repartición concreta la operación de repartición e instala la nueva tabla de ruteo.

• El coordinador de repartición indica a cada fragmento principal, donante y receptor, de forma independiente, que cambien el nombre de la colección temporal fragmentada. Esta se convierte en la nueva colección repartida.

• Cada partición donante descarta la colección particionada anterior.

  Tip

  Reshard a Collection

Reshard a Collection

El siguiente ejemplo vuelve a fragmentar la colección sales.orders con la nueva clave de fragmento { order_id: 1 }:

sh.reshardCollection( "sales.orders", { order_id: 1 } )

Ejemplo de salida:

{
  ok: 1,
  '$clusterTime': {
    clusterTime: Timestamp(1, 1624887954),
    signature: {
      hash: Binary(Buffer.from("0000000000000000000000000000000000000000", "hex"), 0),
      keyId: 0
    }
  },
  operationTime: Timestamp(1, 1624887947)
}

Repartir una colección con zonas

Vuelva a fragmentar una colección con zonas cuando necesite ajustar la distribución de datos entre los fragmentos de su clúster para cumplir con requisitos cambiantes o mejorar el rendimiento.

En el siguiente ejemplo, la colección test.scores reside en shard0 y shard1. La clave de fragmento actual es { _id: 1}.

sh.addShardToZone( “shard2”, ‘NewZone’ )
sh.addShardToZone( “shard3”, ‘NewZone’ )

sh.reshardCollection(
  "test.scores",
  { "studentId": 1, "testId": 1},
  { zones: [ {
    min: { "studentId": MinKey(), "testId": MinKey() },
    max: { "studentId": MaxKey(), "testId": MaxKey() },
    zone: "NewZone" }
    ]
} )

{
   ok: 1,
   '$clusterTime': {
   clusterTime: Timestamp( { t: 1699484530, i: 54 } ),
   signature: {
   hash: Binary.createFromBase64( "90ApBDrSSi4XnCpV3OWIH4OGO0Y=", 0 ),
   keyId: Long( "7296989036055363606" )
   } },
   operationTime: Timestamp( { t: 1699484530, i: 54 } )
}