通过数据订阅功能,您可以实时订阅增量数据,轻松帮助业务实现轻量级缓存更新、业务异步解耦、含ETL逻辑的数据实时同步等场景。本文介绍如何创建RDS MySQL数据订阅通道。
说明 该功能于2020年3月31日下线。
前提条件
源实例为RDS MySQL,且数据库版本为5.1、5.5、5.6或5.7。
说明 如果待订阅的数据源为8.0版本的RDS MySQL或自建MySQL数据库,请使用新版数据订阅,详情请参见
创建RDS MySQL数据订阅通道。
优惠活动
注意事项
- 订阅通道保存最近24小时的数据,过时的数据将会从订阅通道中删除。
- 在订阅通道运行过程中,请勿使用gh-ost或pt-online-schema-change等类似工具执行在线DDL变更,否则可能导致订阅失败。
操作步骤
- 购买数据订阅通道,详情请参见购买数据订阅通道。
- 登录数据传输控制台。
- 在左侧导航栏,单击数据订阅。
- 在数据订阅列表页面顶部,选择订阅通道所属地域。
- 定位至已购买的数据订阅通道,单击配置订阅通道。
- 配置数据订阅的源库信息。
类别 配置 说明 无 订阅名称 DTS会自动生成一个订阅名称,建议配置具有业务意义的名称(无唯一性要求),便于后续识别。 源库信息 版本类型 选择旧版本。 实例类型 选择RDS实例。 数据库类型 固定为MySQL,不可变更。 实例地区 购买数据订阅通道时选择的源实例地域,不可变更。 RDS实例ID 选择待订阅的RDS实例ID。 说明 暂不支持订阅只读实例或临时实例。数据库账号 填入待订阅的RDS数据库账号。 说明- 该数据库账号需具备REPLICATION CLIENT、REPLICATION SLAVE、SHOW VIEW和所有待订阅对象的SELECT权限。
- 当源RDS实例的数据库类型为MySQL 5.5或MySQL 5.6时,无需配置数据库账号和数据库密码。
数据库密码 填入待订阅的RDS数据库账号对应的密码。 - 上述配置完成后,单击授权白名单并进入下一步。
说明 此步骤会将DTS服务器的IP地址自动添加到源RDS实例的白名单中,用于保障DTS服务器能够正常连接源实例。
- 在弹出的创建订阅账号对话框中,等待账号创建完成后单击下一步。
说明 只有当源RDS实例的数据库类型为 MySQL 5.5或 MySQL 5.6时,才需要经过此步骤。在此步骤中,DTS会在源RDS实例中创建用于数据订阅的数据库账号。
- 配置需要订阅的数据类型和订阅对象。
配置 说明 需要订阅的数据类型 - 数据更新
订阅已选择对象的增量数据更新,包含数据的INSERT、DELETE和UPDATE操作。
- 结构更新
订阅整个实例所有对象的结构创建、删除及修改,您需要使用数据订阅客户端过滤所需的数据。
说明- 如果选择整个库作为订阅对象,那么该库中新增对象的增量数据也可以被订阅到。
- 如果选择某个表作为订阅对象,那么只有这个表的增量数据可以被订阅到。此时如果需要加入一个新的表作为订阅对象,您需要将其加入至订阅对象中,详情请参见修改订阅对象。
订阅对象 在订阅对象框中将想要订阅的对象选中,单击图标将其移动到已选择对象框。
说明 订阅对象选择的粒度可以为库、表两个粒度。 - 数据更新
- 上述配置完成后,单击页面右下角的保存并预检查。
说明
- 在订阅任务正式启动之前,会先进行预检查。只有预检查通过后,才能成功启动订阅任务。
- 如果预检查失败,单击具体检查项后的图标,查看失败详情。根据提示修复问题后,重新进行预检查。
- 在预检查对话框中显示预检查通过后,关闭预检查对话框。
下一步
配置完成后,数据订阅通道会进入初始化阶段,这个阶段一般会持续1分钟左右。初始化完成后即可消费订阅数据,详情请参见使用SDK消费订阅数据。