反馈已提交
网络繁忙
「条件分支」节点的作用就是基于一个来自于上游或者系统的条件,判断是否继续运行下游节点或者运行下游节点里面的哪一个。
使用「条件分支」节点必须保证 ETL 任务有参数,因为「条件分支」节点的条件就是通过参数设置的。
支持添加多个条件分支,指向不同的下游节点,并可对条件进行编辑。
条件判断返回的值为布尔型:true 或 false,当返回值为 true 时,执行下游节点,当返回值为 false 时,不执行下游节点。
不满足分支条件时,未执行的下游节点不等同于运行失败,不影响整体任务的运行。
此处给出一个示例(当天的日期时2021-12-30),每天根据机台的宕机次数,将机台对应的维护级别写到另一张表里。
示例任务用到两张表,其表名称和字段的说明分别如下:
edown:模拟生产环境,某个机台每天的宕机次数会自动录入该表。
estatus:每天根据 edown 表里的宕机次数,将机台维护级别写到这个表里,不同宕机次数对应的级别不同,需要判别。
1)创建一个 ETL 任务,将一个「参数赋值」节点拖到设计界面,如下图设置「数据来源」,SQL 语句的作用是将当天机台宕机次数取出来,并输出为参数。
2)如下图设置「输出参数」,使用右侧的「参数预览」可直接查看输出的参数结果,并将节点重命名为:获取当天宕机次数。
1)将一个「SQL脚本」节点拖到设计界面,如下图设置,SQL 语句的作用是:将当天日期和正常级别写到 estatus 表里,并将节点重命名为:正常级别入库。
2)再将一个「SQL脚本」节点拖到设计界面,如下图设置,SQL 语句的作用是:将当天日期和一般级别写到 estatus 表里,并将节点重命名为:一般级别入库。
3)再将一个「SQL脚本」节点拖到设计界面,如下图设置,SQL 语句的作用是:将当天日期和严重级别写到 estatus 表里,并将节点重命名为:严重级别入库。
1)将一个「条件分支」节点拖到设计界面,上游跟「参数赋值」节点连线,下游跟三个「SQL脚本」节点连线。
此时点击条件分支节点打开设置界面后,可以看到多了三个分支,分别对应到下游的三个节点,可以给每个分支设置判别条件,决定执行哪一个。
2)先设置第一个分支的判别条件,当宕机次数等于 0 时,就执行该分支,如下图所示:
其他两个分支同理设置,只是条件不同,最终设置好的效果如下图所示,并将节点重命名为:级别判定。
当天的宕机次数是 6,保存并运行任务,日志处可以看到只执行严重级别入库,其他两个入库节点直接跳过了。
任务运行成功后,可以看到 estatus 表多了一条今天的记录,如下图所示:
直接输入常量类型的条件值,和定义参数时输入的常量格式保持一致,具体要求如下表所示:
用文本常量值举个例子,设置如下图所示:
フィードバック
鼠标选中内容,快速反馈问题
鼠标选中存在疑惑的内容,即可快速反馈问题,我们将会跟进处理。
不再提示
10s后关闭