En los clústeres fragmentados, puedes crear zonas de datos particionados según la clave de partición. Puedes asociar cada zona con una o más particiones en el clúster. Una partición puede asociarse con cualquier número de zonas. En un clúster equilibrado, MongoDB migra fragmentos cubiertos por una zona solo a aquellos particiones asociados con la zona.
Tip
Al definir las zonas y sus rangos antes de fragmentar una colección vacía o inexistente, la operación de recopilación de fragmentos crea fragmentos para los rangos de zona definidos, así como fragmentos adicionales para cubrir todo el rango de valores de clave de fragmento, y realiza una distribución inicial de fragmentos basada en los rangos de zona. Esta creación y distribución inicial de fragmentos permite una configuración más rápida de la fragmentación por zonas. Tras la distribución inicial, el balanceador gestiona la distribución de fragmentos en adelante.
Consulte Zonas predefinidas y rangos de zonas para una colección vacía o inexistente para ver un ejemplo.
Este tutorial utiliza Zonas para enrutar documentos en función de la fecha de creación, ya sea a particiones orientadas a admitir documentos recientes, o a aquellos destinados a admitir documentos archivados.
Los siguientes son algunos ejemplos de casos de uso para segmentar datos según el Acuerdo de Nivel de Servicio (SLA) o el Objetivo de Nivel de Servicio (SLO):
Una aplicación requiere proporcionar acceso de baja latencia a documentos insertados o actualizados recientemente
Una aplicación requiere priorizar el acceso de baja latencia a un rango o subconjunto de documentos
Una aplicación que se beneficia al garantizar que rangos o subconjuntos específicos de datos se almacenen en servidores con hardware que se adapte a los SLA para acceder a esos datos
El siguiente diagrama ilustra un clúster particionado que utiliza zonas basadas en hardware para satisfacer los Acuerdos de Nivel de Servicio (SLA) o los Objetivos de Nivel de Servicio (SLO) de acceso a los datos.
Scenario
Una aplicación de uso compartido de fotos requiere acceso rápido a las fotos subidas en los últimos 6 meses. La aplicación almacena la ubicación de cada foto junto con sus metadatos en la photoshare base de datos bajo la colección data.
Los siguientes documentos representan fotos cargadas por un solo usuario:
{ "_id" : 10003010, "creation_date" : ISODate("2012-12-19T06:01:17.171Z"), "userid" : 123, "photo_location" : "example.net/storage/usr/photo_1.jpg" } { "_id" : 10003011, "creation_date" : ISODate("2013-12-19T06:01:17.171Z"), "userid" : 123, "photo_location" : "example.net/storage/usr/photo_2.jpg" } { "_id" : 10003012, "creation_date" : ISODate("2016-01-19T06:01:17.171Z"), "userid" : 123, "photo_location" : "example.net/storage/usr/photo_3.jpg" }
Tenga en cuenta que solo el documento con _id : 10003012 se cargó durante el último año (a junio de 2016).
clave de partición
La colección de fotografías utiliza el índice { creation_date : 1 } como clave de fragmento.
El campo creation_date en cada documento permite crear zonas en la fecha de creación.
Arquitectura
La implementación del clúster particionado actualmente consta de tres particiones.
Zones
La aplicación requiere añadir cada partición a una zona según su nivel de hardware. Cada nivel de hardware representa una configuración de hardware específica diseñada para cumplir con un SLA o SLO determinado.
- Nivel rápido ("reciente")
Estas son las máquinas de mayor desempeño, con grandes capacidades de RAM, discos SSD rápidos y potentes CPUs.
La zona requiere un rango con:
un límite inferior de
{ creation_date : ISODate(YYYY-mm-dd)}, donde el año, el mes y la fecha especificados porYYYY-mm-ddestán dentro de los últimos 6 meses.un límite superior de
{ creation_date : MaxKey }.
- Nivel de archivo ("archivo")
Estas máquinas usan menos RAM, discos más lentos y CPUs más básicas. Sin embargo, tienen una mayor capacidad de almacenamiento por servidor.
La zona requiere un rango con:
un límite inferior de
{ creation_date : MinKey }.un límite superior de
{ creation_date : ISODate(YYYY-mm-dd)}, donde el año, el mes y la fecha coinciden con los valores utilizados para el límite inferior del nivelrecent.
A medida que aumentan las necesidades de rendimiento, añadir particiones adicionales y asociarlos a la zona adecuada, en función de su nivel de hardware, permite que el clúster se escale horizontalmente.
Al definir rangos de zonas según intervalos de tiempo, compare las ventajas de actualizarlos con poca frecuencia frente a la cantidad de datos que deben migrarse en cada actualización. Por ejemplo, establecer un límite de un año para que los datos se consideren "recientes" probablemente cubra más datos que establecer un límite de un mes. Si bien se requieren más migraciones al rotar en una escala de un mes, la cantidad de documentos que deben migrarse es menor que al rotar en una escala de un año.
Operaciones de escritura
Con zonas, si un documento insertado o actualizado coincide con una zona configurada, solo se puede escribir en un fragmento dentro de esa zona.
MongoDB puede guardar documentos que no coinciden con una zona configurada en cualquier partición del clúster.
Nota
El comportamiento descrito anteriormente requiere que el clúster esté en un estado estable y que ningún fragmento esté violando una zona configurada. Consulte la siguiente sección sobre balanceador para más información.
Operaciones de lectura
MongoDB puede dirigir las queries a una partición específica si la query incluye la clave de partición.
Por ejemplo, MongoDB puede intentar realizar una operación de lectura dirigida en la siguiente query porque incluye creation_date en el documento de query:
photoDB = db.getSiblingDB("photoshare") photoDB.data.find( { "creation_date" : ISODate("2015-01-01") } )
Si el documento solicitado se encuentra dentro del rango de zona recent, MongoDB enviará esta query a las particiones dentro de esa zona, asegurando así una lectura más rápida en comparación con una operación de lectura por difusiónen todo el clúster.
Balanceador
El balanceador migra los fragmentos a la partición apropiada cumpliendo cualquier zona configurada. Hasta la migración, las particiones pueden contener fragmentos que violan las zonas configuradas. Una vez que se complete el equilibrio, las particiones solo deberían contener fragmentos cuyos rangos no violen sus zonas asignadas.
Agregar o remover zonas o rangos de zonas puede provocar migraciones de fragmentos. Dependiendo del tamaño de tu conjunto de datos y de la cantidad de fragmentos que una zona o rango de zonas afecte, estas migraciones podrían afectar el rendimiento del clúster. Considera ejecutar tu balanceador durante ventanas programadas específicas. Consulta Programar la Ventana de Balance para un tutorial sobre cómo configurar una ventana de programación.
Seguridad
Para los clústeres fragmentados que se ejecutan clusterManager con admin control de acceso basado en roles en implementaciones autoadministradas, autentíquese como un usuario con al menos el rol en la base de datos.
Procedimiento
Debe estar conectado(a) a una mongos para crear zonas o rangos de zonas. No puedes crear zonas o rangos de zonas conectándote directamente a una partición.
Desactivar el balanceador
El balanceador debe estar deshabilitado en todo el clúster compartido para asegurar que no ocurran migraciones mientras se configuran las nuevas zonas.
Utiliza sh.stopBalancer() para detener el balanceador del clúster.
sh.stopBalancer()
Utiliza sh.isBalancerRunning() para comprobar si el proceso de balanceador está en ejecución actualmente. Espere a que finalicen las rondas de equilibrado actuales antes de continuar.
Añade cada fragmento a la zona apropiada
Agregue shard0000 a la zona recent.
sh.addShardTag("shard0000", "recent")
Agregue shard0001 a la zona recent.
sh.addShardTag("shard0001", "recent")
Agregue shard0002 a la zona archive.
sh.addShardTag("shard0002", "archive")
Puedes revisar la zona asignada a cualquier partición ejecutando sh.status().
Define los rangos para cada zona
Define el rango de fotos recientes y asócialo a la recent zona mediante el método. Este método sh.addTagRange() requiere:
el namespace completo de la colección de destino.
el límite inferior inclusivo del rango.
el límite superior exclusivo del rango.
la zona.
sh.addTagRange( "photoshare.data", { "creation_date" : ISODate("2016-01-01") }, { "creation_date" : MaxKey }, "recent" )
Define el rango para fotos más antiguas y asócialo a la zona archive utilizando el método sh.addTagRange(). Este método requiere:
el namespace completo de la colección de destino.
el límite inferior inclusivo del rango.
el límite superior exclusivo del rango.
la zona.
sh.addTagRange( "photoshare.data", { "creation_date" : MinKey }, { "creation_date" : ISODate("2016-01-01") }, "archive" )
MinKey y son valores especiales reservados para MaxKey comparaciones.
Habilitar el balanceador
Vuelva a habilitar el balanceador para rebalancear el clúster.
sh.enableBalancing()Utilice, que especifica el espacio de nombres de la colección, para iniciar el balanceador
sh.enableBalancing("photoshare.data")
Utiliza sh.isBalancerRunning() para comprobar si el proceso del balanceador se está ejecutando actualmente.
Revisar los cambios
La próxima vez que se ejecute el balanceador, este dividirá y migrará fragmentos entre las particiones respetando las zonas configuradas.
Una vez finalizado el equilibrio, los fragmentos en la zona recent solo deben contener documentos con creation_date mayor o igual a ISODate("2016-01-01"), mientras que los fragmentos en la zona archive solo deben contener documentos con creation_date menor que ISODate("2016-01-01").
Puede confirmar la distribución de los fragmentos ejecutando sh.status().
Actualización de rangos de zona
Para actualizar los rangos de fragmentos, realice las siguientes operaciones como parte de un trabajo cron u otro procedimiento programado:
Desactivar el balanceador
El balanceador debe estar deshabilitado en todo el clúster compartido para asegurar que no ocurran migraciones mientras se configuran las nuevas zonas.
Utiliza sh.stopBalancer() para detener el balanceador del clúster.
sh.stopBalancer()
Utiliza sh.isBalancerRunning() para comprobar si el proceso de balanceador está en ejecución actualmente. Espere a que finalicen las rondas de equilibrado actuales antes de continuar.
Retira los rangos antiguos de la zona de particiones
Remover el antiguo rango de zona recent utilizando el método sh.removeTagRange(). Este método requiere:
el namespace completo de la colección de destino.
el límite inferior inclusivo del rango.
el límite superior exclusivo del rango.
sh.removeTagRange( "photoshare.data", { "creation_date" : ISODate("2016-01-01") }, { "creation_date" : MaxKey } )
Remover el antiguo rango de zona archive utilizando el método sh.removeTagRange(). Este método requiere:
el namespace completo de la colección de destino.
el límite inferior inclusivo del rango.
el límite superior exclusivo del rango.
sh.removeTagRange( "photoshare.data", { "creation_date" : MinKey }, { "creation_date" : ISODate("2016-01-01") } )
MinKey y son valores especiales reservados para MaxKey comparaciones.
Agregue el nuevo rango de zona para cada zona
Define el rango de fotos recientes y asócialo a la recent zona mediante el método. Este método sh.addTagRange() requiere:
el namespace completo de la colección de destino.
el límite inferior inclusivo del rango.
el límite superior exclusivo del rango.
la zona.
sh.addTagRange( "photoshare.data", { "creation_date" : ISODate("2016-06-01") }, { "creation_date" : MaxKey }, "recent" )
Define el rango para fotos más antiguas y asócialo a la zona archive utilizando el método sh.addTagRange(). Este método requiere:
el namespace completo de la colección de destino.
el límite inferior inclusivo del rango.
el límite superior exclusivo del rango.
la zona.
sh.addTagRange( "photoshare.data", { "creation_date" : MinKey }, { "creation_date" : ISODate("2016-06-01") }, "archive" )
MinKey y son valores especiales reservados para MaxKey comparaciones.
Habilitar el balanceador
Vuelva a habilitar el balanceador para rebalancear el clúster.
sh.enableBalancing()Utilice, que especifica el espacio de nombres de la colección, para iniciar el balanceador
sh.enableBalancing("photoshare.data")
Utiliza sh.isBalancerRunning() para comprobar si el proceso del balanceador se está ejecutando actualmente.
Revisar los cambios
La próxima vez que se ejecute el balanceador, migrará los datos a través de los fragmentos respetando las zonas configuradas.
Antes de la equilibración, las particiones en la zona recent solo contenían documentos con creation_date mayor o igual que ISODate("2016-01-01"), mientras que las particiones en la zona archive solo contenían documentos con creation_date menor que ISODate("2016-01-01").
Una vez finalizado el equilibrio, los fragmentos en la zona recent solo deben contener documentos con creation_date mayor o igual a ISODate("2016-06-01"), mientras que los fragmentos en la zona archive solo deben contener documentos con creation_date menor que ISODate("2016-06-01").
Puede confirmar la distribución de los fragmentos ejecutando sh.status().