CN119415166A 一种业务处理插件的生成方法、装置、设备、介质及产品 （中国建设银行股份有限公司）

本发明公开了一种业务处理插件的生成方基于调度元数据为初始业务处理插件配置目标据输出组件和目标业务调度组件确定用于处理2基于目标业务的业务类型获取所述业务类型对应的初始业对所述目标业务进行分析，得到所述目标业务对应的元数据信息和基于所述数据源元数据和所述处理逻辑为所述初始业务处理插件配置目标数据处理基于所述输出元数据为所述初始业务处理插件配置目标数基于所述调度元数据为所述初始业务处理插件配置目标业根据所述目标数据处理组件、所述目标数据输出组件和所述目标业务调度基于所述数据源元数据为所述初始数据提取组件配置第一组件通过执行所述目标数据提取组件确定出所述目标业务对应的业务基于所述处理逻辑和所述业务宽表数据对所述初始数据处理组件配置第二组件参数，3.根据权利要求2所述的方法，其特征在于，所述第一组件参数包括结构化查询语言基于所述业务主键和预设脚本编辑工具生成所述SQ确定所述处理逻辑对应的至少一个业务字段和所述至少一个业务字段的数据加工任确定所述至少一个业务字段在所述业务宽表数据中为所述初始数据处理组件配置所述映射关系和确定与所述业务主键相关联的业务数据表和所述业务数据通过所述预设脚本编辑工具生成所述SQL查询语句，所述SQL查3对所述原始编制金额、所述上期结转金额和所述调剂金额进行数从所述预算业务对应的业务数据表中统计所述目标预算单元对应的所述预算执行金对所述预算执行金额和所述总预算额度进行数据处理得到所从所述资金集中度业务对应的业务数据表中统计所述目标账户在预设交易时间段内对所述账户余额和所述汇率值进行数据处理得到所述已归集资金、所构建第一业务处理插件，并为所述第一业务处理插为所述第二业务处理插件配置控件属性之后再执基于所述目标输出格式和所述目标存储路径为所述初始数据输出组件配置第三组件基于所述调度策略为所述初始业务调度组件配置第四组件参数，得到所述目根据所述业务处理结果确定所述目标业务的风险等级，所述目4初始插件获取模块，用于基于目标业务的业务类业务数据分析模块，用于对所述目标业务进行分析，得到所述目标第一组件配置模块，用于基于所述数据源元数据和所述处理第二组件配置模块，用于基于所述输出元数据为所述初始业第三组件配置模块，用于基于所述调度元数据为所述被处理器执行时实现如权利要求1至11中任一所述的业务处理插执行时实现如权利要求1至11中任一项所述的业务处5[0001]本发明实施例涉及大数据处理技术领域，尤其涉及一种业务处理插件的生成方[0007]基于所述数据源元数据和所述处理逻辑为所述初始业务处理插件配置目标数据6所述目标业务调度组件确定用于处理所述目标业务的目标业务处程序，该程序被处理器执行时实现如本发明实施例中任一所述的业务处理插件的生成方插件配置目标数据输出组件；基于调度元数据为初始业务处理插件配置目标业务调度组[0027]图5是用来实现本申请实施例的一种业务处理插件的生成方法的电子设备的框7[0030]图1为本申请实施例提供的一种业务处理插件的生成方法的第一流程示意图，本实施例可适用于根据目标业务的元数据信息和处理逻辑动态生成对应的目标业务处理插理特定的某种业务类型的专属模版插件，是一种只包含基础结构但未进行实例化的插件。用于维护插件的数据库中获取与该业务类型相对应的初始业务处理[0035]可选的，本实施例中的初始业务处理插件可以是采用数据集成工具(Pentaho[0038]本实施例中的元数据信息至少可以包括数据源元数据、输出元数据和调度元数8[0041]S130、基于数据源元数据和处理逻辑为初始业务处理插件配置目标数据处理组[0042]本实施例中的初始业务处理插件可以包括初始数据提取组件和初始数据处理组TableInput组件基于数据源元数据为初始数据提取组件配置第一组件参数，即对初始数通过UserDefinedJavaExpression或Calculator组件基于处理逻辑和业务宽表数据对[0046]具体的，微处理器基于输出元数据为初始业务处理插件出格式和目标存储路径；再通过TableOutput或FileOutput组件基于目标输出格式和目[0049]具体的，微处理器基于调度元数据为初始业务处理插件9度策略为初始业务调度组件配置第四组件参数，即对初始业务调度组件进行实例化操作，任务；其中，定时调度子任务是通过Cron(Linux)或TaskScheduler(Windows)定时触发处理目标业务的目标业务处理插件。本申请通过对目标业务的数据处理需求分析，在[0054]下面进一步描述本申请实施例提供的业务处理插件的生成方法，图2为本申请实[0057]本实施例中的业务主键为目标业务的最关键或最核心的数据表的标识号标数据提取组件用于从与目标业务相关的业务数据表中提取关键字段对应[0067]本实施例中的处理逻辑是指对目标业务进行数据加[0072]在本申请实施例中，微处理器通过TableInput组件为初始数据处理组件配置映数据处理组件。本申请通过对目标业务的数据处理需求分析得到数据源元数据和处理逻有技术中数据处理流程通常需要人工编写复杂的数据加工脚本造成的耗时耗力且容易出[0079]下面进一步描述本申请实施例提供的业务处理插件的生成方法，图3为本申请实将SQL查询语句存储到Kettle的BUDGET_SQL变量中。还需要在第一业务处理插件中嵌入对中都能正常运行。初始业务处理插件实现逻辑通常依赖于Kettle的插件接口(如置控件属性之后再执行编译操作，得到初始业务处理插件；将初始业务处理插件部署至以便后续根据具体的目标业务对初始业务处理插件进行动态配置得到用于处理目标业务数据处理流程通常需要人工编写复杂的数据加工脚本造成的耗时耗力且容易出现错误的[0093]初始插件获取模块410，用于基于目标业务的业务类型获取所述业务类型对应的[0095]第一组件配置模块430，用于基于所述数据源元数据和所述处理逻辑为所述初始[0096]第二组件配置模块440，用于基于所述输出元数据为所述初始业务处理插件配置[0097]第三组件配置模块450，用于基于所述调度元数据为所述初始业务处理插件配置和所述目标业务调度组件确定用于处理所述目标业务的确定所述目标业务的业务主键；基于所述业务主键和预设脚本编辑工具生成所述SQL查询述SQL查询语句，所述SQL查询语句用于从所述业务数据表中提取所述关键字段对应的键述目标业务制定调度策略；基于所述调度策略为所述初始业务调度组件配置第四组件参务的业务类型获取所述业务类型对应的目标业务处理插件；运行所述目标业务处理插件，得到所述目标业务的业务处理结果；根据所述业务处理结果确定所述目标业务的风险等[0116]本实施例提供的业务处理插件的生成装置可适用于上述任意实施例提供的业务[0117]图5是用来实现本申请实施例的一种业务处理插件的生成方法的电子设备的框至少一个处理器执行的计算机程序，处理器11可以根据存储在只读存储器(ROM)12中的计算机程序或者从存储单元18加载到随机访问存储器(RAM)13中的计算机程序，来执行各种如因特网的计算机网络和/或各种电信网络与其他设[0120]处理器11可以是各种具有处理和计算能力的通用和/或专用处理组件。处理器11机程序可在包括至少一个可编程处理器的可编程系统上执行和/或解释，该可编程处理器[0123]用于实施本申请的方法的计算机程序可以采用一个或多个编程语言的任何组合机器上执行且部分地在远程机器上执行或完全在远程机器或服务服务器)或者包括中间件部件的计算系统(例如，应用或者该网络浏览器来与此处描述的系统和技术的实施方式交互)或者包括这种后台部件、通信网络进行交互。通过在相应的计算机上运行并且彼此具有客户端_服务器关系的计算被处理器执行时实现如本申请任一实施例所提供的业务处理插写用于执行本发明操作的计算机