(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211170499.1 (22)申请日 2022.09.22 (71)申请人 中国银行股份有限公司 地址 100818 北京市西城区复兴门内大街1 号 (72)发明人 张鹏　王双　孔迪　王丽瑶　 (74)专利代理 机构 北京三友知识产权代理有限 公司 11127 专利代理师 汤在彦 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/23(2019.01) G06F 11/30(2006.01) G06F 16/28(2019.01) G06Q 40/02(2012.01) (54)发明名称 ES全文检索服 务器的数据同步方法及装置 (57)摘要 本发明公开了一种ES全文检索服务器的数 据同步方法及装置， 可用于金融领域， 其中方法 包括： 在数据初始化阶段进行生产数据库数据的 初始全量同步处理； 对初始全量同步处理后的生 产数据库数据进行即时增量同步处理和定时增 量同步处理； 根据初始全量同步处理， 即时增量 同步处理和定时增量同步处理过程中的同步异 常数据， 生成同步异常日志； 根据所述同步异常 日志， 进行异常数据同步处理。 本发明可 以进行 ES全文检索服务器的数据同步， 保证数据同步的 及时性和完整性， 避免造成线上事故。 权利要求书2页 说明书6页 附图3页 CN 115422300 A 2022.12.02 CN 115422300 A 1.一种ES全文检索服 务器的数据同步方法， 其特 征在于， 包括： 在数据初始化阶段进行生产数据库数据的初始全量同步处 理； 对初始全量同步处理后的生产数据库数据进行即时增量同步处理和定时增量同步处 理； 根据初始全量同步处理， 即时增量同步处理和定时增量同步处理过程中的同步异常数 据， 生成同步异常日志； 根据所述同步异常日志， 进行异常数据同步处 理。 2.如权利要求1所述的ES全文检索服务器的数据同步方法， 其特征在于， 按如下方式进 行即时增量同步处 理： 监听消息队列MQ； 根据监听的结果， 进行生产数据库数据更新和ES全文检索服 务器更新。 3.如权利要求1所述的ES全文检索服务器的数据同步方法， 其特征在于， 所述生产 数据 库数据为行名行号数据。 4.如权利要求1所述的ES全文检索服务器的数据同步方法， 其特征在于， 根据所述同步 异常日志， 进行异常数据同步处 理， 包括： 根据初始全量同步处理和即时增量同步处理过程中的同步异常数据， 进行异常数据同 步处理； 根据定时增量同步处 理过程中的同步异常数据， 进行异常数据同步处 理。 5.一种ES全文检索服 务器的数据同步装置， 其特 征在于， 包括： 全量同步处理模块， 用于在数据初始化阶段进行生产数据库数据的初始全量同步处 理； 增量同步处理模块， 用于对初始全量同步处理后的生产 数据库数据进行即时增量同步 处理和定时增量同步处 理； 异常日志生成模块， 用于根据初始全量同步处理， 即时增量同步处理和定时增量同步 处理过程中的同步异常数据， 生成同步异常日志； 异常数据同步模块， 用于根据所述同步异常日志， 进行异常数据同步处 理。 6.如权利要求5所述的ES全文检索服务器的数据同步装置， 其特征在于， 增量同步处理 模块进一 步用于： 监听消息队列MQ； 根据监听的结果， 进行生产数据库数据更新和ES全文检索服 务器更新。 7.如权利要求5所述的ES全文检索服务器的数据同步装置， 其特征在于， 所述生产 数据 库数据为行名行号数据。 8.如权利要求5所述的ES全文检索服务器的数据同步装置， 其特征在于， 异常数据同步 模块进一 步用于： 根据初始全量同步处理和即时增量同步处理过程中的同步异常数据， 进行异常数据同 步处理； 根据定时增量同步处 理过程中的同步异常数据， 进行异常数据同步处 理。 9.一种计算机设备， 包括存储器、 处理器及存储在存储器上并可在处理器上运行的计 算机程序， 其特征在于， 所述处理器执行所述计算机程序时实现权利要求1至4任一所述方权　利　要　求　书 1/2 页 2 CN 115422300 A 2法。 10.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储有计算机程 序， 所述计算机程序被处 理器执行时实现权利要求1至4任一所述方法。 11.一种计算机程序产品， 其特征在于， 所述计算机程序产品包括计算机程序， 所述计 算机程序被处 理器执行时实现权利要求1至4任一所述方法。权　利　要　求　书 2/2 页 3 CN 115422300 A 3