大數據

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,以此類推;

流程關係一覽:
image.png
wpw_table1:週期性往表中寫入數據的任務節點。
wpw_fuzhi:賦值節點,定義執行語句,向下遊傳值(此處是向下遊傳值的賦值語句)
wpw_fenzhi:分支節點,定義分支邏輯,執行具體分支
wpw_test_fenzhi1/wpw_test_fenzhi2:具體分支邏輯節點。

本流程實現的處理步驟和邏輯為:
1.向wpw_table1表日分區中寫入數據(此處可根據業務自性定義sql邏輯)
image.png
2.選取odps sql節點,抽取表wpw_table1中judge字段值作為輸出結果向下遊分支節點傳遞(此處可根據業務自行定義傳值邏輯)
image.png
3.分支節點定義python邏輯判斷,上游節點傳出值為true則走分支1,false則走分支2(可根據業務需要自行定義分支條件)
image.png

image.png
4.分支節點的邏輯(根據業務需要自行定義,此處依賴關係可在步驟3中先行配置)
image.png

配置結束後提交、發佈即可執行
ps:python判斷字符串類型參數需要加單引號調用。

DataWorks百問百答歷史記錄 請點擊這裡查看>>

更多DataWorks技術和產品信息,歡迎加入【DataWorks釘釘交流群】

Leave a Reply

Your email address will not be published. Required fields are marked *