数据传输服务DTS（Data Transmission Service）支持将自建PostgreSQL同步至云原生数据仓库AnalyticDB PostgreSQL。通过DTS提供的数据同步功能，可以轻松实现数据的流转，将企业数据集中分析。

前提条件

注意事项

  • 一个数据同步作业只能同步一个数据库，如果有多个数据库需要同步，则需要为每个数据库创建数据同步作业。
  • 在数据同步的过程中，如果要将源库中创建的新表作为同步对象，您需要对该表执行如下操作以保障该表数据同步的一致性。 
    ALTER TABLE schema.table REPLICA IDENTITY FULL;
  • 为保障同步任务的正常进行，目前仅支持RDS PostgreSQL 11进行主备切换，且需设置参数 rds_failover_slot_mode为sync，设置方式，请参见逻辑复制槽故障转移（Logical Replication Slot Failover）。
    警告 自建PostgreSQL和其他版本的RDS PostgreSQL进行主备切换，会导致同步中断。
  • 若源库有长事务，且实例包含增量同步任务，则可能会导致源库长事务提交前的预写日志WAL（Write-Ahead Logging）无法清理而堆积，从而造成源库磁盘空间不足。

费用说明

同步类型链路配置费用
库表结构同步和全量数据同步不收费。
增量数据同步收费，详情请参见计费概述。

同步限制

  • 不支持结构初始化，即不支持将源库中待同步对象的结构定义（例如表结构）同步至目标库中。
  • 同步对象仅支持数据表。
  • 不支持BIT、VARBIT、GEOMETRY、UUID、TSQUERY、TSVECTOR、TXID_SNAPSHOT类型的数据同步。
  • 同步过程中，如果对源库中的同步对象执行了DDL操作，需要手动在目标库中执行对应的DDL操作，然后重启数据同步作业。

支持同步的SQL操作

INSERT、UPDATE、DELETE。

准备工作

根据自建PostgreSQL中待同步对象的结构，在目标云原生数据仓库AnalyticDB PostgreSQL中创建相应的数据库、Schema、表等结构信息，详情请参见SQL语法。

操作步骤

  1. 购买数据同步作业，详情请参见购买流程。
    说明 购买时，选择源实例为PostgreSQL、目标实例为AnalyticDB for PostgreSQL，并选择同步拓扑为单向同步。
  2. 登录数据传输控制台。
  3. 在左侧导航栏，单击数据同步。
  4. 在同步作业列表页面顶部，选择数据同步实例所属地域。
  5. 定位至已购买的数据同步实例，单击配置同步链路。
  6. 配置同步通道的源实例及目标实例信息。
    配置源和目标库信息
    类别配置说明
    无同步作业名称DTS会自动生成一个同步作业名称，建议配置具有业务意义的名称（无唯一性要求），便于后续识别。
    源实例信息实例类型根据源库的部署位置进行选择，本文以ECS上的自建数据库为例介绍配置流程。
    说明 当自建数据库为其他实例类型时，您还需要执行相应的准备工作，详情请参见准备工作概览。

    本文以ECS上的自建数据库为例介绍配置流程。

    实例地区购买数据同步实例时选择的源实例地域信息，不可变更。
    ECS实例ID选择自建PostgreSQL数据库所属的ECS实例ID。
    数据库类型固定为PostgreSQL。
    端口填入自建PostgreSQL数据库的服务端口。
    数据库名称填入待同步的表所属的数据库名称。
    数据库账号填入自建PostgreSQL的数据库账号。
    说明 数据库账号须具备schema的owner权限。
    数据库密码填入该数据库账号对应的密码。
    目标实例信息实例类型固定为AnalyticDB for PostgreSQL，无需设置。
    实例地区购买数据同步实例时选择的目标实例地域信息，不可变更。
    实例ID选择云原生数据仓库AnalyticDB PostgreSQL实例ID。
    数据库名称填入同步目标表所属的数据库名称。
    数据库账号填入云原生数据仓库AnalyticDB PostgreSQL的初始账号，详情请参见创建数据库账号。
    说明 您也可以填入具备RDS_SUPERUSER权限的账号，创建方法请参见用户权限管理。
    数据库密码填入该数据库账号对应的密码。
  7. 单击页面右下角的授权白名单并进入下一步。
    说明
    • 如果源或目标数据库是阿里云数据库实例（例如RDS MySQL、云数据库MongoDB版等）或ECS上的自建数据库，DTS会自动将对应地区DTS服务的IP地址添加到阿里云数据库实例的白名单或ECS的安全规则中，您无需手动添加，请参见DTS服务器的IP地址段。
    • DTS任务完成或释放后，建议您手动删除添加的DTS服务器IP地址段。
  8. 配置同步策略及对象信息。
    选择同步对象
    类别配置说明
    同步策略配置同步初始化默认情况下，您需要勾选全量数据初始化。预检查完成后，DTS会将源实例中待同步对象的存量数据同步至目标实例，作为后续增量同步数据的基线数据。
    目标已存在表的处理模式
    • 清空目标表的数据

      在预检查阶段跳过目标表是否为空的检查项目。全量初始化之前将目标表的数据清空。适用于完成同步任务测试后的正式同步场景。

    • 忽略报错并继续执行

      在预检查阶段跳过目标表是否为空的检查项目。全量初始化时直接追加迁移数据。适用于多张表同步到一张表的汇总同步场景。

    同步操作类型

    根据业务需求选择需要同步的操作类型：

    说明 不支持AlterTable。
    • Insert
    • Update
    • Delete
    • AlterTable
    选择同步对象无

    在源库对象框中单击待同步的表，然后单击向右小箭头将其移动至已选择对象框。

    说明
    映射名称更改无

    如需更改同步对象在目标实例中的名称，请使用对象名映射功能，详情请参见库表列映射。

    源、目标库无法连接重试时间无
    当源、目标库无法连接时，DTS默认重试720分钟（即12小时），您也可以自定义重试时间。如果DTS在设置的时间内重新连接上源、目标库，同步任务将自动恢复。否则，同步任务将失败。
    说明 由于连接重试期间，DTS将收取任务运行费用，建议您根据业务需要自定义重试时间，或者在源和目标库实例释放后尽快释放DTS实例。
  9. 上述配置完成后，单击页面右下角的预检查并启动。
    说明
    • 在同步作业正式启动之前，会先进行预检查。只有预检查通过后，才能成功启动同步作业。
    • 如果预检查失败，单击具体检查项后的提示，查看失败详情。
      • 您可以根据提示修复后重新进行预检查。
      • 如无需修复告警检测项，您也可以选择确认屏蔽、忽略告警项并重新进行预检查，跳过告警检测项重新进行预检查。
  10. 在预检查对话框中显示预检查通过后，关闭预检查对话框，同步作业将正式开始。
  11. 等待同步作业的链路初始化完成，直至处于同步中状态。
    您可以在数据同步页面，查看数据同步作业的状态。查看同步作业状态