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

前提条件

PolarDB-X 中的数据库须基于RDS MySQL创建,且RDS MySQL版本需为5.5或5.6。
说明 DTS暂不支持订阅基于PolarDB MySQL创建的PolarDB-X 数据库。

注意事项

  • 订阅通道保存最近24小时的数据,过时的数据将会从订阅通道中删除。
  • 数据订阅通道运行期间,请勿对PolarDB-X 实例执行扩容、缩容、迁移热点表、变更拆分键和变更DDL等操作,否则将导致数据订阅失败。
  • 此场景中,数据订阅通道配置完成后,不支持修改订阅对象
  • 不支持整库订阅,只支持表级别订阅。
  • 不支持订阅源实例的 结构更新

操作步骤

  1. 购买数据订阅通道,详情请参见购买流程
    说明 需选择订阅实例类型DRDS
  2. 登录数据传输控制台
  3. 在左侧导航栏,单击数据订阅
  4. 数据订阅列表页面顶部,选择订阅通道所属地域。
  5. 定位至已购买的数据订阅通道,单击配置订阅通道
  6. 配置数据订阅的源库信息。
    配置源库信息
    类别 配置 说明
    订阅名称 DTS会自动生成一个订阅名称,建议配置具有业务意义的名称(无唯一性要求),便于后续识别。
    源库信息 实例类型 选择DRDS实例
    数据库类型 固定为DRDS,不可变更。
    实例地区 购买数据订阅通道时选择的源实例地域,不可变更。
    DRDS实例ID 选择待订阅的PolarDB-X 实例ID。
    数据库名称 选择PolarDB-X 实例中待订阅的数据库。
    数据库账号 填入PolarDB-X 实例的数据库账号。
    数据库密码 填入该数据库账号对应的密码。
  7. 上述配置完成后,单击授权白名单并进入下一步
    警告
    • 如果源或目标数据库是阿里云数据库实例(例如RDS MySQL、云数据库MongoDB版等)或ECS上的自建数据库,DTS会自动将对应地区DTS服务的IP地址添加到阿里云数据库实例的白名单或ECS的安全规则中,您无需手动添加,请参见DTS服务器的IP地址段;如果源或目标数据库是IDC自建数据库或其他云数据库,则需要您手动添加对应地区DTS服务的IP地址,以允许来自DTS服务器的访问。
    • 上述场景中,DTS自动添加或您手动添加DTS服务的公网IP地址段可能会存在安全风险,一旦使用本产品代表您已理解和确认其中可能存在的安全风险,并且需要您做好基本的安全防护,包括但不限于加强账号密码强度防范、限制各网段开放的端口号、内部各API使用鉴权方式通信、定期检查并限制不需要的网段,或者使用通过内网(专线/VPN网关/智能网关)的方式接入。
    • DTS任务完成或释放后,建议您手动检测并删除DTS相关的服务器IP地址段。
  8. 配置需要订阅的数据类型和订阅对象。
    选择订阅类型和对象
    配置 说明
    需要订阅的数据类型 仅支持数据更新 ,即订阅已选择对象的增量数据更新,包含数据的INSERT、DELETE和UPDATE操作。
    订阅对象 订阅对象框中将想要订阅的对象选中,单击向右小箭头图标将其移动到已选择对象框。
    说明
    • 此场景中,订阅对象的选择粒度为表,暂不支持选择整个库作为订阅对象。
    • 订阅任务配置完成后,不支持修改订阅对象,如果需要新增订阅的表,需要新建订阅任务。
  9. 上述配置完成后,单击页面右下角的保存并预检查
    说明
    • 在订阅任务正式启动之前,会先进行预检查。只有预检查通过后,才能成功启动订阅任务。
    • 如果预检查失败,单击具体检查项后的提示图标,查看失败详情。根据提示修复问题后,重新进行预检查。
  10. 预检查对话框中显示预检查通过后,关闭预检查对话框,订阅通道进入初始化阶段。

后续步骤

配置完成后,数据订阅通道会进入初始化阶段。初始化完成后即可消费订阅数据,详情请参见使用SDK示例代码消费订阅数据