(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210763888.9 (22)申请日 2022.06.30 (71)申请人 济南浪潮数据技 术有限公司 地址 250101 山东省济南市自由贸易试验 区济南片区浪潮路1036号 浪潮科技园 S05楼S311室 (72)发明人 邢凯　段谊海　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 李宏志 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/23(2019.01) G06F 9/54(2006.01) (54)发明名称 一种数据同步方法、 装置及计算机可读存储 介质 (57)摘要 本申请公开了一种数据同步方法、 装置及计 算机可读存储介质， 涉及服务器技术。 本申请所 提供的数据同步方法通过获取源数据库中的实 时变更数据， 将实时变更数据存储在消息队列 中； 获取消息队列中的实时变更数据， 将实时变 更数据写入目的数据库。 由此可知， 上述方案通 过将数据存储在消息队列， 实现了不同数据库的 数据同步过程中数据获取流程和数据写入流程 的异步处理， 两者互相不干扰。 因此能够进行多 个不同数据库的数据同步， 实现了数据同步的横 向扩展， 能够支持异构数据库之间的数据同步， 具有更高的同步效率。 权利要求书2页 说明书10页 附图4页 CN 115221242 A 2022.10.21 CN 115221242 A 1.一种数据同步方法， 其特 征在于， 包括： 获取源数据库中的实时变更 数据； 将所述实时变更 数据存储在消息队列中； 获取所述消息队列中的所述实时变更 数据； 将所述实时变更 数据写入目的数据库。 2.根据权利要求1所述的数据同步方法， 其特征在于， 所述将所述实时变更数据存储在 消息队列中包括： 获取第一配置中心； 其中， 所述第一配置中心用于配置所述实时变更数据中的表数据 与所述消息队列的topic的对应关系； 根据所述第一配置中心对所述表数据进行 过滤处理； 根据所述第 一配置中心将过滤后的所述表数据写入对应的所述消息队列的所述topic 中。 3.根据权利要求2所述的数据同步方法， 其特征在于， 所述将所述实时变更数据写入目 的数据库包括： 获取第二配置中心； 其中， 所述第二配置中心用于配置所述消息队列的所述topic与所 述目的数据库所需的目的表之间的对应关系； 根据所述第二配置中心对所述表数据进行 过滤处理； 根据所述第二配置中心将过滤后的所述表数据写入所述目的数据库对应的所述目的 表中。 4.根据权利要求1所述的数据同步方法， 其特 征在于， 还 包括： 将所述消息队列中的所述实时变更数据对接至Flink 中， 以用于通过Flink对所述实时 变更数据进行处 理。 5.根据权利要求1至4任意一项所述的数据同步方法， 其特征在于， 在所述获取源数据 库中的实时变更 数据之前， 还 包括： 监听所述目的数据库发送的数据同步请求； 判断所述数据同步请求是否具有数据同步权限； 若是， 则进入所述获取源数据库中的实时变更 数据的步骤。 6.根据权利要求5所述的数据同步方法， 其特征在于， 在所述将所述实时变更数据写入 目的数据库之后， 还 包括： 生成所述实时变更 数据同步完成的提 示信息。 7.根据权利要求5所述的数据同步方法， 其特征在于， 若所述数据同步请求不具有数据 同步权限， 还 包括： 输出数据同步失败的信息 。 8.一种数据同步装置， 其特 征在于， 包括： 第一获取模块， 用于获取源数据库中的实时变更 数据； 存储模块， 用于将所述实时变更 数据存储在消息队列中； 第二获取模块， 用于获取 所述消息队列中的所述实时变更 数据； 写入模块， 用于将所述实时变更 数据写入目的数据库。 9.一种数据同步装置， 其特 征在于， 包括：权　利　要　求　书 1/2 页 2 CN 115221242 A 2存储器， 用于存 储计算机程序； 处理器， 用于执行所述计算机程序时实现如权利要求1至7任一项所述的数据同步方法 的步骤。 10.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质上存储有计算机 程序， 所述计算机程序被处理器执行时实现如权利要求 1至7任一项 所述的数据同步方法的 步骤。权　利　要　求　书 2/2 页 3 CN 115221242 A 3