配置 AlloyDB for PostgreSQL 数据库

以下部分介绍了如何配置 AlloyDB for PostgreSQL 数据库。

在 Datastream 和 AlloyDB 之间建立连接

如需使 Datastream 能够连接到 AlloyDB 实例，您需要在使用方项目中设置 TCP 代理。TCP 代理映像已面向所有客户公开提供。

  1. 启动代理容器：

    1. 在使用方项目中激活 Cloud Shell。
    2. 运行以下脚本以创建 TCP 代理并停用网桥 以免出现连接问题：
    gcloud compute instances create-with-container \
  --zone=REGION_ID VM_NAME \
  --container-image gcr.io/dms-images/tcp-proxy \
  --tags=dms-tcp-proxy \
  --container-env=SOURCE_CONFIG=ALLOYDB_IP:ALLOYDB_PORT \
  --can-ip-forward \
  --network=SOURCE_AND_DEST_VPC \
  --machine-type=VM_TIER \
  --metadata=startup-script='#! /bin/bash
  mkdir -p /etc/docker
  cat <<EOF > /etc/docker/daemon.json
  {"bridge":"none"}
  EOF
  systemctl restart docker'

    替换以下内容：

    • REGION_ID：您要在其中创建 TCP 代理的区域。
    • VM_NAME：虚拟机的名称。
    • ALLOYDB_IP：AlloyDB for PostgreSQL 实例的 IP 地址。
    • ALLOYDB_PORT：AlloyDB for PostgreSQL 实例的端口号。
    • SOURCE_AND_DEST_VPC：源和目标连接到的 VPC 网络。
    • VM_TIER：虚拟机的类型。

    包含更新后的参数的示例命令：

    gcloud compute instances create-with-container \
  --zone=us-central1-c ds-tcp-proxy \
  --container-image gcr.io/dms-images/tcp-proxy \
  --tags=ds-tcp-proxy \
  --container-env=SOURCE_CONFIG=10.16.0.5:5432 \
  --can-ip-forward \
  --network=default \
  --machine-type=e2-micro
  --metadata=startup-script='#! /bin/bash
  mkdir -p /etc/docker
  cat <<EOF > /etc/docker/daemon.json
  {"bridge":"none"}
  EOF
  systemctl restart docker'

  2. 输入以下内容，运行脚本以输出 TCP 代理的 IP 地址：

    gcloud compute instances describe VM_NAME \
  --format="yaml(networkInterfaces[].networkIP)" \
  --zone=REGION_ID

    替换以下内容：

    • VM_NAME：虚拟机的名称。
    • REGION_ID：您在其中创建了 TCP 代理的区域。

  3. （可选）创建防火墙规则来限制 TCP 代理的入站流量：

    gcloud compute firewall-rules create FIREWALL_RULE_NAME \
  --direction=INGRESS \
  --priority=1000 \
  --target-tags=dms-tcp-proxy \
  --network=SOURCE_VPC \
  --action=ALLOW \
  --rules=tcp:ALLOYDB_PORT \
  --source-ranges=IP_RANGE

    替换以下内容：

    • FIREWALL_RULE_NAME：您的防火墙规则的名称。
    • SOURCE_VPC：源连接到的 VPC 网络。
    • ALLOYDB_PORT：AlloyDB for PostgreSQL 实例的端口号。
    • IP_RANGE：您要限制入站流量的 IP 地址范围。

    允许来自所有 IP 地址的入站流量的示例命令：

    gcloud compute firewall-rules create ds-proxy1 \
  --direction=INGRESS \
  --priority=1000 \
  --target-tags=ds-tcp-proxy \
  --network=default \
  --action=ALLOW \
  --rules=tcp:5432

配置 AlloyDB 以进行复制

  1. 为 AlloyDB 主实例启用逻辑解码。在 Google Cloud 中，将 alloydb.logical_decoding 标志的值设置为开启。如需了解如何更新数据库标志，请参阅配置实例的数据库标志。

  2. 在同一 VPC 中的任何虚拟机上运行以下命令，使用 TCP 代理 IP 地址连接到 AlloyDB 实例：

      psql -h PROXY_IP \
    -U DB_USER \
    -d DB_NAME

    替换以下内容：

    • PROXY_IP：TCP 代理的 IP 地址。
    • DB_USER：AlloyDB 数据库的用户名。
    • DB_NAME：AlloyDB 数据库名称。

  3. 运行以下命令，向数据库用户授予复制权限：

    ALTER USER DB_USER WITH REPLICATION;

  4. 创建发布内容。我们建议您仅为 您要复制的表数量这样，Datastream 就能以只读模式 相关数据，并降低数据库和 Datastream 的负载：

    CREATE PUBLICATION PUBLICATION_NAME
FOR TABLE SCHEMA1.TABLE1, SCHEMA2.TABLE2;

    替换以下内容：

    • PUBLICATION_NAME：出版物的名称。在 Datastream 数据流创建向导中创建数据流时，您需要提供此名称。
    • SCHEMA：包含表的架构的名称。
    • TABLE：您要复制的表的名称。

    您可以为架构中的所有表创建发布内容。通过这种方法， 您可以复制对指定架构列表中表的更改，包括 您将来创建的表：

    CREATE PUBLICATION PUBLICATION_NAME
FOR TABLES IN SCHEMA1, SCHEMA2;

    您还可以为数据库中的所有表创建发布内容。请注意，这种方法会增加源数据库和 Datastream 的负载：

    CREATE PUBLICATION PUBLICATION_NAME FOR ALL TABLES;

  5. 执行以下命令，创建复制槽。

    SELECT PG_CREATE_LOGICAL_REPLICATION_SLOT('REPLICATION_SLOT_NAME', 'pgoutput');

    替换以下内容：

    • REPLICATION_SLOT_NAME：复制槽的名称。 在 Datastream 中创建数据流时，您需要提供此名称 视频流创建向导

创建 Datastream 用户

  1. 如需创建 Datastream 用户，请输入以下 PostgreSQL 命令：

    CREATE USER USER_NAME WITH REPLICATION LOGIN PASSWORD 'USER_PASSWORD';

    替换以下内容：

    • USER_NAME：您要创建的数据流用户的名称。
    • USER_PASSWORD：Datastream 用户的登录密码 资源。

  2. 向您创建的用户授予以下特权：

    GRANT SELECT ON ALL TABLES IN SCHEMA SCHEMA_NAME TO USER_NAME;
GRANT USAGE ON SCHEMA SCHEMA_NAME TO USER_NAME;
ALTER DEFAULT PRIVILEGES IN SCHEMA SCHEMA_NAME GRANT SELECT ON TABLES TO USER_NAME;

    替换以下内容：

    • SCHEMA_NAME：您要向其授予的架构的名称 权限。
    • USER_NAME：您要向其授予权限的用户。

后续步骤