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 receptor de fragmentos crea los nuevos índices necesarios. Estos incluyen todos los índices existentes en la colección fragmentada y un índice compatible con el nuevo patrón de clave de fragmento, si dicho índice no existe ya en la colección fragmentada.

Fase de clonación, aplicación y recuperación

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

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

• Cada destinatario de fragmentos comienza a aplicar entradas de registro de operaciones que ocurrieron después de que el destinatario clonó los datos.

• Cuando la estimación del tiempo restante para completar la operación de refragmentación es inferior a dos segundos, el coordinador de refragmentación bloquea las escrituras para la colección.

  Nota

  Si es necesario, puede forzar manualmente la finalización de la operación de refragmentación ejecutando el sh.commitReshardCollection() método. Esto resulta útil si el tiempo estimado actual para completar la refragmentación es aceptable para que su colección bloquee las escrituras. El método bloquea las escrituras anticipadamente y fuerza la finalización de la refragmentación. Durante el período en que se bloquean las sh.commitReshardCollection() escrituras, su aplicación experimenta un aumento de latencia.

Fase de compromiso

• Una vez que el proceso de reorganización llega a la fase de confirmación, el proceso no se puede finalizar sh.abortReshardCollection() con.

• Cuando todos los fragmentos han alcanzado una consistencia estricta, el coordinador de refragmentación confirma la operación de refragmentación e instala la nueva tabla de enrutamiento.

• 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 fragmento donante elimina la antigua colección de fragmentos.

  Tip

  Repartir una colección

Repartir una colección

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