基于Aliyun RocketMQ http协议做跨互联网数据互通
-
操作示例
准备 CloudCanal
添加数据源
- 本案例采用 MySQL 和阿里云 RocketMQ
- 登录 CloudCanal 平台 ,数据源管理 -> 添加数据源 , 将准备的数据库逐步添加进来
- 建议对数据源进行描述修改,防止配置正反链路时,识别错数据库
RocketMq 的 topic 创建要选择分区顺序消息
创建Mysql->RocketMq同步任务
-
任务管理->新建任务
-
任务同步一般指源端有数据,目标端无数据的链路,涉及对端数据初始化
-
第一个页面
·选择源端和目标端数据源和相关信息,点击下一步 -
第二个页面
·选择全量/增量等功能配置相关信息,点击下一步 -
第三个、第四个页面
·表、列映射裁剪…此处省略
·点击 下一步 -
确认创建
-
任务详情 -> 参数设置
·设置目标 DATASOURCE 参数配置 nameServer 参数为阿里云RocketMQ 的 HTTP 协议客户端公网访问接入点
·设置目标 DATASOURCE 参数配置 protocol 为 HTTP
·生效配置并启动
创建RocketMQ->MySQL同步任务
-
任务管理->新建任务
-
任务同步一般指源端有数据,目标端无数据的链路,涉及对端数据初始化
-
第一个页面
·选择源端和目标端数据源和相关信息,点击下一步 -
第二个页面
·选择全量/增量等功能配置相关信息,点击下一步 -
第三个、第四个页面
·表、列映射裁剪…此处省略
·点击 下一步 -
确认创建
-
任务详情 -> 参数设置
·设置源端 DATASOURCE 参数配置 nameServer 参数为阿里云RocketMQ 的 HTTP 协议客户端公网访问接入点
·设置源端 DATASOURCE 参数配置 protocol 为 HTTP
·生效配置并启动
Copyright © 2020 ClouGence, Inc.备案号:浙ICP备20007605号-2