(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210631618.2 (22)申请日 2022.06.06 (71)申请人 中国银行股份有限公司 地址 100818 北京市西城区复兴门内大街1 号 (72)发明人 方勇　王安定　朱志宇　牛通　 马换新　张媛媛　方莲娣　王玉婷　 段晓珊　黄俊祥　李洋　张盼盼　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 杨傥月 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/2455(2019.01) G06F 16/25(2019.01)G06F 16/242(2019.01) (54)发明名称 一种数据同步方法及其相关 设备 (57)摘要 本申请公开了一种数据 同步方法及其相关 设备， 该方法包括： 在获取到源端(例如， Kafka集 群等)实时发送的当前流数据片段之后， 按照所 述当前流数据片段的数据类型描述信息(例如， Topic消息等)， 从预先生成的至少一个候选数据 同步规则中确定出待使用数据同步规则， 以使该 待使用数据同步规则能够描述出具有该数据类 型描述信息的源端数据如何转换成目标端数据； 再按照所述待使用数据同步规则， 对 所述当前流 数据片段进行数据映射处理， 得到待使用数据； 最后， 将所述待使用数据存储至目标端(例如， Data Sink等)， 如此能够实现将源端的流式数据 的实时同步至目标端的目的， 从而能够实现针对 流式数据的实时同步处 理。 权利要求书2页 说明书10页 附图5页 CN 114996355 A 2022.09.02 CN 114996355 A 1.一种数据同步方法， 其特 征在于， 所述方法包括： 在获取到源端发送的当前流数据片段之后， 按照所述当前流数据片段的数据类型描述 信息， 从预 先生成的至少一个候选数据同步 规则中确定出待 使用数据同步 规则； 按照所述待使用数据同步规则， 对所述当前流数据片段进行数据映射处理， 得到待使 用数据； 将所述待 使用数据存 储至目标端。 2.根据权利要求1所述的方法， 其特征在于， 所述候选数据同步规则的个数为N； 其中， 第n个候选数据同步规则用于描述第n种源端数据类型与第n种目标端 数据类型之间的数据 映射处理； 其中， n 为正整数， n≤N， N 为正整数。 3.根据权利要求2所述的方法， 其特 征在于， 所述方法还 包括： 响应于用户在同步规则配置页面上触发的操作， 生成待使用配置文件； 其中， 所述待使 用配置文件包括所述源端的数据配置信息和所述目标端的数据配置信息； 所述源端的数据 配置信息包括所述第n种源端数据类型 的数据类型描述信息； 所述 目标端的数据配置信息 包括所述第n种目标端数据类型的数据类型描述信息； 解析所述待使用配置文件， 得到所述第n个候选数据同步 规则。 4.根据权利要求3所述的方法， 其特征在于， 所述操作包括源端信息配置操作、 目标端 信息配置操作、 映射关系配置操作、 和异常容 错配置操作中的至少一个。 5.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 在确定所述当前流数据片段满足预设异常条件时， 按照所述预设异常条件对应的异常 校正规则， 对所述当前流数据片段进行 校正处理， 得到校正后数据； 所述按照所述待使用数据同步规则， 对所述当前流数据片段进行数据映射处理， 得到 待使用数据， 包括： 按照所述待使用数据同步规则， 对所述校正后数据进行数据映射处理， 得到待使用数 据。 6.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 在确定所述当前流数据片段不满足所述数据类型描述信 息对应的数据正常条件时， 更 新所述数据类型描述信息对应的异常计数值； 在确定所述异常数据计数值超过所述数据类型描述信 息对应的异常个数阈值 时， 生成 并发送第一告警信息 。 7.一种数据同步装置， 其特 征在于， 包括： 规则确定单元， 用于在获取到源端发送的当前流数据片段之后， 按照所述当前流数据 片段的数据类型描述信息， 从预先生成的至少一个候选数据同步规则中确定出待使用数据 同步规则； 数据映射单元， 用于按照所述待使用数据同步规则， 对所述当前流数据片段进行数据 映射处理， 得到待 使用数据； 数据同步单 元， 用于将所述待 使用数据存 储至目标端。 8.根据权利要求7 所述的方法， 其特 征在于， 所述装置还 包括： 心跳发送单元， 用于在确定所述数据同步装置处于正常运行状态时， 向注册中心发送 心跳数据， 以使在所述注册中心接 收到所述心跳数据之后， 确定所述所述数据同步装置处权　利　要　求　书 1/2 页 2 CN 114996355 A 2于正常运行状态。 9.根据权利要求8所述的方法， 其特征在于， 所述注册中心， 用于在确定预设时间段内 未接收到所述数据同步装置发送的心跳数据之后， 确定所述数据同步装置处于宕机状态， 生成并发送第二告警信息 。 10.一种设备， 其特 征在于， 所述设备包括处 理器以及存 储器： 所述存储器用于存 储计算机程序； 所述处理器用于根据所述计算机程序执 行权利要求1 ‑6中任一项所述的方法。 11.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质用于存储计算机 程序， 所述计算机程序用于执 行权利要求1 ‑6中任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 114996355 A 3