(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211059808.8 (22)申请日 2022.08.31 (71)申请人 中国建设银行股份有限公司 地址 100033 北京市西城区金融大街25号 申请人 建信金融科技有限责任公司 (72)发明人 韦东杰　贾国琛　靳国栋　田媛　 张汉至　 (74)专利代理 机构 中科专利商标代理有限责任 公司 11021 专利代理师 周天宇 (51)Int.Cl. G06F 16/2455(2019.01) G06F 16/2458(2019.01) G06F 16/2457(2019.01) G06F 16/28(2019.01)G06F 16/25(2019.01) G06Q 40/02(2012.01) (54)发明名称 数据流松耦合统计方法、 装置、 设备、 介质和 程序产品 (57)摘要 本公开实施例提供了一种数据流松耦合统 计方法， 涉及金融科技及大数据领域， 方法包括： 获取业务数据流， 业务数据流为多种类型业务的 实时数据总和； 从业务数据流中的提取基础数据 和各类型业务的实时业务数据， 基础数据包括存 在依赖关系的业务之间的关联数据； 将基础数据 补充至各个类型业务的实时业务数据中， 得到各 类型业务的松耦合业务数据； 将各类型业务的松 耦合业务数据分别存入分布式部署的消息队列 中执行分类统计。 本公开还提供了一种数据流松 耦合统计装置、 设备、 存 储介质和程序 产品。 权利要求书2页 说明书9页 附图5页 CN 115391407 A 2022.11.25 CN 115391407 A 1.一种数据流松耦合统计方法， 其特 征在于， 所述方法包括： 获取业务数据流， 所述 业务数据流 为多种类型业 务的实时数据总和； 从所述业务数据流中的提取基础数据和各类型业务的实时业务数据， 所述基础数据包 括存在依赖关系的业 务之间的关联 数据； 将所述基础数据补充至各个类型业务的实时业务数据中， 得到各类型业务的松耦合业 务数据； 将各类型业 务的松耦合 业务数据分别存 入分布式部署的消息队列中执 行分类统计。 2.根据权利要求1所述的方法， 其特征在于， 所述从所述业务数据流中的提取基础数据 和各类型业 务的实时业 务数据包括： 基于预设的复制命令将所述 业务数据流复制为第一 业务数据流和第二 业务数据流； 基于预设的基础 关键字过滤所述第 一业务数据流， 从所述业务数据流中筛选出所述基 础关键字对应的基础数据； 根据业务类型将所述第二 业务数据流分类， 得到各个 类型业务的实时业 务数据。 3.根据权利要求2所述的方法， 其特征在于， 所述基于预设的基础 关键字过滤所述第 一 业务数据流， 得到所述基础数据还 包括： 以所述基础关键字和所述基础数据值构建基础数据键值对， 存入Redis数据结构的基 础数据检索库。 4.根据权利要求3所述的方法， 其特征在于， 所述将所述基础数据补充至各个类型业务 的实时业 务数据中， 得到各类型业 务的松耦合 业务数据包括： 基于业务之间的依赖关系获取 各类型业 务所依赖的基础数据的基础关键 字； 调用所述基础数据检索库， 获取与所述基础关键 字对应的基础数据； 将所述基础数据补充至依赖所述基础数据的业务的实时业务数据中， 得到所述松耦合 业务数据。 5.根据权利要求1所述的方法， 其特征在于， 所述将各类型业务的松耦合业务数据分别 存入分布式部署的消息队列中执 行分类统计包括： 采用分布式的准实时计算引 擎从分布式部署的消息队列中读取各类型业务的松耦合 业务数据， 分别统计各类型业 务的松耦合 业务数据； 将统计后的各类型业务的松耦合业务数据汇总， 得到所述业务数据流的松耦合统计数 据。 6.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 设置Redis服务器集群， 所述Redis服务器集群包括1个主Redis服务器组和多个从 Redis服务器组， 所述主Redis服务器组用于执行所述数据流松耦合统计方法， 所述从Redis 服务器组用于实时备份对主Redis服 务器上产生的数据； 监控所述Redis服 务器集群的运行状态； 当所述主Redis服务器组运行故障时， 将多个从Redis服务器组中的其中一个升级为 Redis服务器。 7.一种数据流松耦合统计装置， 包括： 数据流获取模块， 用于获取业务数据流， 所述业务数据流为多种类型业务的实时数据 总和；权　利　要　求　书 1/2 页 2 CN 115391407 A 2数据提取模块， 用于从所述业务数据流中的提取基础数据和各类型业务的实时业务数 据， 所述基础数据包括存在依赖关系的业 务之间的关联 数据； 数据补全模块， 用于将所述基础数据补充至各个类型业务的实时业务数据中， 得到各 类型业务的松耦合 业务数据； 分布式统计模块， 用于将各类型业务的松耦合业务数据分别存入分布式部署的消息队 列中执行分类统计。 8.一种电子设备， 包括： 一个或多个处 理器； 存储装置， 用于存 储一个或多个程序， 其中， 当所述一个或多个程序被所述一个或多个处理器执行时， 使得所述一个或多个 处理器执行根据权利要求1～6中任一项所述的方法。 9.一种计算机可读存储介质， 其上存储有可执行指令， 该指令被处理器执行时使处理 器执行根据权利要求1～6中任一项所述的方法。 10.一种计算机程序产品， 包括计算机程序， 所述计算机程序被处理器执行时实现根据 权利要求1～6中任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 115391407 A 3