通过数据订阅功能,您可以实时订阅增量数据,轻松帮助业务实现轻量级缓存更新、业务异步解耦、含ETL逻辑的数据实时同步等场景。本文介绍如何创建RDS for MySQL数据订阅通道。

前提条件

源实例为RDS for MySQL,且数据库版本为5.1、5.5、5.6或5.7。
说明 如果待订阅的数据源为8.0版本的RDS for MySQL或自建MySQL数据库,请使用新版数据订阅,详情请参见创建数据订阅通道(新)

注意事项

订阅通道保存最近24小时的数据,过时的数据将会从订阅通道中删除。

操作步骤

  1. 购买数据订阅通道,详情请参见购买数据订阅通道
  2. 登录数据传输控制台
  3. 在左侧导航栏,单击数据订阅
  4. 数据订阅列表页面顶部,选择订阅通道所属地域。
    选择地域
  5. 定位至已购买的数据订阅通道,单击配置订阅通道
  6. 配置数据订阅的源库信息。
    配置源库信息
    类别 配置 说明
    订阅名称 -
    • DTS为每个数据订阅通道自动生成一个订阅名称,订阅名称没有唯一性要求。
    • 您可以修改订阅名称,建议为任务配置具有业务意义的名称以便于识别。
    源库信息 版本类型 选择旧版本
    实例类型 选择RDS实例
    数据库类型 购买数据订阅通道时选择的订阅实例类型,不可变更。
    实例地区 购买数据订阅通道时选择的源实例地域,不可变更。
    RDS实例ID 选择待订阅的RDS实例ID。
    说明 暂不支持订阅只读实例或临时实例。
    数据库账号 填入待订阅的RDS数据库账号。
    说明
    • 账号需要具备Replication slave、Replication client和同步对象的Select权限。
    • 当源RDS实例的数据库类型为MySQL 5.5MySQL 5.6时,无需配置数据库账号数据库密码
    数据库密码 填入待订阅的RDS数据库账号对应的密码。
  7. 上述配置完成后,单击授权白名单并进入下一步
    说明 此步骤会将DTS服务器的IP地址自动添加到源RDS实例的白名单中,用于保障DTS服务器能够正常连接源实例。
  8. 在弹出的创建订阅账号对话框中,等待账号创建完成后单击下一步
    自动创建订阅账号
    说明 只有当源RDS实例的数据库类型为MySQL 5.5MySQL 5.6时,才需要经过此步骤。在此步骤中,DTS会在源RDS实例中创建用于数据订阅的数据库账号。
  9. 配置需要订阅的数据类型和订阅对象。
    选择订阅类型和对象
    配置 说明
    需要订阅的数据类型
    • 数据更新

      订阅已选择对象的增量数据更新,包含数据的INSERT、DELETE和UPDATE操作。

    • 结构更新

      订阅整个实例所有对象的结构创建、删除及修改,您需要使用数据订阅客户端过滤所需的数据。

    说明
    • 如果选择整个库作为订阅对象,那么该库中新增对象的增量数据也可以被订阅到。
    • 如果选择某个表作为订阅对象,那么只有这个表的增量数据可以被订阅到。此时如果需要加入一个新的表作为订阅对象,您需要将其加入至订阅对象中,详情请参见修改订阅对象
    订阅对象

    订阅对象框中将想要订阅的对象选中,单击向右小箭头移动到已选择对象框。

    说明 订阅对象选择的粒度可以为库、表两个粒度。
  10. 上述配置完成后,单击页面右下角的保存并预检查
    说明
    • 在订阅任务正式启动之前,会先进行预检查。只有预检查通过后,才能成功启动订阅任务。
    • 如果预检查失败,单击具体检查项后的,查看失败详情。根据提示修复问题后,重新进行预检查。
  11. 预检查对话框中显示预检查通过后,关闭预检查对话框。

下一步

配置完成后,数据订阅通道会进入初始化阶段,这个阶段一般会持续1分钟左右。初始化完成后即可消费订阅数据,详情请参见使用SDK消费订阅数据