(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210897908.1 (22)申请日 2022.07.28 (71)申请人 浪潮软件科技有限公司 地址 250100 山东省济南市高新区浪潮路 1036号浪潮科技园 (72)发明人 王猛　李蒙　王可　胡超　李凯　 (74)专利代理 机构 济南信达专利事务所有限公 司 37100 专利代理师 姜鹏 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/22(2019.01) G06F 16/28(2019.01) G06F 16/2455(2019.01) G06F 16/25(2019.01)G06F 8/34(2018.01) G06F 16/901(2019.01) (54)发明名称 一种有向无环图转换成执行流程的方法及 系统 (57)摘要 本发明公开了一种有向无环图转换成执行 流程的方法及系统， 属于计算机应用领域； 所述 的方法具体步骤如下： S1基于B/S构架构建可视 化流程； S2采用前后端分离方式进行应用搭建； 本发明方法灵活运用Web相关技术， 通过在前端 图编辑器上定义具有指定意义的节 点、 编排节点 执行过程和自定义流程解析规则， 在后端实现按 流程规则执行数据读取分发工作， 能够实现异构 数据的读取与同步， 进而提高实施人员同步异构 数据的效率。 权利要求书2页 说明书5页 附图1页 CN 115269727 A 2022.11.01 CN 115269727 A 1.一种有向无环图转换成执 行流程的方法， 其特 征是所述的方法具体步骤如下： S1基于B/S 构架构建可视化 流程： S11在MySQL数据库中创建节点信息存 储表， 即以MySQ L数据库作为存储介质； S12以springboot框架作为逻辑处理框架， mybatis ‑plus+durid连接池作为持久层框 架， 为前台图编辑器中创建的流 程图信息提供流 程转化服务和信息持久化 服务； S13创建可用的图编辑器， 用于支撑用户根据需求创建可视化 流程； S2采用前后端分离方式进行应用搭建： S21后端以flinkx+flink作为数据流程执行引擎， 采用springcloud+springboot+ mybatis‑plus+druid连接池， 为前端提供API 服务； S22前端为Vue项目， 深度集成ElementUI、 AntvX6， 通过axios跨域请求springboot提供 的后台API 服务； S23用户访问前端页面， 通过axios跨域请求访问后台API服务， 获取流程信息， 根据用 户指令编辑并执 行数据分发流 程； S24数据流 程执行解析。 2.根据权利要求1所述的方法， 其特征是所述S1中节点具体包括数据读取节点、 数据通 道节点和数据写入节点： 数据读取节点： 根据增量字段读取指定数据源中的指定信息表， 并为该节点进行命名 和描述； 数据通道节点： 数据传输通道， 在复杂网络环境中， 允许读取的同一数据源通过不同数 据通道传输 至不同目标库； 数据写入节点： 通过不同传输通道传入的数据写入指定目标数据源； 支持多个通道并 行执行数据流程。 3.根据权利要求2所述的方法， 其特征是所述S11在MySQL数据库中创建节点信息存储 表， 即以MySQL数据库作为存储介质： 指定特定数据源类型为数据源头和数据目标源， 过设 定数据源参数、 数据目标源参数、 数据传输通道 参数满足数据读取分发写入需求， 具体规则 步骤如下： S111创建一个任务信息； S112根据流程生成原则， 对流程图解析， 获取数据写入节点作为结束节点， 并通过递归 解析方式， 逐级向上获取到该流程的所有节点， 每个有序节 点集合作为一个作业， 一个任务 包含一个或多个作业； S113根据数据读取节点数据源类型 结合flinkx生成自适应数据读取规则； S114根据数据写入节点数据源类型 结合flinkx生成自适应数据写入规则； S115解析每个作业， 根据通道配置信息， 借助flinkx将生成的可解析的json文件提交 到对应数据服 务引擎上 执行。 4.根据权利要求3所述的方法， 其特征是所述数据读取节点通过集成Flinkx提供的数 据源读取规则， 实现MySQL、 Oracle、 Postgresql的读取支持， 允许对flinkx支持的其他数据 源类型进行自定义扩展。 5.根据权利要求4所述的方法， 其特征是所述是数据流程执行过程服务引擎， 本组件引 入flink作为数据加工引擎， 负责数据加载、 写入等处理过程， 一个flink引擎服务支持多个权　利　要　求　书 1/2 页 2 CN 115269727 A 2任务并行 执行。 6.根据权利要求5所述的方法， 其特征是所述数据写入节点通过集成Flinkx提供的数 据源写入规则， 实现MySQL、 Oracle、 Postgresql的写入支持， 允许对flinkx支持其他数据源 类型进行自定义扩展。 7.根据权利要求6所述的方法， 其特征是所述S24数据流程执行解析： 根据流程创建时 生成的节点信息， 按照有序组件、 无需组件处理逻辑重新组装解析流程， 并根据不同节点进 行特定处理。 8.一种有向无环图转换成执行流程的系统， 其特征是所述的系统具体包括流程构建模 块和应用搭建模块： 利用流程构建模块基于B/S 构架构建可视化 流程， 所述流程构建模块具体包括： 节点存储模块： 在MySQL数据库中创建节点信息存储表， 即以MySQL数据库作为存储介 质； 流程处理模块： 以springboot框架作为逻辑处理框架， mybatis ‑plus+durid连接池作 为持久层框架， 为前台图编辑器中创建的流程图信息提供流程转化服务和信息持久化服 务； 编辑模块： 创建可用的图编辑器， 用于支撑用户根据需求创建可视化 流程； 利用应用搭建模块采用前后端分离方式进行应用搭建， 所述应用搭建模块具体包括： 后端搭建模块： 后端以flinkx+flink作为数据流程执行引擎， 采用springcloud+ springboot+mybatis ‑plus+druid连接池， 为前端提供API 服务； 前端搭建模块： 前端为Vue项目， 深度集成ElementUI、 AntvX6， 通过axios跨域请求 springboot提供的后台API 服务； 流程交互模块： 用户访问前端页 面， 通过axios跨域请求访问后台API服务， 获取流程信 息， 根据用户指令编辑并执 行数据分发流 程； 流程执行模块： 数据流 程执行解析。权　利　要　求　书 2/2 页 3 CN 115269727 A 3