(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211302898.9 (22)申请日 2022.10.24 (71)申请人 中国农业银行股份有限公司 地址 100005 北京市东城区建国门内大街 69号 (72)发明人 宋琪　 (74)专利代理 机构 北京品源专利代理有限公司 11332 专利代理师 严慧 (51)Int.Cl. G06F 16/2455(2019.01) G06F 16/2458(2019.01) (54)发明名称 一种数据处 理方法、 装置、 设备及 介质 (57)摘要 本发明公开了一种数据处理方法、 装置、 设 备及介质。 其中， 方法包括： 获取多个业务数据集 合， 对各业务数据集合中的业务数据进行序列化 处理， 得到对应的数据流； 通过流数据处理引擎， 确定与各数据流关联的其他数据流， 对各数据 流、 以及与各数据流关联的其他数据流进行合并 处理， 得到至少两个基础关联数据流； 将各基础 关联数据流缓存至预设数据库中； 通过流数据处 理引擎， 确定与各基础关联数据流关联的其他基 础关联数据流， 进行合并处理， 得到至少一个目 标关联数据流； 将各目标关联数据流提供给目标 用户。 本发 明实施例可以对不同来源的业务数据 构成的大量的不同的数据流进行整合， 便于用户 快速地对业 务数据进行查看与分析。 权利要求书2页 说明书9页 附图3页 CN 115455060 A 2022.12.09 CN 115455060 A 1.一种数据处 理方法， 其特 征在于， 包括： 获取多个业务数据集合， 对各所述业务数据集合中的业务数据进行序列化处理， 得到 与各所述业务数据集 合对应的数据流； 通过流数据处理引擎， 根据各所述数据流对应的时间区间， 确定与各所述数据流关联 的其他数据流， 对各所述数据流、 以及与各所述数据流关联的其他数据流进行合并处理， 得 到至少两个 基础关联 数据流； 将各所述基础关联 数据流缓存至预设数据库中； 通过所述流数据处理引擎， 根据各预设时间窗口， 确定与各所述基础关联数据流关联 的其他基础关联数据流， 对各所述基础关联数据流、 以及与各所述基础关联数据流关联 的 其他基础关联 数据流进行合并处 理， 得到至少一个目标关联 数据流； 将各所述目标关联 数据流提供给目标用户。 2.根据权利要求1所述的方法， 其特征在于， 所述对各所述业务数据集合中的业务数据 进行序列化处 理， 得到与各 所述业务数据集 合对应的数据流， 包括： 针对每一个业 务数据集 合执行下述操作： 根据业务数据的业务 时间从前到后的顺序， 对当前处理 的业务数据集合中的各业务数 据进行排序， 得到业 务数据序列； 将所述业务数据序列确定为所述当前处 理的业务数据集 合对应的数据流。 3.根据权利要求1所述的方法， 其特征在于， 所述通过流数据处理引擎， 根据各所述数 据流对应的时间区间， 确定与各 所述数据流关联的其 他数据流， 包括： 通过流数据处理引擎， 对各所述数据流对应的时间区间进行比对， 将各所述数据流中 的时间区间相同的至少两个数据流确定为关联的数据流。 4.根据权利要求1所述的方法， 其特征在于， 所述对各所述数据流、 以及与各所述数据 流关联的其 他数据流进行合并处 理， 得到至少两个 基础关联 数据流， 包括： 通过所述流数据处 理引擎， 针对每一个数据流执 行下述操作： 将当前处理的数据流、 以及与所述当前处理的数据流关联的其他数据流进行合并处 理， 得到一个 基础关联 数据流。 5.根据权利要求1所述的方法， 其特征在于， 所述通过所述流数据处理引擎， 根据各预 设时间窗口， 确定与各 所述基础关联 数据流关联的其 他基础关联 数据流， 包括： 通过所述流数据处理引擎， 根据各所述基础关联数据流对应的时间区间， 确定各所述 基础关联数据流对应的预设时间窗口， 将对应同一个预设时间窗口的至少两个基础关联数 据流确定为关联的基础关联 数据流。 6.根据权利要求1所述的方法， 其特征在于， 所述对各所述基础关联数据流、 以及与各 所述基础关联数据流关联的其他基础关联数据流进行合并处理， 得到至少一个目标关联数 据流， 包括： 通过所述流数据处 理引擎， 针对每一个 基础关联 数据流执 行下述操作： 将当前处理的基础 关联数据流、 以及与 所述当前处理的基础 关联数据流关联的其他基 础关联数据流进行合并处 理， 得到一个目标关联 数据流。 7.根据权利要求1所述的方法， 其特征在于， 所述将各所述目标关联数据流提供给目标 用户， 包括：权　利　要　求　书 1/2 页 2 CN 115455060 A 2将各所述目标关联 数据流发送至目标用户的终端设备。 8.一种数据处 理装置， 其特 征在于， 包括： 数据集合获取模块， 用于获取多个业务数据集合， 对各所述业务数据集合中的业务数 据进行序列化处 理， 得到与各 所述业务数据集 合对应的数据流； 第一处理模块， 用于通过流数据处理引擎， 根据 各所述数据流对应的时间区间， 确定与 各所述数据流关联的其他数据流， 对各所述数据流、 以及与各所述数据流关联的其他数据 流进行合并处 理， 得到至少两个 基础关联 数据流； 数据流缓存 模块， 用于将各 所述基础关联 数据流缓存至预设数据库中； 第二处理模块， 用于通过所述流数据处理引擎， 根据各预设时间窗口， 确定与各所述基 础关联数据流关联的其他基础关联数据流， 对各所述基础关联数据流、 以及与各所述基础 关联数据流关联的其 他基础关联 数据流进行合并处 理， 得到至少一个目标关联 数据流； 数据流提供模块， 用于将各 所述目标关联 数据流提供给目标用户。 9.一种电子设备， 其特 征在于， 所述电子设备包括： 至少一个处 理器； 以及与所述至少一个处 理器通信连接的存 储器； 其中， 所述存储器存储有可被所述至少一个处理器执行的计算机程序， 所述计算机程 序被所述至少一个处理器执行， 以使所述至少一个处理器能够执行权利要求1 ‑7中任一项 所述的数据处 理方法。 10.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储有计算机指 令， 所述计算机指令用于使处 理器执行时实现权利要求1 ‑7中任一项所述的数据处 理方法。权　利　要　求　书 2/2 页 3 CN 115455060 A 3