(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211085693.X (22)申请日 2022.09.06 (71)申请人 中国建设银行股份有限公司 地址 100033 北京市西城区金融大街25号 申请人 建信金融科技有限责任公司 (72)发明人 蒋松　 (74)专利代理 机构 北京同立钧成知识产权代理 有限公司 1 1205 专利代理师 张芳　臧建明 (51)Int.Cl. G06F 16/2455(2019.01) G06F 16/901(2019.01) G06F 8/41(2018.01) (54)发明名称 数据处理方法、 装置、 电子设备、 介质及产品 (57)摘要 本申请提供一种数据处理方法、 装置、 电子 设备、 介质及产品， 涉及数据处理领域。 包括： 根 据用户定义的业务规则以及源数据， 生成规则模 型文件； 规则模 型文件定义有多个模 型节点以及 多个计算引擎； 针对多个模型节点， 生成有向无 环图， 并根据规则模型文件， 解析出多个模型节 点对应的规则代码； 遍历 有向无环图中的多个模 型节点， 并针对当前遍历 的模型节点， 基于模型 节点对应的源 数据， 调用模型节 点对应的计算引 擎执行模型节 点对应的规则代码， 直至遍历完所 有模型节 点， 得到数据处理结果。 以上方案， 通过 有向无环图对模 型节点统一管 理， 每个节点有对 应的计算引擎， 多个模型节点可以同时进行数据 处理， 从而提高数据处 理效率。 权利要求书3页 说明书13页 附图5页 CN 115357626 A 2022.11.18 CN 115357626 A 1.一种数据处 理方法， 其特 征在于， 包括： 根据用户定义的业务规则以及源数据， 生成规则模型文件； 所述规则模型文件定义有 多个模型节点以及多个 计算引擎； 针对所述多个模型节点， 生成有向无环图， 并根据 所述规则模型文件， 解析出所述多个 模型节点对应的规则代码； 遍历所述有向无环图中的所述多个模型节点， 并针对当前遍历的模型节点， 基于所述 模型节点对应的源数据， 调用所述模型节点对应的计算引擎执行所述模型节点对应的规则 代码， 直至遍历完所有模型节点， 得到数据处 理结果。 2.根据权利要求1所述的方法， 其特征在于， 所述规则模型文件包括有向无环图依赖定 义； 所述针对所述多个模型节点， 生成有向无环图， 包括： 根据所述业务规则中的所述有向无环图依赖定义， 生成所述多个模型节点的有向无环 图； 其中， 所述有向无环图依赖定义用于定义所述多个模型节点之间的依赖关系和依赖类 型， 所述依赖类型包括继续执 行和结束执 行。 3.根据权利要求1所述的方法， 其特征在于， 所述规则模型文件包括模型节点的模型节 点定义， 所述模型节 点的模型节点定义包括用于定义所述模型节点的节点类型的第一字段 和用于定义所述模型节点对应的规则代码的第二字段； 所述根据所述规则模型文件， 解析 出所述多个模型节点对应的规则代码， 包括： 根据所述业务规则中所述模型节点定义中的第一字段， 确定每个模型节点的节点类 型； 若所述模型节点的节点类型为结构化查询语言类型， 则对所述模型节点对应的所述第 二字段中结构化查询语言格式的内置函数代码进 行解析， 获得所述模型节点对应的规则代 码； 若所述模型节点的节点类型为自定义类型， 则读取所述第 二字段中用户自定义的非结 构化查询语言格式的代码， 获得 所述模型节点对应的规则代码。 4.根据权利要求3所述的方法， 其特征在于， 所述规则模型文件还包括用户自定义函数 定义， 所述用户自定义函数定义用于定义用户自定义的结构化查询语言格式的非 内置函数 代码； 所述若所述模型节点的节点类型为结构化查询 语言类型， 则对所述模型节点对应的 所述第二字段中结构化 查询语言格式的内置函数代码进行解析， 包括： 若所述模型节点的节点类型为结构化查询语言类型， 且所述模型节点对应的所述用户 自定义函数定义为空值， 则对所述模型节点对应的所述第二字段中结构化查询语言格式的 内置函数代码进行解析。 5.根据权利要求 4所述的方法， 其特 征在于， 所述方法还 包括： 若所述模型节点的节点类型为结构化查询语言类型， 且所述模型节点对应的所述用户 自定义函数定义不为空值， 则根据所述用户自定义函数定义生成用户自定义函数； 并从所 述用户自定义 函数中解析 出代码合并至所述 规则代码。 6.根据权利要求2所述的方法， 其特征在于， 所述遍历所述有向无环图中的所述多个模 型节点， 包括： 按照模型节点入度由小至大的顺序， 将所述有向无环图中每个入度下的模型节点作为 当前遍历的模型节点。权　利　要　求　书 1/3 页 2 CN 115357626 A 27.根据权利要求1所述的方法， 其特征在于， 所述规则模型文件包括计算引擎定义； 所 述针对当前遍历的模型节点， 基于所述模型节点对应的源数据， 调用所述模型节点对应的 计算引擎执 行所述模型节点对应的规则代码， 包括： 根据当前遍历的模型节点对应的计算引擎定义， 确定所述模型节点对应的计算引擎； 其中， 所述计算引擎定义包含用户为模型节点指定的计算引擎， 所述计算引擎包括大数据 引擎和/或数据库引擎； 基于所述模型节点对应的源数据， 调用所述模型节点对应的计算引擎执行所述模型节 点对应的规则代码。 8.根据权利要求1 ‑7中任一项所述的方法， 其特征在于， 所述规则模型文件包括分布式 锁定义； 所述方法还 包括： 根据当前遍历的模型节点对应的分布式锁定义， 确定所述模型节点对应的目标分布式 锁； 其中， 所述分布式锁定义包 含用户为模型节点指定的分布式锁； 通过所述目标分布式锁锁定当前遍历的模型节点对应的源数据， 直至所述模型节点对 应的计算引擎执 行完成所述模型节点对应的规则代码。 9.一种数据处 理装置， 其特 征在于， 包括： 生成模块， 用于根据用户定义的业务规则以及源数据， 生成规则模型文件； 所述规则模 型文件定义有 多个模型节点以及多个 计算引擎； 解析模块， 用于针对所述多个模型节点， 生成有向无环图， 并根据所述规则模型文件， 解析出所述多个模型节点对应的规则代码； 处理模块， 用于遍历所述有向无环图中的所述多个模型节点， 并针对当前遍历的模型 节点， 基于所述模型节点对应的源数据， 调用所述模型节点对应的计算引擎执行所述模型 节点对应的规则代码， 直至遍历完所有模型节点， 得到数据处 理结果。 10.根据权利要求9所述的装置， 其特征在于， 所述规则模型文件包括有向无环图依赖 定义； 所述解析模块， 具体用于根据所述业务规则中的所述有向无环图依赖定义， 生成所述 多个模型节点的有向无环图； 其中， 所述有向无环图依赖定义用于定义所述多个模型节点 之间的依赖关系和依赖类型， 所述依赖类型包括继续执 行和结束执 行。 11.根据权利要求9所述的装置， 其特征在于， 所述规则模型文件包括模型节点的模型 节点定义， 所述模型节点的模型节点定义包括用于定义所述模型节点的节点类型的第一字 段和用于 定义所述模型节点对应的规则代码的第二字段； 所述解析模块， 具体用于根据所述业务规则中所述模型节点定义中的第一字段， 确定 每个模型节点的节点类型； 所述解析模块， 具体还用于若所述模型节点的节点类型为结构化查询语言类型， 则对 所述模型节点对应的所述第二字段中结构化查询语言格式的内置函数代码进 行解析， 获得 所述模型节点对应的规则代码； 所述解析模块， 具体还用于若所述模型节点的节点类型为自定义类型， 则读取所述第 二字段中用户自定义的非结构化查询语言格式的代码， 获得所述模型节点对应的规则代 码。 12.根据权利要求11所述的装置， 其特征在于， 所述规则模型文件还包括用户自定义函权　利　要　求　书 2/3 页 3 CN 115357626 A 3