文档中心

数据库传输服务

创建 PostgreSQL 数据订阅任务

创建公有网络 PostgreSQL数据订阅任务

本场景介绍如何通过数据库传输服务 DTS 创建公有网络 PostgreSQL 数据订阅任务。

前提条件

已自主搭建 PostgreSQL 数据库，且此数据库可通过公网访问。

如果通过专有网络 Kafka 的方式消费数据，则按需设置消费端信息，具体如下所示：

在使用 VPN 实现数据订阅时，自建数据库所属的本地网络已通过 VPN 网关接入火山引擎。详细操作，请参见搭建云上 VPC 与云下多数据中心网络互通。

在需要使用专线实现数据订阅时，您需要搭建云上单私有网络和云下单数据中心网络连通的专线连接。详细操作，请参见配置专线连接。

订阅前准备

白名单与访问权限：

当数据库实例的接入方式选择的是公有网络时，且数据库实例开启了访问限制，那么在创建数据库传输任务前，您需要将 DTS 服务器 IP 地址添加至数据库实例的白名单或安全组中。不同地域下的 DTS 服务器 IP 地址不同，具体如下所示：
华南 1（广州）、华北 2（上海）和华北 2（北京）的 DTS 服务器 IP 地址是 221.194.189.0/27,157.148.90.32/27,180.184.132.64/27,61.129.54.64/27,220.196.172.32/27,117.135.143.32/27,220.196.168.32/27,116.132.250.32/27,111.45.13.32/27,125.88.248.32/27,180.153.35.32/27,220.181.65.32/27,220.181.65.64/27。
亚太东南（柔佛）的 DTS 服务器 IP 地址是 101.47.0.32/27,220.181.65.32/27,220.181.65.64/27,101.47.65.192/27,101.47.65.32/27。
亚太东南（雅加达）的 DTS 服务器 IP 地址是 221.194.189.0/27,157.148.90.32/27。
中国香港的 DTS 服务器 IP 地址是 101.47.0.32/27,220.181.65.32/27,220.181.65.64/27,101.47.65.192/27,101.47.65.32/27。
关于 DTS 服务器 IP 地址段的详细信息，请参见添加 DTS 服务器的 IP 地址段。

当数据库实例的接入方式选择的是专有网络时，且数据库实例开启了访问限制，那么在创建数据库传输任务前，您需要将子网网段添加至数据库实例的白名单或安全组中。华南1（广州）子网网段是 172.31.0.0/20，华北2（上海）和华北2（北京）子网网段是 192.168.3.0/24，亚太东南（柔佛）子网网段是 192.168.0.0/24。更多信息，请参见添加 DTS 服务器的 IP 地址段。

网络连通性：创建数据订阅任务之前，请确认源库和消费端的网络连通性与服务可用性。

您还可以根据预检查项中的说明，来检查源库和目标库中各迁移对象做相应准备。更多详情，请参见预检查项（PostgreSQL）。

限制说明

限制类	说明
源数据库限制	数据库版本：当前支持 10、11、12、13、14、15、16 和 17 版本的 PostgreSQL 实例。
消费端限制	当消息订阅到内置中间件时，具有以下限制条件：当订阅的单行消息超过 10MB 时，消息会被丢弃。当消息订阅到内置中间件时，默认 Topic 仅包含一个 Partition，可以保证消息投递的有序性；如果有更大流量的投递需求，请选择将数据订阅到客户自有中间件。当消息订阅到 Kafka 时，具有以下限制条件：成功创建订阅任务后，不支持修改 Kafka Partition 的接收策略。如果消费端为专有网络 Kafka 或消息队列 Kafka 版时，创建订阅任务后，请勿修改分区 Partition 的数量。仅支持 SASL 认证且认证机制为 PLAIN，此处应指定为 PLAIN 机制的用户名。关于如何创建 PLAIN 机制的 SASL 用户，请参见创建 SASL 用户。
其他限制	在选择订阅数据投递时，内置中间件为所有用户共享，仅适用于测试场景；业务场景中，建议选择客户自有中间件。创建数据订阅任务时，目前仅支持 Standard 链路规格。关于链路规格的详细信息，请参见产品规格。如果将消息订阅到客户自有中间件，在数据订阅过程中，请勿修改自有中间件实例的参数配置，否则任务将订阅失败。 Avro 格式订阅格式当前属于邀测阶段，如需使用请提交工单联系技术支持。在进行 PostgreSQL 同步任务时，PostgreSQL 的源端数据库账号需在源库创建触发器、函数等对象。因此，在同步过程中，请勿修改该账号在源库所创建的触发器、函数、内部表等对象的访问权限。

支持的 SQL 语句

操作类型	SQL 操作语句
DML	INSERT、UPDATE、DELETE
DDL	CREATE TABLE、ALTER TABLE、DROP TABLE、TRUNCATE TABLE、CREAT INDEX、DROP INDEX、CREATE SEQUENCE、ALTER SEQUENCE、DROP SEQUENCE、DROP RULE

操作步骤

在顶部菜单栏，选择项目和地域。

在左侧导航栏，单击数据订阅。

在数据订阅列表页面，单击创建订阅。

在配置源库页面，配置以下参数信息。

单击下一步:配置订阅对象。

在配置订阅对象页面，配置以下参数信息。

说明

若暂时不需要启动订阅任务，您可以在完成配置订阅对象后，单击页面右下角的保存，保存订阅任务，表示成功创建订阅任务后不启动此任务。

保存后该订阅任务的状态为待启动，当需要启动此任务时，在数据订阅列表页面，单击目标未启动订阅任务操作列下的配置订阅通道。具体操作，请参见步骤 5 及后续步骤

单击预检查。

（可选）当创建的任务已有预检查时，您可以根据以下提示确认是否重新发起预检查，当需要重新发起预检查时，请在是否重新发起预检查对话框，单击确定。

若源端和目标端的数据库实例未做修改，则无需再次发起预检查。

如果修改了源端、目标端的数据库实例信息或订阅任务的参数配置，那么建议您重新发起预检查，否则可能会致使任务启动失败或者任务中断。

在预检查配置向导页面，根据检查结果执行以下操作：

单击操作列的详情，查看详细的告警和失败信息，并根据告警或失败信息修改库表后，单击重试。

单击操作列的忽略，忽略本次告警继续启动订阅任务。同时，也可以单击忽略全部，一键忽略全部告警信息。

说明

当预检查结果失败时，请勿忽略本次告警。

选择忽略告警并启动订阅任务后，可能会存在某些隐患，具体信息，请参见界面提示。

关于预检查的具体说明，请参见预检查项（PostgreSQL）。

在预检查页面右下角，单击确认订单。

根据创建任务的计费类型，选择配置方式：

按量付费

在确认订单配置向导页面，再次确认配置信息。阅读《数据库产品和服务条款》并勾选我已阅读并同意《数据库产品和服务条款》，然后单击创建并启动任务。

包年包月

在确认订单配置向导页面，再次确认配置信息。阅读《数据库产品和服务条款》并勾选我已阅读并同意《数据库产品和服务条款》，然后单击创建并启动任务。

在确认订单信息配置向导页面，确认实例的计费信息。

（可选）单击代金券兑换，在代金券兑换对话框，输入代金券兑换码后单击兑换。

（可选）在代金券区域，按需勾选可用代金券，单次仅支持选中一张，即可抵扣部分费用。也可不使用代金券。

单击下一步。

说明

在支付完成配置向导页面，显示支付成功则任务创建成功。

成功创建数据订阅任务后，您可以在数据库传输服务 DTS 控制台的订阅任务列表查看到数据订阅任务。

后续操作

新建消费组

消费订阅数据

通过 Kafka 消费火山引擎 Proto 格式的订阅数据

通过 Kafka 消费 Canal Proto 格式的订阅数据

API	描述
CreateTransmissionTask	调用 CreateTransmissionTask 接口创建数据库传输服务任务。
ModifyTransmissionTask	调用 ModifyTransmissionTask 接口修改传输任务。