创建RDS MySQL数据订阅通道

注意事项

• 由于使用gh-ost或pt-online-schema-change等类似工具执行在线DDL变更不会被订阅到，客户端在将消费到的数据写入目标表时可能会因为表结构不一致而导致写入失败。
• 如果订阅的源数据库还处于其他任务中（例如该数据库还存在于某个正在运行的数据迁移任务中），您可能会订阅到订阅对象以外的数据，此类场景中，您需要手动在订阅客户端中过滤掉不需要的数据。

操作步骤

1. 购买数据订阅通道，详情请参见购买数据订阅任务。
2. 登录数据传输控制台。
3. 在左侧导航栏，单击数据订阅。
4. 在数据订阅列表页面上方，选择订阅通道所属地域。
5. 定位至已购买的数据订阅通道，单击配置订阅通道。
6. 配置数据订阅的源库信息和网络类型。
7. 上述配置完成后，单击授权白名单并进入下一步。

   如果源数据库是阿里云数据库实例（例如RDS MySQL、云数据库MongoDB版等），DTS会自动将对应地区DTS服务的IP地址添加到阿里云数据库实例的白名单；如果源数据库是ECS上的自建数据库，DTS会自动将对应地区DTS服务的IP地址添到ECS的安全规则中，您还需手动在ECS上的自建数据库中添加对应地区DTS服务的IP地址，以允许来自DTS服务器的访问；如果源数据库是IDC自建数据库或其他云数据库，则需要您手动添加对应地区DTS服务的IP地址，以允许来自DTS服务器的访问。DTS服务的IP地址，请参见DTS服务器的IP地址段。

   警告 DTS自动添加或您手动添加DTS服务的公网IP地址段可能会存在安全风险，一旦使用本产品代表您已理解和确认其中可能存在的安全风险，并且需要您做好基本的安全防护，包括但不限于加强账号密码强度防范、限制各网段开放的端口号、内部各API使用鉴权方式通信、定期检查并限制不需要的网段，或者使用通过内网（专线/VPN网关/智能网关）的方式接入。
8. 在弹出的创建订阅账号对话框中，等待账号创建完成后单击下一步。
9. 配置需要订阅的数据类型和订阅对象。
10. 上述配置完成后，单击页面右下角的保存并预检查。
    说明

    • 在订阅任务正式启动之前，会先进行预检查。只有预检查通过后，才能成功启动订阅任务。
    • 如果预检查失败，单击具体检查项后的
11. 在预检查对话框中显示预检查通过后，关闭预检查对话框。

配置完成后，数据订阅通道会进入初始化阶段，这个阶段一般会持续1分钟左右。初始化完成后即可进行新增消费组与消费订阅数据的操作。

下一步

1. 新增消费组
2. 使用Kafka客户端消费订阅数据
3. 使用SDK示例代码消费订阅数据