You need to enable JavaScript to run this app.
大数据研发治理套件

大数据研发治理套件

复制全文
通用
分支任务
复制全文
分支任务

分支判断节点是 DataLeap 提供的一种逻辑控制节点类型,用于满足不同分支条件下触发不同处理逻辑的需求。在实际业务场景中,您可根据上游产出,来判断走向下游哪条分支任务,如条件1满足,执行下游A任务;条件2满足,则执行下游B任务。本文将为您介绍分支任务的配置说明。

说明

分支判断任务通常与归并任务配合使用。详见归并任务

1 注意事项

  • 分支任务目前以白名单形式放开,您可通过提工单方式,联系我们进行加白后开通使用。
  • 在分支节点中,若下游分支的任务不满足条件,则这些任务将会是跳过执行,且已触发下游的状态。

2 新建任务

  1. 登录 DataLeap 租户控制台
  2. 在具体项目中进入数据开发界面,并单击新建任务按钮进行任务新建。
  3. 依次选择数据开发 > 通用 > 分支任务
  4. 填写任务基本信息,单击确定按钮,完成任务创建。

注意

任务名称信息仅允许字符.、字母、数字、下划线、连字符、[]、【】、()、()以及中文字符,且需要在127个字符以内。

Image

3 任务配置

分支判断任务创建完成后,进入到分支逻辑定义界面,您可根据实际场景定义不同分支判断逻辑,不同逻辑可走向不同分支下游。

3.1 分支逻辑定义

Image
在分支逻辑定义界面,您可进行以下操作:

序号

功能

说明

1

分支名称

单击新建分支右侧编辑按钮,进行分支名称的命名。

2

分支描述

单击编辑按钮,对每个分支链路添加相应的描述信息,方便后续下游任务关联时区分。

3

分支条件

在下拉框中,选择分支条件语句类型,默认支持选择Shell语句类型,分支条件语法示例详见下方“3.2 Shell分支示例”。

说明

分支执行语句,若最后返回 0,则该分支正常退出,下游正常执行;若最后返回 1,则该分支异常退出,下游状态为“跳过执行,且已触发下游”。

4

添加分支

单击添加分支按钮,您可根据实际下游任务场景,添加多个不同的分支判断逻辑条件。

5

复制

单击复制按钮,可直接将当前创建的分支复制,成为一个新的分支。

6

删除

单击删除按钮,将当前分支删除。

3.2 Shell分支示例

创建分支任务: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
    

说明

  • Shell_分支A:当上游输入结果条件满足{{input}} 小于 10 时,shell_分支A关联的下游任务被触发,shell_分支B的下游任务会是跳过执行的状态。
  • Shell_分支B:当上游输入结果条件满足{{input}} 大于 10 时,shell_分支B关联的下游任务被触发,shell_分支A的下游任务会是跳过执行的状态。

4 调度设置

分支逻辑编辑完成后,单击右侧侧边栏的调度设置,配置调度设置相关参数,便可进行分支判断任务周期性调度。配置详见任务调度属性
分支任务的下游任务设置依赖操作说明如下:

  1. 在新建任务界面,新建下游 Python 任务,命名:Python_A。
  2. 在代码编辑器界面输入相应语句内容后,单击右侧调度设置界面,进行依赖关系配置。
  3. 在依赖关系处,单击手动添加按钮,输入上游分支任务名称(branch_shell)进行添加。
  4. 添加完上游分支任务后,再在依赖设置处,下拉选择关联的 Shell_分支A ;
  5. 依赖设置完成后,单击保存按钮,完成下游任务设置。

按照以上流程,将另一个下游分支链路进行保存,则后续当分支任务的上下游任务,一起在运维调度执行时,若 branch_shell 分支任务的 Shell_分支A 链路条件满足时,则下游 Python_A 任务将会被实际触发运行,Python_B 任务将会被跳过。

说明

Python_B 任务的下游节点,会一直延续传递跳过状态,直到分支结束。

Image
其余更多调度设置说明详见“任务调度依赖”。

5 提交任务

数据开发界面调试运行、调度设置等操作完成后,您可单击操作栏中的保存提交上线按钮,在弹窗中,进行回溯数据、监控设置、提交设置等操作,并单击确认按钮,完成作业提交。操作详见“4 提交上线”。

6 运维中心验证分支执行结果

与分支任务相关的上下游任务,在整体发布至运维中心后,您可通过数据回溯操作,来验证分支执行结果:

  1. 在数据开发界面,上方导航栏处,单击选择运维中心 > 离线任务运维 > 数据回溯 > 发起的,进入发起数据回溯界面。
  2. 单击界面右上角新建数据回溯按钮,并完成数据回溯相关设置,等待回溯任务执行完成。回溯操作详见“数据回溯”。
  3. 前往实例运维界面,根据分支任务名称进行搜索任务回溯实例,在实例列表操作列中,单击实例DAG,进入查看对应分支的调度日志执行详情。

Image

最近更新时间:2026.01.16 11:57:20
这个页面对您有帮助吗?
有用
有用
无用
无用