分支判断节点是 DataLeap 提供的一种逻辑控制节点类型,用于满足不同分支条件下触发不同处理逻辑的需求。在实际业务场景中,您可根据上游产出,来判断走向下游哪条分支任务,如条件1满足,执行下游A任务;条件2满足,则执行下游B任务。本文将为您介绍分支任务的配置说明。
说明
分支判断任务通常与归并任务配合使用。详见归并任务。
注意
任务名称信息仅允许字符.、字母、数字、下划线、连字符、[]、【】、()、()以及中文字符,且需要在127个字符以内。
分支判断任务创建完成后,进入到分支逻辑定义界面,您可根据实际场景定义不同分支判断逻辑,不同逻辑可走向不同分支下游。

在分支逻辑定义界面,您可进行以下操作:
序号 | 功能 | 说明 |
|---|---|---|
1 | 分支名称 | 单击新建分支右侧编辑按钮,进行分支名称的命名。 |
2 | 分支描述 | 单击编辑按钮,对每个分支链路添加相应的描述信息,方便后续下游任务关联时区分。 |
3 | 分支条件 | 在下拉框中,选择分支条件语句类型,默认支持选择Shell语句类型,分支条件语法示例详见下方“3.2 Shell分支示例”。 说明 分支执行语句,若最后返回 0,则该分支正常退出,下游正常执行;若最后返回 1,则该分支异常退出,下游状态为“跳过执行,且已触发下游”。 |
4 | 添加分支 | 单击添加分支按钮,您可根据实际下游任务场景,添加多个不同的分支判断逻辑条件。 |
5 | 复制 | 单击复制按钮,可直接将当前创建的分支复制,成为一个新的分支。 |
6 | 删除 | 单击删除按钮,将当前分支删除。 |
创建分支任务:branch_shell,并增加两个分支条件,分别命名shell_分支A、shell_分支B,并在条件语句编辑器中,输入以下语句:
Shell_分支A
num={{input}} if [ $num -lt 10 ]; then echo "上游输入 $num 小于 10,走分支A" exit 0 else exit 1 fi
Shell_分支B
num={{input}} if [ $num -gt 10 ]; then echo "上游输入 $num 大于 10,走分支B" exit 0 else exit 1 fi
说明
分支逻辑编辑完成后,单击右侧侧边栏的调度设置,配置调度设置相关参数,便可进行分支判断任务周期性调度。配置详见任务调度属性。
分支任务的下游任务设置依赖操作说明如下:
按照以上流程,将另一个下游分支链路进行保存,则后续当分支任务的上下游任务,一起在运维调度执行时,若 branch_shell 分支任务的 Shell_分支A 链路条件满足时,则下游 Python_A 任务将会被实际触发运行,Python_B 任务将会被跳过。
说明
Python_B 任务的下游节点,会一直延续传递跳过状态,直到分支结束。
其余更多调度设置说明详见“任务调度依赖”。
数据开发界面调试运行、调度设置等操作完成后,您可单击操作栏中的保存和提交上线按钮,在弹窗中,进行回溯数据、监控设置、提交设置等操作,并单击确认按钮,完成作业提交。操作详见“4 提交上线”。
与分支任务相关的上下游任务,在整体发布至运维中心后,您可通过数据回溯操作,来验证分支执行结果: