(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210630765.8 (22)申请日 2022.06.06 (71)申请人 中国银行股份有限公司 地址 100818 北京市西城区复兴门内大街1 号 (72)发明人 肖碧怡　 (74)专利代理 机构 北京三友知识产权代理有限 公司 11127 专利代理师 薛平　沈珍珠 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/2455(2019.01) G06F 16/25(2019.01) (54)发明名称 一种数据更新方法及装置 (57)摘要 本发明公开了一种数据更新方法及装置， 属 于大数据， 其中该方法包括： 外围系统接收核心 系统推送的实时消息， 根据实时消息去数据库中 查询缓存数据， 根据业务要求对查询到的缓存数 据进行业务计算后将结果存入目标数据库中； 外 围系统接收核心系统每日下发的批量数据， 将需 要实时计算的批量数据加载到数据库中， 用以供 查询缓存数据； 外围系统接收核心系统每日下发 的批量数据， 根据要求确定批量数据中变化的数 据后存入目标数据库中； 其中， 目标数据库用于 向外围系统用户提供数据查询服务。 本发明可以 保证用户查询业务数据的时效性； 减少了查询的 时延， 缓解了核心系统的联机查询压力； 保证数 据的一致性、 以及准确性、 有效性。 权利要求书2页 说明书8页 附图2页 CN 114969071 A 2022.08.30 CN 114969071 A 1.一种数据更新方法， 其特 征在于， 包括： 外围系统接收核心系统推送的实时消息， 根据实时消息去数据库中查询缓存数据， 根 据业务要求对查询到的缓存数据进行业 务计算后将结果存 入目标数据库中； 外围系统接收核心系统每日下发的批量数据， 将需要实时计算的批量数据加载到数据 库中， 用以供查询缓存数据； 外围系统接收核心系统每日下发的批量数据， 根据要求确定批量数据中变化的数据后 存入目标数据库中； 其中， 目标 数据库用于向外围系统用户提供 数据查询服 务。 2.如权利要求1所述的方法， 其特征在于， 所述实时消息是核心系统检测到数据库中数 据发生变动 后， 通过Kafka推送的。 3.如权利要求1所述的方法， 其特征在于， 所述用以供查询缓存数据的数据库是Redis 数据库。 4.如权利要求1所述的方法， 其特 征在于， 进一 步包括： 存在以下情况之一或者 其组合时， 外围系统对实时消息进行ETL处 理后进行业 务计算： 数据不正确、 数据重复、 数据格式与外围系统需要的数据格式不 一致。 5.如权利要求1至4任一所述的方法， 其特征在于， 所述实时消息是核心系统中联机查 询次数大于预设次数的接口涉及的数据。 6.一种数据更新装置， 其特 征在于， 位于 外围系统， 包括： 实时更新模块， 用于接收核心系统推送的实时消息， 根据实时消息去数据库中查询缓 存数据， 根据业 务要求对查询到的缓存数据进行业 务计算后将结果存 入目标数据库中； 批量更新模块， 用于接收核心系统每日下发的批量数据， 将需要实时计算的批量数据 加载到数据库中， 用以供查询缓存数据； 根据要求确定批量数据中变化的数据后存入目标 数据库中； 其中， 目标 数据库用于向外围系统用户提供 数据查询服 务。 7.如权利要求6所述的装置， 其特征在于， 实时更新模块进一步用于接收核心系统检测 到数据库中数据发生变动 后， 通过Kafka推送的所述实时消息 。 8.如权利要求6所述的装置， 其特征在于， 实时更新模块进一步用于在Redis数据库查 询缓存数据。 9.如权利要求6所述的装置， 其特征在于， 实时更新模块进一步用于存在以下情况之一 或者其组合时， 对实时消息进行ETL处 理后进行业 务计算： 数据不正确、 数据重复、 数据格式与外围系统需要的数据格式不 一致。 10.如权利要求6至9任一所述的装置， 其特征在于， 实时更新模块进一步用于接收来自 核心系统中联机查询次数 大于预设次数的接口涉及的数据的所述实时消息 。 11.一种计算机设备， 包括存储器、 处理器及存储在存储器上并可在处理器上运行的计 算机程序， 其特征在于， 所述处理器执行所述计算机程序时实现权利要求1至5任一所述方 法。 12.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储有计算机程 序， 所述计算机程序被处 理器执行时实现权利要求1至 5任一所述方法。 13.一种计算机程序产品， 其特征在于， 所述计算机程序产品包括计算机程序， 所述计权　利　要　求　书 1/2 页 2 CN 114969071 A 2算机程序被处 理器执行时实现权利要求1至 5任一所述方法。权　利　要　求　书 2/2 页 3 CN 114969071 A 3