基于Aliyun RocketMQ http协议做跨互联网数据互通

[cloudcanal-白也]

操作示例

准备 CloudCanal

• 登陆 CloudCanal SaaS版,使用参见快速上手文档

添加数据源

• 本案例采用 MySQL 和阿里云 RocketMQ
• 登录 CloudCanal 平台 ，数据源管理 -> 添加数据源 , 将准备的数据库逐步添加进来
• 建议对数据源进行描述修改，防止配置正反链路时，识别错数据库
  RocketMq 的 topic 创建要选择分区顺序消息
  

创建Mysql->RocketMq同步任务

• 任务管理->新建任务

• 任务同步一般指源端有数据，目标端无数据的链路，涉及对端数据初始化

• 第一个页面
  ·选择源端和目标端数据源和相关信息，点击下一步

• 第二个页面
  ·选择全量/增量等功能配置相关信息，点击下一步

• 第三个、第四个页面
  ·表、列映射裁剪…此处省略
  ·点击 下一步

• 确认创建
  

• 任务详情 -> 参数设置
  ·设置目标 DATASOURCE 参数配置 nameServer 参数为阿里云RocketMQ 的 HTTP 协议客户端公网访问接入点
  ·设置目标 DATASOURCE 参数配置 protocol 为 HTTP
  ·生效配置并启动
  

创建RocketMQ->MySQL同步任务

• 任务管理->新建任务

• 任务同步一般指源端有数据，目标端无数据的链路，涉及对端数据初始化

• 第一个页面
  ·选择源端和目标端数据源和相关信息，点击下一步

• 第二个页面
  ·选择全量/增量等功能配置相关信息，点击下一步

• 第三个、第四个页面
  ·表、列映射裁剪…此处省略
  ·点击 下一步

• 确认创建
  

• 任务详情 -> 参数设置
  ·设置源端 DATASOURCE 参数配置 nameServer 参数为阿里云RocketMQ 的 HTTP 协议客户端公网访问接入点
  ·设置源端 DATASOURCE 参数配置 protocol 为 HTTP
  ·生效配置并启动