(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211209286.5 (22)申请日 2022.09.30 (71)申请人 上海浦东发展银行股份有限公司 地址 200000 上海市黄浦区中山 东一路12 号 (72)发明人 古毅伟　竹记　林雯　 (74)专利代理 机构 北京品源专利代理有限公司 11332 专利代理师 黄立伟 (51)Int.Cl. G06F 16/23(2019.01) G06F 9/46(2006.01) G06F 9/54(2006.01) (54)发明名称 一种实时数据更新方法、 装置、 电子设备及 存储介质 (57)摘要 本发明实施例公开了一种实时数据更新方 法、 装置、 电子设备及存储介质， 其中， 应用于数 据处理服务器的实时数据更新方法包括： 根据缓 存队列数据标志 轮询目标队列， 以顺序获取实时 数据更新操作对应的全局事务编号下各局部事 务编号的分布式事务处理数据； 其中， 所述目标 队列包括消息队列和/或缓存队列； 将顺序获取 的所述分布式事务处理数据按照事务处理顺序 同步更新至聚合数据库。 本发明实施例的技术方 案能够保持实时数据更新的时序性， 从而提高实 时数据更新的准确性和可靠性。 权利要求书2页 说明书16页 附图5页 CN 115525666 A 2022.12.27 CN 115525666 A 1.一种实时数据更新方法， 其特 征在于， 应用于数据处 理服务器， 包括： 根据缓存队列 数据标志轮询目标队列， 以顺序获取实时数据更新操作对应的全局事务 编号下各局部事务编号的分布式事务处理数据； 其中， 所述目标队列包括消息队列和/或缓 存队列； 将顺序获取的所述分布式事务处 理数据按照事务处 理顺序同步更新至聚合数据库。 2.根据权利要求1所述的方法， 其特征在于， 所述根据缓存队列数据标志轮询目标队 列， 以顺序获取实时数据更新操作对应的全局事务编号下各局部事务编号的分布式事务处 理数据， 包括： 在确定所述缓存队列 数据标志的标志数据为第 一标志数据的情况下， 轮询所述消息队 列， 以按照所述事务处 理顺序获取当前目标局部事务编号的分布式事务处 理数据； 在确定所述缓存队列 数据标志的标志数据为第 二标志数据的情况下， 轮询所述消息队 列和所述缓存队列， 以按照所述事务处理顺序获取所述当前目标局部事务编号的分布式事 务处理数据； 其中， 在轮询所述目标队列获取到的当前局部事务编 号的分布式事务处理数据不为所 述当前目标局部事务编号的分布式事务处理数据的情况下， 所述当前局部事务编号的分布 式事务处 理数据用于缓存至所述缓存队列中。 3.根据权利要求2所述的方法， 其特征在于， 在所述将顺序获取的所述分布式事务处理 数据按照事务处 理顺序同步更新至聚合数据库之后， 还 包括： 将所述缓存队列数据标志的标志数据重 置为所述第一标志数据。 4.一种实时数据更新方法， 其特 征在于， 应用于局部事务处 理器， 包括： 获取全局事务处 理器根据实时数据更新操作下发的局部事务编号； 根据所述局部事务编号执 行分布式事务， 得到分布式事务处 理数据； 将所述分布式事务处 理数据推送至消息队列进行存 储； 其中， 所述分布式事务处理数据用于数据处理服务器按事务处理顺序同步更新至聚合 服务器。 5.一种实时数据更新方法， 其特 征在于， 应用于全局事务处 理器， 包括： 响应于实时数据 更新操作， 生成所述实时数据更新操作对应的全局事务编 号和局部事 务编号； 将所述实时数据更新操作对应的全局事务编号和局部事务编号发送至数据处理服务 器； 接收所述数据处理服务器反馈的事务编 号关联信 息， 并在确定所述事务编 号关联信 息 通过校验的情况下， 将所述局部事务编号推送至局部事务处理器， 以通过所述局部事务处 理器根据所述局部事务编号执 行分布式事务， 得到分布式事务处 理数据； 其中， 所述分布式事务处理数据用于数据处理服务器按事务处理顺序同步更新至聚合 服务器。 6.一种实时数据更新装置， 其特 征在于， 配置 于数据处 理服务器， 包括： 分布式事务处理数据获取模块， 用于根据缓存队列数据标志轮询目标队列， 以顺序获 取实时数据更新操作对应的全局事务编号下各局部事务编号的分布式事务处理数据； 其 中， 所述目标队列包括消息队列和/或 缓存队列；权　利　要　求　书 1/2 页 2 CN 115525666 A 2分布式事务处理数据 更新模块， 用于将顺序获取的所述分布式事务处理数据按照事务 处理顺序同步更新至聚合数据库。 7.一种实时数据更新装置， 其特 征在于， 配置 于局部事务处 理器， 包括： 局部事务编 号获取模块， 用于获取全局事务处理器根据实时数据 更新操作 下发的局部 事务编号； 分布式事务处理数据生成模块， 用于根据所述局部事务编号执行分布式事务， 得到分 布式事务处 理数据； 分布式事务处理数据推送模块， 用于将所述分布式事务处理数据推送至消息队列进行 存储； 其中， 所述分布式事务处理数据用于数据处理服务器按事务处理顺序同步更新至聚合 服务器。 8.一种实时数据更新装置， 其特 征在于， 配置 于全局事务处 理器， 包括： 事务编号生成模块， 用于响应于实时数据更新操作， 生成所述实时数据更新操作对应 的全局事务编号和 局部事务编号； 事务编号发送模块， 用于将所述实时数据 更新操作对应的全局事务编号和局部事务编 号发送至数据处 理服务器； 局部事务编号推送模块， 用于接收所述数据处理服务器反馈的事务编号关联信息， 并 在确定所述事务编号关联信息通过校验的情况下， 将所述局部事务编号推送至局部事务处 理器， 以通过所述局部事务处理器根据所述局部事务编号执行分布式事务， 得到分布式事 务处理数据； 其中， 所述分布式事务处理数据用于数据处理服务器按事务处理顺序同步更新至聚合 服务器。 9.一种电子设备， 其特 征在于， 所述电子设备包括： 至少一个处 理器； 以及 与所述至少一个处 理器通信连接的存 储器； 其中， 所述存储器存储有可被所述至少一个处理器执行的计算机程序， 所述计算机程序被所 述至少一个处理器执行， 以使 所述至少一个处理器能够执行权利要求 1‑3、 4或5中任一项 所 述的实时数据更新方法。 10.一种计算机存储介质， 其特征在于， 所述计算机可读存储介质存储有计算机指令， 所述计算机指令用于使处理器执行时实现权利要求1 ‑3、 4或5中任一项所述的实时数据更 新方法。权　利　要　求　书 2/2 页 3 CN 115525666 A 3