文档首页 / 流程任务:DAG 画布编排

流程任务:DAG 画布编排

在画布上用节点和连线编排批处理流程:触发方式、节点分组、发布到生产、调度、补数与调试能力。

概述

流程任务适合多步骤编排:查库 → 同步 → 调接口 → 写库 → 通知。固定流向的表同步优先用 管道任务,秒级持续同步用 实时任务。

权限与入口:task:view 查看;task:edit 新建 / 编辑 / 发布 / 运行;task:script 使用脚本节点。菜单:数据集成 → 流程任务

流程任务是在画布上用节点和连线编排的批处理流程,可按 cron 或一次性时间调度,也可由事件、接口调用触发。

流程任务列表

图:流程任务列表

图中编号说明:

  1. 新建任务。
  2. 所属目录树:按目录筛选任务。
  3. 状态:草稿 / 待发布 / 运行中 / 运行成功 / 运行失败 / 已暂停 / 等待中;名称后的「开发」标签表示当前是开发草稿,尚未发布到生产。
  4. 操作:行首是运行 / 停止执行与查看运行记录,「…」里是更多操作。

新建任务

点「新建任务」,填写任务名称、触发方式(定时 / 手动 / 事件 / 接口调用)、模板和所属目录,创建后直接进入画布。触发方式只是起步引导,之后可以随时叠加其他触发。选择「接口调用触发」时,任务自动设为轻量档位,只允许 HTTP、应用动作、SQL 脚本、参数赋值、条件等短节点,用于被数据服务(流程服务)同步调用(见 流程服务:把任务变成接口)。

在画布上编排

流程任务画布编辑器

图:画布编辑器

图中编号说明:

  1. 节点面板:可搜索,按分组列出所有节点,点击或拖到画布上添加。
  2. 画布上的节点:节点上的小红点表示这个节点还有必填项没配;运行后节点上会显示运行状态。
  3. 连线:标签是触发条件(成功后 / 失败后);悬停连线可在中间插入节点。
  4. 配置面板:点击节点后,这里显示它的属性;点连线则改流转条件。
节点分组 包含的节点
数据处理 数据同步、数据转换、查询 / 新增 / 修改 / 删除数据、MongoDB 操作、SQL 脚本、参数赋值(含「计算」)、格式转换、文件传输
应用连接器 企业微信、简道云、钉钉、SOAP、RabbitMQ、邮件、MQTT、Redis 等应用动作
取数与输入 数据文件取数、接口取数、Kafka 输入
逻辑控制 条件判断、分支选择、循环、延时、等待事件
流程操作 调用任务、调用检测、运行间状态、停止并报错、结束流程
扩展功能 HTTP 请求、消息通知、Kafka 输出、JS 脚本、Python、Shell
其他 便签

风险:Shell、Python、JS 脚本节点能在服务器上执行代码,默认关闭;只有部署时显式开启,并且账号拥有 task:script 时才可使用。请只授予完全可信的人。

画布常用快捷键:Ctrl+Z 撤销、Ctrl+Y 重做、Ctrl+C / V 复制粘贴节点(连同它们之间的连线)、Ctrl+A 全选、Ctrl+S 保存、Delete 删除、Shift+点击多选、Shift+拖拽框选、方向键微调位置、拖动时按住 Alt 临时关闭对齐吸附。从节点端口拖到空白处松手,可直接新建并连上下游节点;在空白处右键有常用节点的快捷添加。

发布、调度与运行

  1. 保存画布:保存的是「开发」草稿。底部状态栏会提示节点数、连线数和「n 个节点有问题」,修完再发布。
  2. 发布到生产:任务行「…」里点「发布到生产」。发布后生成不可变的生产快照;之后再改画布会出现「有待发布改动」,需要再次发布才会生效。「生产版本」里可以查看历史版本与只读快照。
  3. 设置触发:在「…」里选「调度计划」(cron 或一次性时间)、「事件触发」(订阅事件入口);接口调用触发通过数据服务绑定。不设置调度也可以手动或由接口触发。
  4. 运行:点行首播放按钮立即运行;「带参数运行 / 补数」可传入运行参数或补一段历史;「运行时限」限制单次最长时间;「停止全部运行」用于紧急停止。
  5. 看结果:「查看运行记录」打开抽屉;点「日志」进入逐行运行日志(运行记录与运行日志),失败时先看错误级别的日志与失败节点。

其他实用能力:节点禁用(右键菜单或配置面板里可以一键禁用选中节点及其所有下游,禁用的节点运行时被跳过,可撤销)、运行到节点(只跑到指定节点,用来调试)、任务参数、失败处理任务、「数据对账」(把任务与对账规则关联,见 数据对账)。

相关文档

联系我们

请填写您的信息,我们将在 1 个工作日内与您联系。