基于事件驱动架构的交易数据处理方法、装置及设备.pdf

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