DataWorks百问百答53:如何配置使用赋值节点+分支节点?

赋值节点:在节点中通过编写代码的方式对输出参数赋值,结合节点上下文传递,供下游节点引用和使用其取值。
赋值节点详情介绍: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,以此类推;

流程关系一览:
DataWorks百问百答53:如何配置使用赋值节点+分支节点?
wpw_table1:周期性往表中写入数据的任务节点。
wpw_fuzhi:赋值节点,定义执行语句,向下游传值(此处是向下游传值的赋值语句)
wpw_fenzhi:分支节点,定义分支逻辑,执行具体分支
wpw_test_fenzhi1/wpw_test_fenzhi2:具体分支逻辑节点。

本流程实现的处理步骤和逻辑为:
1.向wpw_table1表日分区中写入数据(此处可根据业务自性定义sql逻辑)
DataWorks百问百答53:如何配置使用赋值节点+分支节点?
2.选取odps sql节点,抽取表wpw_table1中judge字段值作为输出结果向下游分支节点传递(此处可根据业务自行定义传值逻辑)
DataWorks百问百答53:如何配置使用赋值节点+分支节点?
3.分支节点定义python逻辑判断,上游节点传出值为true则走分支1,false则走分支2(可根据业务需要自行定义分支条件)
DataWorks百问百答53:如何配置使用赋值节点+分支节点?

DataWorks百问百答53:如何配置使用赋值节点+分支节点?
4.分支节点的逻辑(根据业务需要自行定义,此处依赖关系可在步骤3中先行配置)
DataWorks百问百答53:如何配置使用赋值节点+分支节点?

配置结束后提交、发布即可执行
ps:python判断字符串类型参数需要加单引号调用。

DataWorks百问百答历史记录 请点击这里查看>>

更多DataWorks技术和产品信息,欢迎加入【DataWorks钉钉交流群】

上一篇:控制ASP.NET Web API 调用频率


下一篇:DataWorks百问百答56:数据集成同步中的增量同步功能如何配置?