CN111831191B 工作流配置方法、装置、计算机设备和存储介质 （平安证券股份有限公司）

关系通过分布式消息中间件将实体节点进行连2接收终端发送的配置数据包；所述配置数据包在检测到配置完从所述配置数据包中提取每个组件对应的组件标识，针对每根据所述组件对应的组件参数模板中的组件参数标识，从所述按照所述组件关系通过分布式消息中间件将相应实体节点进行连接，得到将所述工作流提交至分布式数据处理引擎，根据所述配置文件中每个组件的组件参根据所述配置文件确定每个组件对应的初始将所述每个组件对应的程序逻辑包按照相应组件参数进行实4.根据权利要求1至3任意一项所述的方法，其特征在于所述分布式数据处理引擎在运行所述工作流的过程中，动态监控所所述分布式数据处理引擎按照所述新增实体节点数量与相应的组件参数所述分布式数据处理引擎在运行所述工作流的过程中，动态监控所3接收模块，用于接收终端发送的配置数据包；所述配置数据包生成模块，用于从所述配置数据包中提取每个组实例化模块，用于将所述程序逻辑包按照相应组件参数配置模块，用于按照所述组件关系通过分布式消息中间件将相应实体节点进行连接，提交模块，用于将所述工作流提交至分布式数据处理引擎，根据所述9.一种计算机设备，包括存储器和处理器，所述存储器存被处理器执行时实现权利要求1至5中任一项所述的45[0026]根据所述终端针对所发送的配置数据包反馈的调整数据包，动态调整相应工作6务器104根据所接收到的配置数据包生成包括每个组件对应的组件标识与组件参数，以及所查询到的程序逻辑包按照相应的组件参数进行实例化，得到相应组件所对应的实体节[0052]步骤202，接收终端发送的配置数据包；配置数据包在检测到配置完成触发操作7[0062]在一个实施例中，服务器根据所接收到的配置数据包生成预设格式的配置文8预配置的逻辑节点库中查询每个组件标识对应务器本地的，以便于服务器基于由终端生成并发送的配置数据包确定组成工作流的组件9件包括但不限于是ActiveMQ(一种开放源代码的消息中间件)、RabbitMQ(一种面向消息的中间件)与Kafka(一种高吞吐量的分布式发参数模板与相应组件标识对应存储在本地。服务器根据从配置数据包中提取出的组件标这样，运行实体节点的过程即是调用已赋予组件参数相应物理含义的程序逻辑包的过程，组件的输入接口与输出接口各自对应的分布式消息中间件；将每个组件对应的实体节点，应的各个实体节点通过分布式消息中间件X2与组件3对应的各个实体节点进行连接，得到后一个组件对应的实体节点从该分布式消息中间件中读取所缓存的数据并进行处理，由[0106]在一个实施例中，服务器根据所确定的工作流标识在本于或等于预设负载阈值时，分布式数据处理引擎确定相应组件所对应的新增实体节点数态确定该实体节点对应的组件所对应的新增实体节点数量，将该组件对应的程序逻辑包，[0124]步骤302，接收终端发送的配置数据包；配置数据包在检测到配置完成触发操作是可以与其它步骤或者其它步骤中的步骤或者阶段的至少一部分轮流或[0141]配置模块405，用于按照组件关系通过分布式消息中间件将相应实体节点进行连机程序被处理器执行时实现上述各个方法实施例中非易失性和易失性存储器中的至少一种。非易失性存储器可包括只读存储器(Read-OnlyMemory，ROM)、磁带、软盘、闪存或光存储器等。易失性存储器可包括随机存取存储器