如果您需要在任务流中进行条件判断,可以添加条件分支节点,条件分支节点可实现任务流在特定条件下执行后续任务。本文介绍配置条件分支节点的方法。

前提条件

已创建任务流,具体操作,请参见创建任务流

应用场景

执行任务流时,如果条件分支节点的条件表达式判断结果为True,执行后续任务,否则不执行后续任务。条件分支节点可以应用于以下场景或更多类似场景。
  • 数据条目达到一定数量后,进行数据备份与删除。
  • 销售额达标后,发送提醒信息。
  • 判断文件是否存在,如果文件不存在,新建文件。

操作步骤

  1. 进入任务流详情界面。
    1. 登录数据管理DMS 5.0
      说明 如果您需要切换到旧版数据管理DMS,单击页面右下角返回旧版,进入数据管理DMS平台。具体操作,请参见数据管理DMS 5.0切换至旧版
    2. 在顶部菜单栏中,选择传输与加工 > 任务编排
      说明 如果您使用的是旧版数据管理DMS,在顶部菜单栏中,选择全部功能 > 数据工厂 > 任务编排(新)
    3. 单击目标任务流名称,进入任务流详情页面。
  2. 在画布左侧任务类型列表中,拖拽条件分支节点到画布空白区域。
  3. 选中条件分支节点。
  4. 节点信息页签中,配置条件表达式。
    • 从变量名下拉列表中选择上游变量运行状态
      说明
      • 您可以在左侧的输入变量页签下,查看上游变量、运行状态和系统变量。
      • 如果您选择的变量名为运行状态,则关系符和变量值不需要设置。
    • 从关系符下拉列表中选择比较运算符。
    • 在变量值文本框中输入您期望的变量值或变量。变量的输入格式为${var_name}。关于变量,请参见条件分支变量
    • 可选:单击条件表达式右侧的按钮,新增或删除表达式。
      • 加:新增一个与原表达式同级的条件表达式,并从逻辑运算符下拉列表中,选择新增表达式与原表达式之间的逻辑运算符。
      • 5加4:新增一个条件表达式,且该表达式与原表达式共同移动到下一级。从逻辑运算符下拉列表中,选择新增表达式与原表达式之间的逻辑运算符。
      • 减:删除条件表达式。
      9任务编排条件表达式2
    说明
    • 条件表达式最多可以添加3级。
    • 您可以在条件表达式右侧的预览区域,查看判断逻辑。

条件分支变量

  • 上游变量。上游变量是来自上游节点的输出变量。
  • 系统变量。
    变量名 意义 例子
    sys.flow.start.timestamp 运行时间的时间戳。 2021-05-24T11:20:07.562+08:00
    sys.flow.start.year 运行时间的年份。 2021
    sys.flow.start.month 运行时间的月份。 5
    sys.flow.start.day 运行时间的日期。 24
    sys.flow.start.hour 运行时间的小时。 11
    sys.flow.start.minute 运行时间的分钟。 20
    sys.flow.start.second 运行时间的秒。 7
    sys.flow.start.milliseconds 运行时间的毫秒数。 562
    sys.flow.start.timezone 运行时间的时区。 Asia/Shanghai
    sys.flow.biztime 业务时间,默认为运行时间减一天。 1621740007562
    sys.flow.name 任务流名称。 dwd_activity日pv
    sys.node.name 任务名称。 单实例SQL-1
  • 时间变量。使用系统默认的时间变量或任务流变量。设置任务流变量,请参见配置时间变量