dolphinscheduler的switch组件

一、背景

Apache DolphinScheduler 是一个分布式易扩展的可视化DAG工作流任务调度开源系统。

switch组件官方文档

https://dolphinscheduler.apache.org/zh-cn/docs/2.0.6/user_doc/guide/task/switch.html

Switch简介 

Switch 是一个条件判断节点，依据全局变量的值和用户所编写的表达式判断结果执行对应分支。 注意使用 javax.script.ScriptEngine.eval 执行表达式。

创建任务

点击项目管理 -> 项目名称 -> 工作流定义，点击"创建工作流"按钮，进入 DAG 编辑页面。 拖动工具栏中的 

 任务节点到画板中即能完成任务创建。 注意 switch 任务创建后，要先配置上下游，才能配置任务分支的参数。

任务参数

• 节点名称：一个工作流定义中的节点名称是唯一的。
• 运行标志：标识这个节点是否能正常调度,如果不需要执行，可以打开禁止执行开关。
• 描述信息：描述该节点的功能。
• 任务优先级：worker 线程数不足时，根据优先级从高到低依次执行，优先级一样时根据先进先出原则执行。
• Worker 分组：任务分配给 worker 组的机器机执行，选择 Default，会随机选择一台 worker 机执行。
• 环境名称：安全中心中配置的环境，不配置则不使用。
• 任务组名称：资源中心中配置的任务组，不配置则不使用。
• 失败重试次数：任务失败重新提交的次数，支持下拉和手填。
• 失败重试间隔：任务失败重新提交任务的时间间隔，支持下拉和手填。
• 延时执行时间：任务延迟执行的时间。
• 超时告警：勾选超时告警、超时失败，当任务超过"超时时长"后，会发送告警邮件并且任务执行失败。
• 条件：可以为 switch 任务配置多个条件，当条件满足时，就会执行指定的分支，可以配置多个不同的条件来满足不同的业务，使用字符串判断时需要使用""。
• 分支流转：默认的流转内容，当条件中的内容为全部不符合要求时，则运行分支流转中指定的分支。

二、实操DEMO

SQL任务switch判断DEMO

第一步：新建SQL任务，配置好参数

字段名称和输出参数需要保持一致，涉及到别名通过as匹配；

参数要设置成OUT类型。

第二步： 定义SWITCH节点

需要先配置前置任务；

才能在条件中引用上游传递过来的参数值；

配置好跟下游任务的依赖关系，符合条件的分支流转才能选到下游任务。

三、参考资料

DolphinScheduler任务参数附录 

DolphinScheduler任务插件有一些公共参数，我们将这些公共参数列在文档中供您查阅。每种任务都有如下的所有或者部分默认参数：

默认任务参数