(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210741314.1 (22)申请日 2022.06.28 (71)申请人 中国银行股份有限公司 地址 100818 北京市西城区复兴门内大街1 号 (72)发明人 王增峰　 (74)专利代理 机构 北京三友知识产权代理有限 公司 11127 专利代理师 刘飞　陶海萍 (51)Int.Cl. G06Q 40/04(2012.01) G06Q 30/02(2012.01) G06F 16/25(2019.01) (54)发明名称 基于事件驱动架构的交易数据处理方法、 装 置及设备 (57)摘要 本说明书涉及交易数据处理技术领域， 提供 了一种基于事件驱动架构的交易数据处理方法、 装置及设备， 该方法包括： 获取事件生产者通过 异步消息机制发布的交易事件； 调用所述交易事 件对应的操作算子集合中的一个或多个操作算 子， 以生成对应的目标交易事件； 所述操作算子 集合中每个操作算子由该交易事件的事件消费 者定义； 将所述目标交易事件通过异步消息机制 推送给对应的事件消费者。 本说明书实施例可以 降低交易数据处理中上下游的耦合度， 提高交易 数据处理场景的可扩 展性。 权利要求书2页 说明书10页 附图4页 CN 115099972 A 2022.09.23 CN 115099972 A 1.一种基于事 件驱动架构的交易数据处 理方法， 其特 征在于， 包括： 获取事件生产者 通过异步消息 机制发布的交易事 件； 调用所述交易事件对应的操作算子集合中的一个或多个操作算子， 以生成对应的目标 交易事件； 所述操作算子集 合中每个操作算子由该交易事 件的事件消费者定义； 将所述目标交易事 件通过异步消息 机制推送给对应的事 件消费者。 2.如权利要求1所述的基于事件驱动架构的交易数据处理方法， 其特征在于， 在调用所 述交易事 件对应的操作算子集 合中的操作算之前， 还 包括： 确认所述交易事 件的数据类型； 所述数据类型包括有界数据流和无界数据流； 当所述交易事件为无界数据流 时， 根据预设的延迟触发策略调用所述交易事件对应的 操作算子集 合中的一个或多个操作算子 。 3.如权利要求2所述的基于事件驱动架构的交易数据处理方法， 其特征在于， 所述根据 预设的延迟触发策略调用所述交易事件对应的操作算子集合中的一个或多个操作算子， 包 括： 确定当前已到 达的交易事 件集合中创建时间最 新的交易事 件对应的创建时间； 从所述已到达的交易事件集合中获取当前滚动窗口内的交易事件， 形成交易事件子集 合； 其中， 当前滚动窗口内的交易事件为tmax‑τ范围内的指 定数量个创建时间最新的交易事 件， tmax为当前已到达的交易事件集合中创建时间最新的交易事件对应的创建时间， τ为预 设的延迟时长； 对于所述交易事件子集合中的每个交易事件， 调用该交易事件对应的操作算子集合中 的一个或多个操作算子， 以生成对应的目标交易事 件。 4.如权利要求1所述的基于事件驱动架构的交易数据处理方法， 其特征在于， 所述操作 算子包括以下中的任意 一种： 过滤操作算子； 映射操作算子； 内连接操作算子； 外连接操作算子 。 5.如权利要求2所述的基于事件驱动架构的交易数据处理方法， 其特征在于， 所述确 认 所述交易事 件的数据类型， 包括： 确定接收所述交易事 件的交易事 件接口标识； 根据所述交易事 件接口标识查询接口与数据类型对应关系表； 根据查询结果确定所述交易事 件的数据类型。 6.如权利要求1所述的基于事件驱动架构的交易数据处理方法， 其特征在于， 所述异步 消息机制包括消息队列或云消息队列。 7.一种基于事 件驱动架构的交易数据处 理装置， 其特 征在于， 包括： 获取模块， 用于获取事 件生产者 通过异步消息 机制发布的交易事 件； 调用模块， 用于调用所述交易事件对应的操作算子集合中的一个或多个操作算子， 以 生成对应的目标 交易事件； 所述操作算子集合中每个操作算子由该交易事件的事件消费者 定义； 推送模块， 用于将所述目标交易事 件通过异步消息 机制推送给对应的事 件消费者。权　利　要　求　书 1/2 页 2 CN 115099972 A 28.一种计算机设备， 包括存储器、 处理器、 以及存储在所述存储器上的计算机程序， 其 特征在于， 所述计算机程序被所述处理器运行时， 执行根据权利要求 1‑6任意一项 所述方法 的指令。 9.一种计算机存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序被计算 机设备的处 理器运行时， 执 行根据权利要求1 ‑6任意一项所述方法的指令 。 10.一种计算机程序产品， 其特征在于， 所述计算机程序产品包括计算机程序， 所述计 算机程序被处 理器运行时， 执 行根据权利要求1 ‑6任意一项所述方法的指令 。权　利　要　求　书 2/2 页 3 CN 115099972 A 3