一种基于XXL-JOB与FlinkSQL的数据同步方法及系统

(19)中华人民共和国国家知识产权局

	(12)发明专利说明书
		(10)申请公布号 CN 114048492 A (43)申请公布日 2022.02.15

(21)申请号 CN202111297627.4

(22)申请日 2021.11.04

(71)申请人浪潮云信息技术股份公司

地址 250100 山东省济南市高新区浪潮路1036号浪潮科技园S01号楼

(72)发明人高鹏超张立勇孙向晖毛胜磊李宁

(74)专利代理机构 37100 济南信达专利事务所有限公司

代理人冯春连

(51)Int.CI

G06F21/60(20130101)

G06F21/62(20130101)

G06F16/27(20190101)

权利要求说明书说明书幅图

(54)发明名称

一种基于XXL-JOB与FlinkSQL的数据同步方法及系统

(57)摘要

本发明公开一种基于XXL‑JOB与FlinkSQL的数据同步方法及系统，涉及数据同步技术领域，包括如下步骤：基于AES加密算法对接入的数据源信息进行加密传输并存储；通过选择源数据库、目标数据库、配置同步规则构建FlinkSQL任务；基于XXL‑JOB对构建的FlinkSQL任务配置不同的定时规则，启动定时任务；启动定时任务后，将FlinkSQL任务提交至Flink集，通过Flink集实现数据同步。本发明可以解决各种异构数据源之间的高效数据同步问题，克服其他数据同步方案的单一性和低效性。

法律状态

法律状态公告日	法律状态信息	法律状态
2022-02-15	公开	发明专利申请公布
2022-03-04	实质审查的生效IPC(主分类):G06F21/60专利申请号:2021112976274申请日:20211104	实质审查的生效