(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211193273.3 (22)申请日 2022.09.28 (71)申请人 中国农业银行股份有限公司 地址 100005 北京市东城区建国门内大街 69号 (72)发明人 李宁　王凯旋　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 丁曼曼 (51)Int.Cl. G06F 16/2455(2019.01) G06F 16/23(2019.01) G06F 16/27(2019.01) (54)发明名称 一种缓存更新方法及装置 (57)摘要 本申请公开了一种缓存 更新方法及装置， 该 方法包括： 当数据库中的目标表格发生数据变更 时， 获取目标表格的变更数据。 然后基于第一流 计算拓扑解析所获取的变更数据， 生成第一报 文。 利用第二流计算拓扑对第一报文进行加工处 理， 获取处理好的第二报文。 基于第三流计算拓 扑对第二报文进行落地处理， 也就是， 获取满足 缓存存储格式的第三报文， 然后基于第三报文更 新缓存。 通过本申请所提供的缓存更新方法， 可 以及时获取数据库中发生变更的数据， 并利用流 计算结构 对数据进行处理， 以基于变更数据更新 缓存， 从而后续可 以直接在缓存中读取数据， 提 高读取数据的效率， 降低数据库的查询压力。 权利要求书2页 说明书9页 附图2页 CN 115525682 A 2022.12.27 CN 115525682 A 1.一种缓存更新方法， 其特 征在于， 所述方法包括： 响应于目标表格中变更 数据的操作， 获取 所述目标表格的变更 数据； 基于第一 流计算拓扑， 解析 所述变更 数据生成一个或多个第一报文； 针对所述一个或多个第 一报文中的任一第 一报文， 基于第 二流计算拓扑对所述第 一报 文进行处理， 获取第二报文； 基于第三 流计算拓扑对所述第二报文 进行落地处理， 获取第三报文； 基于所述第三报文更新缓存。 2.根据权利要求1所述的方法， 其特征在于， 所述解析所述变更数据生成一个或多个第 一报文， 包括： 解析所述变更 数据生成第一或多个第四报文； 针对所述 一个或多个第四报文的任一第四报文， 获取 所述第四报文所对应的主键； 当包括多个所述主键时， 获取所述主键所对应的最新第四报文为所述第 一报文； 或者， 当包括一个所述主键时， 获取 所述主键所对应的第四报文为所述第一报文。 3.根据权利要求1所述的方法， 其特征在于， 所述基于第 二流计算拓扑对所述第 一报文 进行处理， 获取第二报文， 包括： 基于所述第二流计算拓扑的分发组件， 将所述第一报文分发到对应的流中， 所述流与 所述第一报文具有相同的标识； 建立与所述第一报文所对应的第一组件； 基于所述第一组件接收所述 流， 对所述 流中的第一报文 进行处理， 获取所述第二报文。 4.根据权利要求3所述的方法， 其特征在于， 所述对所述流中的第一报文进行处理， 包 括： 对所述流中的第一报文 进行联合查询补充和/或对所述第一报文的字段进行翻译。 5.根据权利要求1所述的方法， 其特征在于， 所述基于第 三流计算拓扑对所述第 二报文 进行落地处理， 获取第三报文， 包括： 基于所述第二报文的内容生成在所述缓存中所对应的键、 值以及值类型， 组成所述第 三报文。 6.根据权利要求1所述的方法， 其特征在于， 所述响应于目标表格中变更数据的操作， 获取所述目标表格的变更 数据， 包括： 建立与所述目标表格所对应的触发器； 响应于所述目标表格中变更数据的操作， 利用所述触发器获取所述目标表格的变更数 据。 7.一种缓存更新装置， 其特 征在于， 所述装置包括： 获取单元， 用于响应于目标表格中变更 数据的操作， 获取 所述目标表格的变更 数据； 解析单元， 用于基于第一 流计算拓扑， 解析 所述变更 数据生成一个或多个第一报文； 第一处理单元， 用于针对所述一个或多个第一报文中的任一第一报文， 基于第二流计 算拓扑对所述第一报文 进行处理， 获取第二报文； 第二处理单元， 用于基于第三流计算拓扑对所述第二报文进行落地处理， 获取第三报 文； 更新单元， 用于基于所述第三报文更新缓存。权　利　要　求　书 1/2 页 2 CN 115525682 A 28.根据权利要求7所述的装置， 其特征在于， 所述解析单元， 具体用于解析所述变更数 据生成第一或多个第四报文； 针对所述一个或多个第四报文的任一第四报文， 获取所述第 四报文所对应的主键； 当包括多个所述主键时， 获取所述主键所对应的最新第四报文为所 述第一报文； 或者， 当包括一个所述主键时， 获取所述主键所对应的第四报文为所述第一报 文。 9.根据权利要求7所述的装置， 其特征在于， 所述第一处理单元， 具体用于基于所述第 二流计算拓扑 的分发组件， 将所述第一报文分发到对应的流中， 所述流与所述第一报文具 有相同的标识； 建立与所述第一报文 所对应的第一组件； 基于所述第一组件接收所述流， 对 所述流中的第一报文 进行处理， 获取所述第二报文。 10.根据权利要求7所述的装置， 其特征在于， 所述第 二处理单元， 具体用于基于所述第 二报文的内容获取在所述缓存中所对应的键、 值以及值类型， 组成所述第三报文。权　利　要　求　书 2/2 页 3 CN 115525682 A 3