通过数据订阅功能,您可以实时订阅源库的增量数据,轻松帮助业务实现轻量级缓存更新、业务异步解耦、含ETL逻辑的数据实时同步等场景。本文将介绍如何创建PolarDB-X 数据订阅通道。
前提条件
PolarDB-X 中的数据库须基于RDS MySQL创建,且RDS MySQL版本需为5.5或5.6。
说明 DTS暂不支持订阅基于PolarDB MySQL创建的PolarDB-X 数据库。
注意事项
- 订阅通道保存最近24小时的数据,过时的数据将会从订阅通道中删除。
- 数据订阅通道运行期间,请勿对PolarDB-X 实例执行扩容、缩容、迁移热点表、变更拆分键和变更DDL等操作,否则将导致数据订阅失败。
- 此场景中,数据订阅通道配置完成后,不支持修改订阅对象。
- 不支持整库订阅,只支持表级别订阅。
- 不支持订阅源实例的
结构更新
。
操作步骤
- 购买数据订阅通道,详情请参见购买流程。
- 登录数据传输控制台。
- 在左侧导航栏,单击数据订阅。
- 在数据订阅列表页面顶部,选择订阅通道所属地域。
- 定位至已购买的数据订阅通道,单击配置订阅通道。
- 配置数据订阅的源库信息。

类别 |
配置 |
说明 |
无 |
订阅名称 |
DTS会自动生成一个订阅名称,建议配置具有业务意义的名称(无唯一性要求),便于后续识别。 |
源库信息 |
实例类型 |
选择DRDS实例。
|
数据库类型 |
固定为DRDS,不可变更。
|
实例地区 |
购买数据订阅通道时选择的源实例地域,不可变更。
|
DRDS实例ID |
选择待订阅的PolarDB-X 实例ID。
|
数据库名称 |
选择PolarDB-X 实例中待订阅的数据库。
|
数据库账号 |
填入PolarDB-X 实例的数据库账号。
|
数据库密码 |
填入该数据库账号对应的密码。 |
- 上述配置完成后,单击授权白名单并进入下一步。
警告
- 如果源或目标数据库是阿里云数据库实例(例如RDS MySQL、云数据库MongoDB版等)或ECS上的自建数据库,DTS会自动将对应地区DTS服务的IP地址添加到阿里云数据库实例的白名单或ECS的安全规则中,您无需手动添加,请参见DTS服务器的IP地址段;如果源或目标数据库是IDC自建数据库或其他云数据库,则需要您手动添加对应地区DTS服务的IP地址,以允许来自DTS服务器的访问。
- 上述场景中,DTS自动添加或您手动添加DTS服务的公网IP地址段可能会存在安全风险,一旦使用本产品代表您已理解和确认其中可能存在的安全风险,并且需要您做好基本的安全防护,包括但不限于加强账号密码强度防范、限制各网段开放的端口号、内部各API使用鉴权方式通信、定期检查并限制不需要的网段,或者使用通过内网(专线/VPN网关/智能网关)的方式接入。
- DTS任务完成或释放后,建议您手动检测并删除DTS相关的服务器IP地址段。
- 配置需要订阅的数据类型和订阅对象。

配置 |
说明 |
需要订阅的数据类型 |
仅支持数据更新 ,即订阅已选择对象的增量数据更新,包含数据的INSERT、DELETE和UPDATE操作。
|
订阅对象 |
在订阅对象框中将想要订阅的对象选中,单击 图标将其移动到已选择对象框。
说明
- 此场景中,订阅对象的选择粒度为表,暂不支持选择整个库作为订阅对象。
- 订阅任务配置完成后,不支持修改订阅对象,如果需要新增订阅的表,需要新建订阅任务。
|
- 上述配置完成后,单击页面右下角的保存并预检查。
说明
- 在订阅任务正式启动之前,会先进行预检查。只有预检查通过后,才能成功启动订阅任务。
- 如果预检查失败,单击具体检查项后的
图标,查看失败详情。根据提示修复问题后,重新进行预检查。
- 在预检查对话框中显示预检查通过后,关闭预检查对话框,订阅通道进入初始化阶段。
后续步骤
配置完成后,数据订阅通道会进入初始化阶段。初始化完成后即可消费订阅数据,详情请参见使用SDK示例代码消费订阅数据。