A partir de MongoDB 8.0, puedes mover una colección no particionada a una partición diferente usando el moveCollection dominio.
Acerca de esta tarea
moveCollectionSólo se puede ejecutar en clústeres fragmentados.moveCollectionsolo puede mover colecciones que no estén fragmentadas.moveCollectionsolo puede mover una colección a la vez.moveCollectiontiene una duración mínima de 5 minutos.Si la colección que se está moviendo utiliza MongoDB Search, sus índices de búsqueda dejan de estar disponibles una vez que
moveCollectionfinaliza. Debe reconstruir manualmente los índices de búsqueda.No se pueden realizar cambios en la topología, como agregar o eliminar fragmentos o realizar transiciones entre servidores de configuración integrados y dedicados, hasta que se complete
moveCollection.No puedes ejecutar las siguientes operaciones en la colección que se está moviendo mientras
moveCollectionesté en curso:No se pueden ejecutar las siguientes operaciones contra el clúster mientras
moveCollectionesté en progreso:Las creaciones de índices que ocurran mientras
moveCollectionesté en curso podrían fallar silenciosamente.No cree índices mientras
moveCollectionesté en progreso.No llame a
moveCollectionsi hay creaciones de índices en curso.
Control de acceso
Si tu implementación tiene control de acceso habilitado, el rol enableSharding te otorga acceso para ejecutar el comando moveCollection.
Antes de comenzar
Antes de trasladar tu colección, asegúrate de cumplir los siguientes requisitos:
Su aplicación puede tolerar un periodo de dos segundos en el que la colección afectada bloquea las escrituras. Durante este periodo, la aplicación experimenta un aumento de latencia.
Su base de datos cumple con estos requisitos de recursos:
Asegúrate de que la partición a la que mueves la colección tenga suficiente espacio de almacenamiento para la colección y sus índices. La partición de destino requiere al menos
( Collection storage size + Index Size ) * 2bytes disponibles.Asegúrate de que tu capacidad de E/S esté por debajo de 50%.
Asegúrate de que la carga de tu CPU esté por debajo del 80%.
Importante
La base de datos no exige estos requisitos. Si no se asignan suficientes recursos, pueden producirse las siguientes consecuencias:
la base de datos se queda sin espacio y se apaga
rendimiento reducido
la operación tarda más de lo esperado
Si su aplicación tiene períodos de tiempo con menos tráfico, realice esta operación en la colección durante ese tiempo si es posible.
Pasos
Mover la colección.
Para mover una colección no particionada llamada inventory en la base de datos app a la partición shard02, ejecuta moveCollection:
db.adminCommand( { moveCollection: "app.inventory", toShard: "shard02" } )
Para obtener una lista de los ID de fragmentos disponibles,sh.status() ejecute. Para más detalles, consulte la salida de sh.status().
Supervisar el progreso de la operación moveCollection.
Supervisa el tiempo restante.
Para monitorear el tiempo restante para la
moveCollectionoperación, utilice la$currentOpetapa de canalización.Este ejemplo muestra cómo comprobar el progreso de
moveCollectionen la colecciónapp.inventory:db.getSiblingDB("admin").aggregate( [ { $currentOp: { allUsers: true, localOps: false } }, { $match: { type: "op", "originatingCommand.reshardCollection": "app.inventory" } } ] ) Nota
Para ver los valores actualizados, es necesario ejecutar continuamente la pipeline anterior.
La
$currentOpsalida de la pipeline:totalOperationTimeElapsedSecs: elapsed operation time en segundosremainingOperationTimeEstimatedSecs: tiempo restante estimado en segundos para la operaciónmoveCollectionactual. Se devuelve como-1al iniciar una nueva operaciónmoveCollection.
Nota
remainingOperationTimeEstimatedSecsse establece en una estimación de tiempo pesimista:- La estimación del tiempo de la fase de recuperación se establece en el tiempo de la fase de clonación, que
- es un tiempo relativamente largo.
- En la práctica, si solo hay unas pocas operaciones de escritura pendientes, el
- el tiempo real de la fase de actualización es relativamente corto.
Esta etapa del pipeline tiene una salida similar a la siguiente:
[ { shard: '<shard>', type: 'op', desc: 'ReshardingRecipientService | ReshardingDonorService | ReshardingCoordinatorService <reshardingUUID>', op: 'command', ns: '<database>.<collection>', originatingCommand: { reshardCollection: '<database>.<collection>', key: <shardkey>, unique: <boolean>, collation: { locale: 'simple' } }, totalOperationTimeElapsedSecs: <number>, remainingOperationTimeEstimatedSecs: <number>, ... }, ... ] Supervise el número de bytes transferidos.
Para supervisar la cantidad de bytes transferidos, utiliza
shardingStatistics.resharding.active.bytesCopiedy compara con la cantidad de bytes en la colección.
Confirme que la colección se ha movido.
Para confirmar que la colección se ha movido a la partición esperada, utilize la etapa de $collStats pipeline.
Este ejemplo muestra cómo confirmar que la colección app.inventory existe en la partición esperada:
db.inventory.aggregate( [ { $collStats: {} }, { $project: { "shard": 1 } } ] )
Esta etapa del pipeline tiene una salida similar a la siguiente:
[ { shard: 'shard02' } ]