Puedes transmitir actualizaciones de captura de datos modificados (CDC) desde conjuntos de réplicas de MongoDB
autoadministrados o clústeres fragmentados a un destino
compatible, como BigQuery o
Cloud Storage, con Datastream. Para preparar tu fuente, crea un usuario de Datastream con privilegios de lectura en la base de datos de admin
para tu implementación.
Conjunto de réplicas
Para obtener información sobre la implementación de un conjunto de réplicas de MongoDB, consulta Implementa un conjunto de réplicas autoadministrado en la documentación de MongoDB.
Para configurar Datastream para usarla con un conjunto de réplicas de MongoDB autoadministrado, sigue estos pasos:
- Instala la shell de MongoDB. Para obtener información sobre cómo instalar MongoDB Shell, consulta Instala mongosh.
- Abre una ventana de terminal y ejecuta el comando
mongoshpara conectarte al conjunto de réplicas o al nodo principal. Crea un usuario para Datastream en la base de datos
admin:use admin db.createUser({ user: "USERNAME", pwd: "PASSWORD", roles: [ "readAnyDatabase", {role: "read", db: "admin"} ] })Reemplaza USERNAME y PASSWORD por el nombre de usuario y la contraseña que prefieras.
Clúster fragmentado
Para obtener información sobre la implementación de un clúster con fragmentación, consulta Implementa un clúster con fragmentación en la documentación de MongoDB.
Si deseas configurar Datastream para usarla con un clúster fragmentado de MongoDB autoadministrado, sigue estos pasos:
- Instala la shell de MongoDB. Para obtener información sobre cómo instalar MongoDB Shell, consulta Instala mongosh.
- Abre una ventana de terminal y ejecuta el comando
mongoshpara conectarte al clúster fragmentado de MongoDB. Crea un usuario de Datastream en cada nodo de fragmento principal y en el router de consultas
mongos:use admin db.createUser({ user: "USERNAME", pwd: "PASSWORD", roles: [ "readAnyDatabase" ] })Reemplaza USERNAME y PASSWORD por tu nombre de usuario y contraseña. Puedes elegir cualquier nombre de usuario y contraseña, pero deben ser idénticos en todos los nodos de fragmento principales y en el router de consultas de
mongos.Para averiguar qué fragmentos están conectados al enrutador de consultas de
mongos, ejecuta el siguiente comando:db.adminCommand({ listShards: 1 })