完成数据订阅通道的配置后,您可以使用DTS提供的SDK示例代码来订阅数据变更信息,本文介绍该示例代码的使用说明。

前提条件

已完成数据订阅通道(旧版)的配置,详情请参见 创建RDS MySQL数据订阅通道 创建数据订阅通道

准备工作

创建AccessKey并获取AccessKey ID和AccessKey Secret信息,详情请参见创建AccessKey

注意 如果使用子账号(RAM用户)来订阅数据,该账号需具备 AliyunDTSFullAccess权限,授权方法请参见 通过系统策略授权子账号管理DTS

操作步骤

本文以IntelliJ IDEA软件(Community Edition 2018.1.4 Windows版本)为例,介绍如何运行SDK示例代码来消费订阅数据。

  1. 根据订阅的数据源选择并下载SDK示例代码文件,然后解压该文件。
  2. 可选:定位至SDK示例代码解压的目录,使用文本编辑工具打开pom.xml文件,将数据订阅SDK的版本修改为最新版本。
    设置SDK版本
    注意 您可以在Maven网站中获取最新的数据订阅SDK版本,详情请参见 数据订阅SDK的Maven页面
  3. 打开IntelliJ IDEA软件,然后单击Open
    打开项目
  4. 在弹出的对话框中,定位至SDK示例代码解压的目录,依次展开文件夹,找到项目对象模型文件:pom.xml
    找到项目对象模型文件
  5. 在弹出对话框中,选择Open as Project
  6. 在IntelliJ IDEA软件界面,依次展开文件夹,找到并双击打开对应的Java客户端文件。
    • RDS MySQL:对应的文件为Main.java打开RDS MySQL的java客户端文件
    • DRDS:对应的文件为drds_demo.java打开DRDS的java客户端文件
  7. 设置Java客户端文件中的代码参数。
    设置参数
    参数 说明
    accessKey 分别填写阿里云账号的AccessKey ID和AccessKey Secret信息,详情请参见准备工作
    accessSecret
    subscribeInstanceID 填写数据订阅实例ID。您可以登录数据传输控制台,单击左侧导航栏的数据订阅,然后找到目标数据订阅实例ID。
  8. 在IntelliJ IDEA软件界面的顶部,选择Run > Run运行该客户端。
    说明 首次运行时,软件需要一定时间自动加载相关依赖包并完成安装。

执行结果

运行结果如下图所示,该客户端可正常订阅到源库的数据变更信息。

SDK示例代码运行结果