(19)国家知识产权局
(12)发明 专利申请
(10)申请公布号
(43)申请公布日
(21)申请 号 202211176624.X
(22)申请日 2022.09.26
(71)申请人 中国建设银行股份有限公司
地址 100033 北京市西城区金融大街25号
申请人 建信金融科技有限责任公司
(72)发明人 林思远 张永育 张一浓 翁世清
陈守当
(74)专利代理 机构 北京同立钧成知识产权代理
有限公司 1 1205
专利代理师 王欢 臧建明
(51)Int.Cl.
G06F 16/27(2019.01)
G06F 16/25(2019.01)
G06F 16/22(2019.01)
(54)发明名称
数据同步方法、 装置及服 务器集群
(57)摘要
本申请提供一种数据同步方法、 装置及服务
器集群, 涉及计算机技术, 该方法包括: 响应于同
步数据指令, 生成 并向第一服务器集群中的第一
服务器发送包含数据抽取条件和源表的获取数
据指令; 接收第一服务器发送的目标数据, 并将
目标数据发送至第二服务器集群中的预设路径
中。 向第二服务器集群中的第二服务器发送读取
数据指令; 若确定第二服务器已读取完毕, 则生
成并向第二服务器发送与操作命令行对应的操
作指令, 以使第二服务器根据操作指令对目标数
据进行加工处理, 得到加工的目标数据, 以完成
数据同步操作。 本申请的方法, 能够灵活适配数
仓表格, 在两个数据库之间进行表格中数据的同
步, 解决了备份数据的效率较低的技 术问题。
权利要求书3页 说明书13页 附图6页
CN 115391463 A
2022.11.25
CN 115391463 A
1.一种数据同步方法, 其特 征在于, 所述方法包括:
响应于同步数据指令, 其中, 所述同步数据指令包括数据抽取条件、 用于抽取数据的源
表、 以及操作命令行, 生成并向第一服务器集群中的第一服务器发送包含所述数据抽取条
件和所述源表的获取数据指令, 以使所述第一服务器根据所述获取数据指令, 从所述第一
服务器中对应的第一数据库中获取 所述源表中的满足所述数据抽取 条件的目标 数据;
接收所述第 一服务器发送的所述目标数据, 并将所述目标数据发送至第 二服务器集群
中的预设路径中;
向所述第二服务器集群中的第二服务器发送读取数据指令; 其中, 所述读取数据指令
用于指示在所述预设路径中读取 所述目标 数据;
若确定所述第 二服务器已读取完毕, 则生成并向所述第 二服务器发送与所述操作命令
行对应的操作指令, 以使所述第二服务器根据所述操作指令对所述目标数据进行加工处
理, 得到加工的目标 数据, 以完成数据同步操作。
2.根据权利要求1所述的方法, 其特征在于, 所述响应于同步数据指令, 生成并向所述
第一服务器集群中的第一服务器发送包含所述数据抽取条件和所述源表的获取数据指 令,
包括:
所述响应于同步数据指令, 对所述同步数据指令进行解析, 得到所述同步数据指令中
的数据抽取 条件、 用于抽取 数据的源表;
生成包含所述数据抽取 条件和所述源表的获取 数据指令;
向所述第一服务器集群中第一服务器发送包含所述数据抽取条件和所述源表的获取
数据指令, 以使所述第一服务器根据所述获取数据指令, 从所述第一服务器中对应的第一
数据库中获取 所述源表中的满足所述数据抽取 条件的目标 数据。
3.根据权利要求2所述的方法, 其特征在于, 所述同步数据指令还包括用于存储所述目
标数据的目标表; 在所述响应于同步数据指 令, 对所述同步数据指 令进行解析, 得到所述同
步数据指令中的数据抽取 条件、 用于抽取 数据的源表之后, 所述方法, 还 包括:
向第二服务器发送确 认目标表指令, 以使所述第 二服务器根据 所述确认目标表指令确
认是否需要生成目标表;
若接收到所述第 二服务器发送的生成指令, 则向所述第 二服务器发送所述源表中的字
段; 其中, 所述源表中的字段用于根据预设的第一数据库中的字段与第二数据库的字段之
间的映射关系, 确定与所述源表中的字段对应的第二数据库中的字段, 根据确定的所述第
二数据库中的字段生成目标表并将所述目标表存 储于第二 服务器对应的第二数据库中;
若接收到所述第 二服务器发送的生成成功指令, 则确定所述第 二服务器对应的第 二数
据库内存在所述目标表。
4.根据权利要求2所述的方法, 其特征在于, 所述同步数据指令还包括分区模式; 在所
述响应于同步数据指令, 对所述同步数据指令进行解析, 得到所述同步数据指令中的数据
抽取条件、 用于抽取 数据的源表之后, 所述方法, 还 包括:
确定所述分区模式的类型; 其中, 所述类型包括静态分区模式和动态分区模式;
生成与所述分区模式的类型对应的目标分区; 其中, 所述分区用于存 储目标表。
5.根据权利要求3或4所述的方法, 其特征在于, 所述读取数据指令用于指示在所述预
设路径中读取 所述目标 数据至所述目标分区中的所述目标表中。权 利 要 求 书 1/3 页
2
CN 115391463 A
26.根据权利要求2所述的方法, 其特征在于, 所述同步数据指令还包括所述源表的业务
类型; 在所述响应于同步数据指 令, 对所述同步数据指 令进行解析, 得到所述同步数据指 令
中的数据抽取 条件、 用于抽取 数据的源表之后, 所述方法, 还 包括:
根据预设的业务类型与业务算法之间的对应关系, 确定并调用所述源表的业务类型对
应的目标业 务算法。
7.根据权利要求6所述的方法, 其特征在于, 所述若确定所述第二服务器已读取完毕,
则生成并向所述第二 服务器发送与所述操作命令行对应的操作指令, 包括:
若确定所述第 二服务器已读取完毕, 则根据 所述目标业务算法生成与 所述操作命令行
对应的操作指令, 并向所述第二 服务器发送所述操作指令 。
8.根据权利要求1所述的方法, 其特 征在于, 所述方法还 包括:
接收所述第二 服务器发送的错 误记录条 数;
若确定所述错误记录条数小于等于预设的容错阈值, 则确定所述目标数据的同步操作
成功。
9.根据权利要求1 ‑4或6‑8任一项所述的方法, 其特征在于, 所述同步数据指令还包括
全量数据同步模式或增量数据同步模式。
10.一种数据同步装置, 其特 征在于, 包括:
第一发送单元, 用于响应于同步数据指令, 其中, 其中, 所述同步数据指令包括数据抽
取条件、 用于抽取数据的源表、 以及操作命令行, 生成并向第一服务器集群中的第一服务器
发送包含所述数据抽取条件和所述源表的获取数据指 令, 以使所述第一服务器根据所述 获
取数据指 令, 从所述第一服务器中对应的第一数据库中获取所述源表中的满足所述数据抽
取条件的目标 数据;
第二发送单元, 用于接收所述第一服务器发送的所述目标数据, 并将所述目标数据发
送至第二 服务器集群中的预设路径中;
第三发送单元, 用于向所述第 二服务器集群 中的第二服务器发送读取数据指令; 其中,
所述读取 数据指令用于指示在所述预设路径中读取 所述目标 数据;
第四发送单元, 用于若确定所述第二服务器已读取完毕, 则生成并向所述第二服务器
发送与所述操作命令行对应的操作指 令, 以使所述第二服务器根据所述操作指 令对所述目
标数据进行加工处 理, 得到加工的目标 数据, 以完成数据同步操作。
11.根据权利要求10所述的装置, 其特 征在于, 所述第一发送单 元, 包括:
解析模块, 用于所述响应于同步数据指令, 对所述同步数据指令进行解析, 得到所述同
步数据指令中的数据抽取 条件、 用于抽取 数据的源表;
第一生成模块, 用于生成包 含所述数据抽取 条件和所述源表的获取 数据指令;
第一发送模块, 用于向所述第 一服务器集群中第 一服务器发送包含所述数据抽取条件
和所述源表的获取数据指令, 以使所述第一服务器根据所述获取数据指令, 从所述第一服
务器中对应的第一数据库中获取 所述源表中的满足所述数据抽取 条件的目标 数据。
12.根据权利要求11所述的装置, 其特征在于, 所述同步数据指令还包括用于存储所述
目标数据的目标表; 所述装置, 还 包括:
第二发送模块, 用于在所述响应于同步数据指令, 对所述同步数据指令进行解析, 得到
所述同步数据指令中的数据抽取条件、 用于抽取数据的源表之后, 向第二服务器发送确认权 利 要 求 书 2/3 页
3
CN 115391463 A
3
专利 数据同步方法、装置及服务器集群
文档预览
中文文档
23 页
50 下载
1000 浏览
0 评论
0 收藏
3.0分
温馨提示:本文档共23页,可预览 3 页,如浏览全部内容或当前文档出现乱码,可开通会员下载原始文档
本文档由 SC 于 2024-02-18 22:33:12上传分享