为自行管理的 MongoDB 数据库配置 CDC

您可以使用 Datastream 将变更数据捕获 (CDC) 更新从自行管理的 MongoDB 副本集或分片集群流式传输到支持的目标位置，例如 BigQuery 或 Cloud Storage。如需准备来源，您需要在部署的 admin 数据库中创建具有读取权限的 Datastream 用户。

副本集

如需了解如何部署 MongoDB 副本集，请参阅 MongoDB 文档中的部署自行管理的副本集。

如需配置 Datastream 以与自行管理的 MongoDB 副本集搭配使用，请按照以下步骤操作：

1. 安装 MongoDB Shell。如需了解如何安装 MongoDB Shell，请参阅安装 mongosh。
2. 打开终端窗口，然后运行 mongosh 命令以连接到副本集或主节点。

3. 在 admin 数据库中为 Datastream 创建用户：

   use admin
   db.createUser({
     user: "USERNAME",
     pwd: "PASSWORD",
     roles: [ "readAnyDatabase", {role: "read", db: "admin"} ]
   })
   

   将 USERNAME 和 PASSWORD 替换为您偏好的用户名和密码。

分片集群

如需了解如何部署分片集群，请参阅 MongoDB 文档中的部署分片集群。

如需将 Datastream 配置为与自行管理的 MongoDB 分片集群搭配使用，请按照以下步骤操作：

1. 安装 MongoDB Shell。如需了解如何安装 MongoDB Shell，请参阅安装 mongosh。
2. 打开终端窗口，然后运行 mongosh 命令，连接到 MongoDB 分片集群。

3. 在每个主分片节点和 mongos 查询路由器中创建一个 Datastream 用户：

   use admin
   db.createUser({
      user: "USERNAME",
      pwd: "PASSWORD",
      roles: [ "readAnyDatabase" ]
   })
   

   将 USERNAME 和 PASSWORD 替换为您的用户名和密码。您可以选择任何用户名和密码，但它们在所有主分片节点和 mongos 查询路由器中必须相同。

4. 如需了解哪些分片已连接到 mongos 查询路由器，请运行以下命令：

   db.adminCommand({ listShards: 1 })