赋值节点:在节点中通过编写代码的方式对输出参数赋值,结合节点上下文传递,供下游节点引用和使用其取值。
赋值节点详情介绍:https://help.aliyun.com/document_detail/137534.html?spm=5176.11065259.1996646101.searchclickresult.45227050VqpSAF
分支节点:逻辑控制系列节点中的一类。分支节点可以定义分支逻辑和不同逻辑条件时下游分支走向。
分支节点详情介绍:https://help.aliyun.com/document_detail/137533.html?spm=5176.11065259.1996646101.searchclickresult.237c2bc85NJuw3
使用场景:A表每日周期产生数据,针对A表的数据的后续操作,判断A表的产出符合什么样的条件,如果符合条件①则执行分支1,如果符合条件②则执行分支2,以此类推;
流程关系一览:
wpw_table1:周期性往表中写入数据的任务节点。
wpw_fuzhi:赋值节点,定义执行语句,向下游传值(此处是向下游传值的赋值语句)
wpw_fenzhi:分支节点,定义分支逻辑,执行具体分支
wpw_test_fenzhi1/wpw_test_fenzhi2:具体分支逻辑节点。
本流程实现的处理步骤和逻辑为:
1.向wpw_table1表日分区中写入数据(此处可根据业务自性定义sql逻辑)
2.选取odps sql节点,抽取表wpw_table1中judge字段值作为输出结果向下游分支节点传递(此处可根据业务自行定义传值逻辑)
3.分支节点定义python逻辑判断,上游节点传出值为true则走分支1,false则走分支2(可根据业务需要自行定义分支条件)
4.分支节点的逻辑(根据业务需要自行定义,此处依赖关系可在步骤3中先行配置)
配置结束后提交、发布即可执行
ps:python判断字符串类型参数需要加单引号调用。
DataWorks百问百答历史记录 请点击这里查看>>
更多DataWorks技术和产品信息,欢迎加入【DataWorks钉钉交流群】