Gestionar balanceador de clúster fragmentado

Verifica el estado de balanceador

sh.getBalancerState() verifica si el balanceador está habilitado (es decir, que el balanceador tiene permiso para ejecutarse). sh.getBalancerState() no comprueba si el equilibrador está equilibrando activamente los fragmentos.

Para ver si el balanceador está habilitado en tu clúster, ejecuta el siguiente comando, que retorna un valor booleano:

sh.getBalancerState()

También puedes ver si el balanceador está habilitado usando sh.status(). El campo currently-enabled indica si el balanceador está habilitado, y el campo currently-running indica si el balanceador está actualmente en funcionamiento.

Comprobar si el balanceador está funcionando

Para ver si el proceso del balanceador está activo en su clúster:

1. Conéctese a cualquier en el mongos mongo clúster utilizando el shell.

2. Utilice la siguiente operación para determinar si el balanceador está ejecutándose:

   sh.isBalancerRunning()

Configurar el tamaño de fragmento por defecto

El tamaño de fragmento predeterminado para un clúster fragmentado es de 64 megabytes. En la mayoría de los casos, este tamaño es adecuado para dividir y migrar fragmentos. Para obtener información sobre cómo el tamaño de fragmento afecta las implementaciones, consulte "Tamaño de fragmento".

Cambiar el tamaño de fragmento por defecto afecta a los fragmentos que se procesan durante las migraciones y las divisiones automáticas, pero no afecta retroactivamente a todos los fragmentos.

Para configurar el tamaño de fragmento predeterminado, consulta Modificar el tamaño de fragmento en un clúster.

Programar la ventana de equilibrio

En algunas situaciones, especialmente cuando su conjunto de datos crece lentamente y una migración puede afectar el rendimiento, es útil asegurarse de que el balanceador esté activo solo en ciertos momentos. El siguiente procedimiento especifica el activeWindow, que es el periodo de tiempo durante el cual el balanceador podrá migrar fragmentos:

use config

sh.startBalancer()

db.settings.updateOne(
   { _id: "balancer" },
   { $set: { activeWindow : { start : "<start-time>", stop : "<stop-time>" } } },
   { upsert: true }
)

Remueva un cronograma de Ventana de Balanceo

Si ha configurado la ventana de balanceo y desea remover el cronograma para que el balanceador esté siempre en funcionamiento, utilice $unset para borrar el activeWindow, como se muestra a continuación:

use config
db.settings.updateOne( { _id : "balancer" }, { $unset : { activeWindow : true } } )

Desactivar el balanceador

Por defecto, el equilibrador puede ejecutarse en cualquier momento y sólo mueve los fragmentos según sea necesario. Para desactivar el balanceador por un corto periodo de tiempo y evitar toda migración, utiliza el siguiente procedimiento:

1. Conéctese a cualquier en el mongos mongo clúster utilizando el shell.

2. Ejecute la siguiente operación para deshabilitar el balanceador:

   sh.stopBalancer()

   Si una migración está en progreso, el sistema completará la migración en curso antes de detenerse.

   A partir de MongoDB 4.2, también deshabilita la división automática para el clústersh.stopBalancer() fragmentado.

3. Para verificar que el balanceador no se iniciará, ejecute el siguiente comando, que devuelve false si el balanceador está deshabilitado:

   sh.getBalancerState()

   Opcionalmente, para verificar que no haya migraciones en progreso después de la deshabilitación, ejecute la siguiente operación en el mongo shell:

   use config
   while( sh.isBalancerRunning() ) {
             print("waiting...");
             sleep(1000);
   }

db.adminCommand( { balancerStop: 1 } )

Habilitar el balanceador

Utilice este procedimiento si ha desactivado el balanceador y está listo para volver a activarlo:

1. Conéctese a cualquier en el mongos mongo clúster utilizando el shell.

2. Emita una de las siguientes operaciones para habilitar el equilibrador:

   Desde la shell mongo, ejecuta:

   sh.startBalancer()

   Nota

   Para habilitar el balanceador desde un controlador, utilice el comando balancerStart contra la admin base de datos, como se muestra a continuación:

   db.adminCommand( { balancerStart: 1 } )

   A partir de MongoDB 4.2, sh.startBalancer() también permite la división automática para el clúster fragmentado.

Desactivar el equilibrado durante las copias de seguridad

Si MongoDB migra un fragmento durante una copia de seguridad, es posible que termines con una instantánea inconsistente de tu clúster fragmentado. No ejecute nunca una copia de seguridad mientras el equilibrador esté activo. Para garantizar que el balanceador esté inactivo durante su operación de copia de seguridad:

• Configura la ventana de balanceo para que el balanceador esté inactivo durante la copia de seguridad. Asegúrate de que la copia de seguridad pueda completarse mientras tengas el equilibrador deshabilitado.

• desactivar manualmente el balanceador durante la duración del procedimiento de copia de seguridad.

Si apagas el balanceador en medio de una ronda de equilibrado, el apagado no es instantáneo. El balanceador completa el movimiento de fragmento en curso y luego detiene todas las siguientes rondas de balanceo.

Antes de iniciar una copia de seguridad, confirme que el balanceador no esté activo. Puede usar el siguiente comando para determinar si el balanceador está activo:

!sh.getBalancerState() && !sh.isBalancerRunning()

Una vez finalizado el procedimiento de copia de seguridad, puede reactivar el proceso de equilibrado.

Deshabilitar el balanceo en una colección

Puedes deshabilitar la equilibración de una colección específica con el método sh.disableBalancing(). Es posible que desee desactivar el balanceador para una colección específica para admitir operaciones de mantenimiento o cargas de trabajo atípicas, por ejemplo, durante la ingestión de datos o la exportación de datos.

Cuando desactivas el equilibrado en una colección, MongoDB no interrumpirá las migraciones en curso.

Para desactivar el balanceo en una colección, conéctate a un mongos con la mongo shell y llama al método sh.disableBalancing().

Por ejemplo:

sh.disableBalancing("students.grades")

El método acepta como sh.disableBalancing() parámetro el espacio de nombres completo de la colección.

Habilite el balanceo en una colección

Puede habilitar el equilibrio para una colección específica con el sh.enableBalancing() método.

Cuando habilitas el balanceo para una colección, MongoDB no comenzará a balancear los datos inmediatamente. Sin embargo, si los datos en tu colección particionada no están balanceados, MongoDB podrá empezar a distribuir los datos de manera más uniforme.

Para habilitar el balanceo en una colección, conéctate a un mongos con el mongo shell y llama al método sh.enableBalancing().

Por ejemplo:

sh.enableBalancing("students.grades")

El método acepta como sh.enableBalancing() parámetro el espacio de nombres completo de la colección.

Confirme que el balanceo esté habilitado o deshabilitado

Para confirmar si el balanceo de una colección está habilitado o deshabilitado, consulte la collections colección en la base de datos para encontrar el espacio de nombres config de la colección y verifique el noBalance campo. Por ejemplo:

db.getSiblingDB("config").collections.findOne({_id : "students.grades"}).noBalance;

Esta operación devolverá un error nulo, true, false, o ninguna salida:

• Un error nulo indica que el espacio de nombres de la colección es incorrecto.

• Si el resultado es true, el balanceo está desactivado.

• Si el resultado es false, el balanceo está habilitado actualmente pero se ha deshabilitado en el pasado para la colección. El balanceo de esta colección comenzará la próxima vez que se ejecute el balanceador.

• Si la operación no devuelve ningún resultado, el balanceo está habilitado actualmente y nunca se ha deshabilitado para esta colección. El balanceo de esta colección comenzará la próxima vez que se ejecute el balanceador.

También puedes ver si el balanceador está habilitado usando sh.status(). El campo currently-enabled indica si el balanceador está habilitado.

Cambiar el comportamiento de replicación para la migración de fragmentos

use config
db.settings.updateOne(
   { "_id" : "balancer" },
   { $set : { "_secondaryThrottle" : { "w": "majority" }  } },
   { upsert : true }
)

db.getSiblingDB("config").settings.updateOne(
   { _id: "balancer" },
   { $set: { attemptToBalanceJumboChunks : true } },
   { upsert: true }
)

Cambiar el tamaño máximo de almacenamiento para una partición determinada

Por defecto, las particiones no tienen restricciones en el tamaño de almacenamiento. Sin embargo, puedes establecer un tamaño máximo de almacenamiento para una partición determinada en el clúster particionado. Al seleccionar posibles particiones de destino, el balanceador ignora las particiones donde una migración superaría el tamaño máximo de almacenamiento configurado.

La colección shards en la base de datos de configuración almacena datos de configuración relacionados con las particiones.

{ "_id" : "shard0000", "host" : "shard1.example.com:27100" }
{ "_id" : "shard0001", "host" : "shard2.example.com:27200" }

Para limitar el tamaño de almacenamiento de una partición determinada, utiliza el método db.collection.updateOne() con el operador $set para crear el campo maxSize y asignarle un valor integer. El campo maxSize representa el tamaño máximo de almacenamiento para la partición en megabytes.

La siguiente operación establece un tamaño máximo en una partición de 1024 megabytes:

config = db.getSiblingDB("config")
config.shards.updateOne( { "_id" : "<shard>"}, { $set : { "maxSize" : 1024 } } )

Este valor incluye el tamaño mapeado de todos los archivos de datos en la partición, incluyendo las bases de datos local y admin.

Por defecto, maxSize no está especificado, permitiendo que las particiones consuman la cantidad total de espacio disponible en sus máquinas si es necesario.

También puedes configurar maxSize cuando añadas una partición.

Para establecer maxSize al agregar una partición, establecer el parámetro maxSize del comando addShard al tamaño máximo en megabytes. El siguiente comando ejecutado en el shell mongo agrega una partición con un tamaño máximo de 125 megabytes:

config = db.getSiblingDB("config")
config.runCommand( { addshard : "example.net:34008", maxSize : 125 } )