流程任务:DAG 画布编排
在画布上用节点和连线编排批处理流程:触发方式、节点分组、发布到生产、调度、补数与调试能力。
概述
流程任务适合多步骤编排:查库 → 同步 → 调接口 → 写库 → 通知。固定流向的表同步优先用 管道任务,秒级持续同步用 实时任务。
权限与入口:
task:view查看;task:edit新建 / 编辑 / 发布 / 运行;task:script使用脚本节点。菜单:数据集成 → 流程任务
流程任务是在画布上用节点和连线编排的批处理流程,可按 cron 或一次性时间调度,也可由事件、接口调用触发。

图:流程任务列表
图中编号说明:
- 新建任务。
- 所属目录树:按目录筛选任务。
- 状态:草稿 / 待发布 / 运行中 / 运行成功 / 运行失败 / 已暂停 / 等待中;名称后的「开发」标签表示当前是开发草稿,尚未发布到生产。
- 操作:行首是运行 / 停止执行与查看运行记录,「…」里是更多操作。
新建任务
点「新建任务」,填写任务名称、触发方式(定时 / 手动 / 事件 / 接口调用)、模板和所属目录,创建后直接进入画布。触发方式只是起步引导,之后可以随时叠加其他触发。选择「接口调用触发」时,任务自动设为轻量档位,只允许 HTTP、应用动作、SQL 脚本、参数赋值、条件等短节点,用于被数据服务(流程服务)同步调用(见 流程服务:把任务变成接口)。
在画布上编排

图:画布编辑器
图中编号说明:
- 节点面板:可搜索,按分组列出所有节点,点击或拖到画布上添加。
- 画布上的节点:节点上的小红点表示这个节点还有必填项没配;运行后节点上会显示运行状态。
- 连线:标签是触发条件(成功后 / 失败后);悬停连线可在中间插入节点。
- 配置面板:点击节点后,这里显示它的属性;点连线则改流转条件。
| 节点分组 | 包含的节点 |
|---|---|
| 数据处理 | 数据同步、数据转换、查询 / 新增 / 修改 / 删除数据、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 临时关闭对齐吸附。从节点端口拖到空白处松手,可直接新建并连上下游节点;在空白处右键有常用节点的快捷添加。
发布、调度与运行
- 保存画布:保存的是「开发」草稿。底部状态栏会提示节点数、连线数和「n 个节点有问题」,修完再发布。
- 发布到生产:任务行「…」里点「发布到生产」。发布后生成不可变的生产快照;之后再改画布会出现「有待发布改动」,需要再次发布才会生效。「生产版本」里可以查看历史版本与只读快照。
- 设置触发:在「…」里选「调度计划」(cron 或一次性时间)、「事件触发」(订阅事件入口);接口调用触发通过数据服务绑定。不设置调度也可以手动或由接口触发。
- 运行:点行首播放按钮立即运行;「带参数运行 / 补数」可传入运行参数或补一段历史;「运行时限」限制单次最长时间;「停止全部运行」用于紧急停止。
- 看结果:「查看运行记录」打开抽屉;点「日志」进入逐行运行日志(运行记录与运行日志),失败时先看错误级别的日志与失败节点。
其他实用能力:节点禁用(右键菜单或配置面板里可以一键禁用选中节点及其所有下游,禁用的节点运行时被跳过,可撤销)、运行到节点(只跑到指定节点,用来调试)、任务参数、失败处理任务、「数据对账」(把任务与对账规则关联,见 数据对账)。
相关文档
- 凭据、环境变量、通知渠道与事件入口:HTTP 节点用凭据,事件触发订阅事件入口。
- 数据服务:把「接口调用触发」的轻量任务发布成流程服务。
- 数据质量:库表、检测与对账:「调用检测」节点与对账规则。
- 运行记录与运维概览:查看运行实例与日志。