(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211235151.6 (22)申请日 2022.10.10 (71)申请人 中国农业银行股份有限公司 地址 100005 北京市东城区建国门内大街 69号 (72)发明人 冯琦　李聪聪　成鹏　陈楠　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 张思淼 (51)Int.Cl. G06Q 40/04(2012.01) G06Q 40/06(2012.01) G06F 9/54(2006.01) (54)发明名称 一种基金交易数据的处 理方法及装置 (57)摘要 本申请提供了一种基金交易数据的处理方 法及装置。 其中， 所述基金交易数据的处理方法 可以应用于数据分析系统。 具体地， 在执行本申 请实施例提供的技术方案时， 数据分析系统首先 可以获取多条待分析的基金交易数据。 然后可以 根据多条基金交易数据中每条基金交易数据的 属性信息， 将多条基金交易数据写入Kafka消息 队列。 接着， 可以通过Kafka消息队列建立异步处 理任务， 以便对多条基金交易数据进行异步处 理。 这样， 基于 Kafka消息队列对基金交易数据进 行异步处理， 即使基金交易数据的数据量较大， 也能够及时对基金交易数据进行处理， 提高基金 交易数据的处理效率和准确率。 另外， 基于 Kafka 消息队列对基金交易数据进行处理， 也不依赖外 界存储介质。 权利要求书2页 说明书7页 附图1页 CN 115526723 A 2022.12.27 CN 115526723 A 1.一种基金交易数据的处 理方法， 其特 征在于， 所述方法包括： 获取多条基金交易数据； 根据所述多条基金交易数据中每条基金交易数据的属性信 息， 将多条所述基金交易数 据写入Kafka消息队列； 通过Kfaka消息队列建立异步处 理任务， 以便对所述多条基金交易数据进行异步处 理。 2.根据权利要求1所述的方法， 其特征在于， 所述多条基金交易数据包括第 一基金交易 数据， 所述根据所述多条基金交易数据中每条基金交易数据的属 性信息， 将多条所述基金 交易数据写入Kafka消息队列中包括： 建立所述第一基金交易数据对应的处 理任务； 获取所述第一基金交易数据的指标信息； 根据所述第一基金交易数据的指标信息确定所述第一基金交易数据对应的处 理规则； 根据所述处 理规则， 从所述第一基金交易数据的属性信息中选择 所述处理参数； 基于所述处理参数和所述处理任务， 将所述第一基金交易数据写入所述Kafka消息队 列。 3.根据权利要求2所述的方法， 其特征在于， 所述第 一基金交易数据包括所述第 一基金 交易数据对应的基金机构， 所述第一基金 交易数据的属性信息包括所述第一基金 交易数据 的上级基金机构， 所述方法还 包括： 根据所述第 一基金交易数据对应的基金机构和上下级对应关系， 确定所述第 一基金交 易数据的上级基金机构， 所述上 下级对应关系用于指示基金机构之间的上 下级关系。 4.根据权利要求2所述的方法， 其特征在于， 所述第 一基金交易数据的属性信 息包括以 下任意一项或多 项： 所述第一基金交易数据的基金类型、 所述第一基金交易数据的风险类型、 所述第一基 金交易数据的负责人员类型和所述第一基金交易数据的基金 领域类型。 5.根据权利要求1 ‑4任一项所述的方法， 其特 征在于， 所述方法还 包括： 响应于所述多条基金交易数据的异步处理完成， 或， 响应于达到所述异步处理任务的 结束时间， 停止执 行所述异步处 理任务。 6.一种基金交易数据的处 理装置， 其特 征在于， 所述装置包括： 获取模块， 用于获取多条基金交易数据； 处理模块， 用于根据所述多条基金交易数据中每条基金交易数据的属性信息， 将多条 所述基金交易数据写入Kafka消 息队列； 通过Kfaka消 息队列建立异步处理任务， 以便对所 述多条基金交易数据进行异步处 理。 7.根据权利要求6所述的装置， 其特征在于， 所述多条基金交易数据包括第 一基金交易 数据， 所述处理模块， 具体用于建立所述第一基金交易数据对应的处 理任务； 所述获取模块， 还用于获取 所述第一基金交易数据的指标信息； 所述处理模块， 具体还用于根据所述第 一基金交易数据的指标信 息确定所述第 一基金 交易数据对应的处理规则； 根据所述处理规则， 从所述第一基金交易数据的属 性信息中选 择所述处理参数； 基于所述处理参数和所述处理任务， 将所述第一基金交易数据写入所述 Kafka消息队列。权　利　要　求　书 1/2 页 2 CN 115526723 A 28.根据权利要求6所述的装置， 其特征在于， 所述第 一基金交易数据包括所述第 一基金 交易数据对应的基金机构， 所述第一基金 交易数据的属性信息包括所述第一基金 交易数据 的上级基金机构， 所述处理模块， 还用于根据所述第一基金交易数据对应的基金机构和上下级对应关 系， 确定所述第一基金交易数据的上级基金机构， 所述上下级对应关系用于指示基金机构 之间的上 下级关系。 9.根据权利要求8所述的装置， 其特征在于， 所述第 一基金交易数据的属性信 息包括以 下任意一项或多 项： 所述第一基金交易数据的基金类型、 所述第一基金交易数据的风险类型、 所述第一基 金交易数据的负责人员类型和所述第一基金交易数据的基金 领域类型。 10.根据权利要求6 ‑9任一项所述的装置， 其特 征在于， 所述处理模块， 还用于响应于所述多条基金交易数据的异步处理完成， 和/或， 响应于 达到所述异步处 理任务的结束时间， 停止执 行所述异步处 理任务。权　利　要　求　书 2/2 页 3 CN 115526723 A 3