DataWorks：do-while節點邏輯原理介紹

背景資訊

使用限制

• 僅DataWorks標準版及以上版本支援使用do-while節點。詳情請參見DataWorks各版本詳解。

• do-while節點迴圈次數上限為1024次。

• 不支援並發執行。即上次迴圈完成後才可進入下一次迴圈。

注意事項

節點群組成與流程編排

內建變數

通常，do-while節點使用${dag.變數名}格式來擷取變數。DataWorks為您提供了兩個系統內建變數${dag.loopTimes}、${dag.offset}；同時，您也可以結合賦值節點，通過${dag.變數名}格式擷取賦值參數值。

• 系統內建變數

  每次任務迴圈運行時，您可以通過一些內建的變數來擷取當前已迴圈次數和位移量。

  內建變數	含義	取值
  ${dag.loopTimes}	當前已迴圈次數	第一次迴圈為1、第二次為2、第三次為3…第n次為n。
  ${dag.offset}	位移量	第一次迴圈為0、第二次為1、第三次為2…第n次為n-1。

• 擷取賦值節點結果

  如果您聯合使用了賦值節點，則還可以通過以下方式來擷取賦值參數值和迴圈變數參數。

  說明

  當do-while節點依賴賦值節點時，您可將賦值節點的本節點輸出參數設定為do-while節點的本節點輸入參數，在do-while節點中擷取賦值節點的結果集與結果集中的指定節點。格式為${dag.變數名}，其中，變數名需配置為do-while節點的本節點輸入參數。本文樣本定義do-while節點中的input參數（即本節點輸入參數）來接收賦值節點結果集，實際使用時，需替換為您真實的參數名稱。

  內建變數	含義
  ${dag.input}	上遊賦值節點傳遞的資料集。
  ${dag.input[${dag.offset}]}	迴圈節點內部擷取當前迴圈的資料行。
  ${dag.input.length}	迴圈節點內部擷取資料集長度。

取值案例

不同賦值語言的賦值節點，其結果集格式存在差異。do-while節點擷取賦值節點結果集時，Shell賦值語言需使用一維數組的方式在代碼中擷取賦值節點傳遞的結果集、或結果集中的指定資料；ODPS SQL賦值語言需使用二維數組的方式在代碼中擷取賦值節點傳遞的結果集、或結果集中的指定資料。詳情請參見賦值節點輸出格式。

案例1：上遊賦值節點為Shell文法

• 節點輸出

  上遊賦值節點為Shell文法，最後一條輸出結果為2021-03-28,2021-03-29,2021-03-30,2021-03-31,2021-04-01。

• 變數取值

  內建變數	第1次迴圈時取值	第2次迴圈時取值
  ${dag.input}	2021-03-28,2021-03-29,2021-03-30,2021-03-31,2021-04-01
  ${dag.input[${dag.offset}]}	2021-03-28	2021-03-29
  ${dag.input.length}	5
  ${dag.loopTimes}	1	2
  ${dag.offset}	0	1

案例2：上遊賦值節點為ODPS SQL文法

• 節點輸出

  上遊賦值節點為ODPS SQL文法，最後一條Select語句查詢出兩條資料：

  +----------------------------------------------+
  | uid            | region | age_range | zodiac |
  +----------------------------------------------+
  | 0016359810821  | 湖北省 | 30~40歲   | 巨蟹座 |
  | 0016359814159  | 未知   | 30~40歲   | 巨蟹座 |
  +----------------------------------------------+

• 變數取值

  內建變數	第1次迴圈時取值	第2次迴圈時取值
  ${dag.input}	+----------------------------------------------+ | uid | region | age_range | zodiac | +----------------------------------------------+ | 0016359810821 | 湖北省 | 30~40歲 | 巨蟹座 | | 0016359814159 | 未知 | 30~40歲 | 巨蟹座 | +----------------------------------------------+
  ${dag.input[${dag.offset}]}	0016359810821,湖北省,30~40歲,巨蟹座	0016359814159,未知,30~40歲,巨蟹座
  ${dag.input.length}	2 說明 二維數組的行數為資料集長度，當前賦值節點輸出的二維數組行數為2。
  ${dag.input[0][1]} 說明 二維數組的第一行第二列的取值。	湖北省
  ${dag.loopTimes}	1	2
  ${dag.offset}	0	1

退出迴圈樣本：End節點代碼範例

End節點支援使用ODPS SQL、Shell和Python（Python2）三種語言進行迴圈判斷代碼開發，以下為您樣本三種不同語言下，典型的代碼範例。

使用ODPS SQL語言

SELECT  CASE 
 WHEN COUNT(1) > 0 AND ${dag.offset}<= 9 
  THEN true 
  ELSE false 
 END 
FROM  xc_dpe_e2.xc_rpt_user_info_d  where dt='20200101';

End節點範例程式碼中將錶行數和遷移量與固定值比較，來限制do-while節點整體的迴圈次數。

使用Shell語言

if [ ${dag.loopTimes} -lt 5 ];
then
     echo "True"
else
     echo "False"
fi

將迴圈次數${dag.loopTimes}和5進行比較，來限制do-while節點整體的迴圈次數。

例如：第一次迴圈${dag.loopTimes}的值為1、第二次為2，以此類推，第五次為5。至此end節點的輸出結果為False，do-while節點退出迴圈。

使用Python（Python2）語言

if ${dag.loopTimes}<${dag.input.length}:
   print True;
else
   print False;
# 如果end節點輸出True，則繼續下一個迴圈。
# 如果end節點輸出False，則終止迴圈。

代碼中把迴圈次數${dag.loopTimes}和賦值節點傳遞的資料集行數進行比較，來限制do-while節點整體的迴圈次數。

應用情境

與賦值節點聯合使用

與分支節點、歸併節點聯合應用

與分支節點和歸併節點聯合應用時，典型的應用情境和注意事項如下所示。