数据订阅

最近更新时间:2019-03-07 17:50:03

1. 功能说明

数据传输服务DTS提供了基于binlog的增量数据订阅功能,仅需几步简单操作,即可订阅云数据库TencentDB的增量更新数据。

  • 在腾讯云DTS控制台购买并创建TencentDB实例的订阅通道。
  • 使用DTS数据订阅SDK连接这个订阅通道,订阅并消费增量数据。

2. 创建数据订阅通道

登录数据传输服务控制台,进入数据订阅页面。

  • 单击控制台右上角【新建数据订阅】开始订阅通道配置。
  • 选择源TencentDB实例所在地域。
  • 开通成功后,进入控制台,为刚才购买的额数据订阅通道初始化配置。
  • 选择源TencentDB实例。
  • 选择所需的同步类型及库表。

    DTS数据订阅的订阅对象粒度细分为库、表。即用户可以选择订阅某些库或者是订阅某几张表。
    DTS将订阅数据类型细分为数据更新、结构更新。如果只选择订阅对象及数据更新的话,那么只能订阅到insert/delete/update三种数据变更内容,如果需要订阅结构更新(DDL),那么需要选择订阅数据类型中的结构变更。一旦订阅了结构更新,那么DTS会将整个TencentDB实例的所有结构变更拉取出来,用户需要使用SDK过滤需要的数据。
  • 当选择完订阅对象后,即可启动订阅通道。

3. 修改消费时间点

DTS支持在消费的过程中,随时修改消费时间点。一旦修改完消费时间点,那么下游SDK拉取到的增量数据从修改后的消费时间点开始。修改的消费时间点必须在订阅通道的数据范围之内。DTS目前只支持在控制台修改消费点,不支持在SDK中指定消费位点。
修改消费时间点操作步骤如下:

  • 停止SDK消费进程。
  • 修改消费时间点。
    当需要修改通道消费时间点时,将鼠标挪到这个通道的消费时间点上,会出现“配置”字样,单击此进入修改页面。

  • 重启SDK消费进程。
    当修改完消费位点后,即可重启本地的SDK消费进程,此时SDK会从修改的消费位点开始订阅增量数据。

4. 修改订阅对象

DTS支持在订阅消费的过程中,动态增加/减少订阅对象。如果增加了订阅对象,那么修改完成后,订阅通道会从当前时间拉取新增订阅对象的增量数据。如果减少订阅对象,那么修改完成后,SDK中将无法再订阅到这个对象的数据。
修改订阅对象操作步骤如下:

  • 修改订阅对象入口。
  • 修改订阅对象。

5. 使用SDK消费数据

请查看SDK使用指南