(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210889928.4 (22)申请日 2022.07.27 (71)申请人 京东城市 （北京） 数字科技有限公司 地址 100086 北京市海淀区知春路76号 （写 字楼） 1号楼 9层1-7-5号 (72)发明人 梁福坤　 (74)专利代理 机构 中原信达知识产权代理有限 责任公司 1 1219 专利代理师 张效荣　王志远 (51)Int.Cl. G06F 16/24(2019.01) G06F 16/25(2019.01) (54)发明名称 一种数据融合方法和装置 (57)摘要 本发明公开了一种数据融合方法和装置， 涉 及计算机技术领域。 该方法的一具体实施方式包 括： 基于选定的算子建立数据融合任务， 并保存 数据融合任务的配置； 将数据融合任务封装为数 据服务， 数据服务的输入参数根据数据融合任务 的配置确定； 响应于调用方对数据服务的调用请 求， 执行数据融合任务以得到数据融合结果， 将 数据融合结果通过数据服务返回至调用方。 该实 施方式能够通过即用即查询的方式发布成新的 服务， 防止保存的数据不能更新或更新滞后， 支 持针对跨库的方式进行数据的联表查询以及对 SQL查询任务编排和结果的规则处理， 实现跨越 数据库、 数据实例、 数据库类型的数据融合。 权利要求书2页 说明书13页 附图8页 CN 115309767 A 2022.11.08 CN 115309767 A 1.一种数据融合方法， 其特 征在于， 包括： 基于选定的算子建立数据融合任务， 并保存所述数据融合任务的配置； 将所述数据融合任务封装为数据服务， 所述数据服务的输入参数根据 所述数据融合任 务的配置确定； 响应于调用方对所述数据服务的调用请求， 执行所述数据融合任务以得到数据融合结 果， 将所述数据融合结果 通过所述数据服 务返回至所述调用方。 2.根据权利要求1所述的方法， 其特征在于， 所述基于选定的算子建立数据融合任务之 前， 包括： 获取数据库链接认证信息； 根据所述数据库链接认证信息配置数据源信息； 将所述数据源信息持久化保存到数据库。 3.根据权利要求2所述的方法， 其特征在于， 所述将所述数据源信 息持久化保存到数据 库之前， 包括： 对所述数据源信息的有效性进行验证， 并确定所述有效性验证通过。 4.根据权利要求1所述的方法， 其特征在于， 所述基于选定的算子建立数据融合任务， 包括： 将所述选 定的算子拖拽到画 布， 并确定 选定的各算子之间的关联关系。 5.根据权利要求1所述的方法， 其特 征在于， 所述保存所述数据融合任务的配置， 包括： 保存对选定的每个算子的配置， 对算子的配置包括对算子的属性、 参数、 依赖以及输出 的配置。 6.根据权利要求5所述的方法， 其特征在于， 对算子的依赖的配置包括： 将所述算子的 输入配置为外 部输入参数或所述 算子的上游算子的输出。 7.根据权利要求5所述的方法， 其特 征在于， 对算子的输出的配置包括： 配置对所述算子的结果数据的处理规则， 所述处理规则包括以下的一种或多种： 过滤 规则、 聚合 规则、 排序规则。 8.根据权利要求7所述的方法， 其特征在于， 所述将所述数据融合任务封装为数据服 务， 包括： 获取保存的所述数据融合任务的配置； 从所述数据融合任务的配置中解析 得到所述数据融合任务的输入参数； 将执行所述数据融合任务得到的数据融合结果通过规则引擎进行数据重组后的数据 发布成应用程序接口服务， 所述数据融合任务的输入参数作为所述应用程序接口服务的入 参。 9.一种数据融合装置， 其特 征在于， 包括： 任务建立模块， 用于基于选定的算子建立数据融合任务， 并保存所述数据融合任务的 配置； 服务封装模块， 用于将所述数据融合任务封装为数据服务， 所述数据服务的输入参数 根据所述数据融合任务的配置确定； 数据融合模块， 用于响应于调用方对所述数据服务的调用请求， 执行所述数据融合任 务以得到数据融合结果， 将所述数据融合结果 通过所述数据服 务返回至所述调用方。权　利　要　求　书 1/2 页 2 CN 115309767 A 210.根据权利要求9所述的装置， 其特 征在于， 还 包括数据源配置模块， 用于： 获取数据库链接认证信息； 根据所述数据库链接认证信息配置数据源信息； 将所述数据源信息持久化保存到数据库。 11.根据权利要求10所述的装置， 其特 征在于， 所述数据源配置模块还用于： 对所述数据源信息的有效性进行验证， 并确定所述有效性验证通过。 12.根据权利要求9所述的装置， 其特 征在于， 所述任务建立模块还用于： 将所述选 定的算子拖拽到画 布， 并确定 选定的各算子之间的关联关系。 13.根据权利要求9所述的装置， 其特 征在于， 所述任务建立模块还用于： 保存对选定的每个算子的配置， 对算子的配置包括对算子的属性、 参数、 依赖以及输出 的配置。 14.根据权利要求13所述的装置， 其特征在于， 对算子的依赖的配置包括： 将所述算子 的输入配置为外 部输入参数或所述 算子的上游算子的输出。 15.根据权利要求13所述的装置， 其特 征在于， 对算子的输出的配置包括： 配置对所述算子的结果数据的处理规则， 所述处理规则包括以下的一种或多种： 过滤 规则、 聚合 规则、 排序规则。 16.根据权利要求15所述的装置， 其特 征在于， 所述 服务封装模块还用于： 获取保存的所述数据融合任务的配置； 从所述数据融合任务的配置中解析 得到所述数据融合任务的输入参数； 将执行所述数据融合任务得到的数据融合结果通过规则引擎进行数据重组后的数据 发布成应用程序接口服务， 所述数据融合任务的输入参数作为所述应用程序接口服务的入 参。 17.一种电子设备， 其特 征在于， 包括： 一个或多个处 理器； 存储器， 用于存 储一个或多个程序， 当所述一个或多个程序被所述一个或多个处理器执行时， 使得所述一个或多个处理器 实现如权利要求1 ‑8中任一所述的方法。 18.一种计算机可读介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序被处 理器执行时实现如权利要求1 ‑8中任一所述的方法。权　利　要　求　书 2/2 页 3 CN 115309767 A 3