É possível transmitir atualizações de captura de dados alterados (CDC) de conjuntos de réplicas ou clusters fragmentados autogerenciados do MongoDB para um destino compatível, como o BigQuery ou o Cloud Storage, usando o Datastream. Para preparar a origem, crie um usuário do Datastream com privilégios de leitura no banco de dados admin para sua implantação.
Conjunto de réplicas
Para ver informações sobre como implantar um conjunto de réplicas do MongoDB, consulte Distribuir um conjunto de réplicas autogerenciado na documentação do MongoDB.
Para configurar o Datastream para uso com um conjunto de réplicas do MongoDB autogerenciado, siga estas etapas:
- Instale o MongoDB Shell. Para ver mais informações sobre como instalar o MongoDB Shell, consulte Instalar o mongosh.
- Abra uma janela do terminal e execute o comando
mongoshpara se conectar ao conjunto de réplicas ou ao nó principal. Crie um usuário para o Datastream no banco de dados
admin:use admin db.createUser({ user: "USERNAME", pwd: "PASSWORD", roles: [ "readAnyDatabase", {role: "read", db: "admin"} ] })Substitua USERNAME e PASSWORD pelo nome de usuário e pela senha de sua preferência.
Cluster fragmentado
Para ver informações sobre como implantar um cluster fragmentado, consulte Implementar um cluster fragmentado na documentação do MongoDB.
Para configurar o Datastream para uso com um cluster fragmentado do MongoDB autogerenciado, siga estas etapas:
- Instale o MongoDB Shell. Para ver mais informações sobre como instalar o MongoDB Shell, consulte Instalar o mongosh.
- Abra uma janela do terminal e execute o comando
mongoshpara se conectar ao cluster fragmentado do MongoDB. Crie um usuário do Datastream em cada nó de fragmento principal e no roteador de consultas
mongos:use admin db.createUser({ user: "USERNAME", pwd: "PASSWORD", roles: [ "readAnyDatabase" ] })Substitua USERNAME e PASSWORD pelo seu nome de usuário e senha. É possível escolher qualquer nome de usuário e senha, mas eles precisam ser idênticos em todos os nós de fragmento primários e no roteador de consultas
mongos.Para descobrir quais fragmentos estão conectados ao roteador de consultas
mongos, execute o seguinte comando:db.adminCommand({ listShards: 1 })