DataWorks：do-while節點

節點群組成

雙擊 do-while 節點，進入其內部編排畫布，主要由以下三部分構成：

• 開始：迴圈的入口標記，不可編輯或刪除。

• 迴圈體：一個可自由編排的工作區域。可通過“建立內部節點”添加 Shell、SQL、Python 等多種類型的任務節點，形成需重複執行的商務程序。

• 結束：迴圈的判斷節點，本質是一個賦值節點。支援 ODPS SQL、Shell、Python 編寫代碼，最終輸出 True 或 False 字串以決定是否繼續迴圈。

內建變數

在 do-while 節點的迴圈體和結束節點中，您可以使用以下內建變數擷取當前迴圈狀態及輸入資料：

樣本：${dag.input[0][1]} 可提取第一行第二列的值 "beijing"。

步驟一：配置迴圈體（添加 Shell 節點）

1. 在您的商務程序中建立一個 do-while 節點。

2. 雙擊進入節點內部，在“迴圈體”地區單擊 “建立內部節點”，選擇 Shell 節點，並命名為 print_loop_times。

3. 按右鍵該節點，選擇 “開啟節點”。

4. 在代碼編輯器中輸入以下命令：

   # 使用內建變數 ${dag.loopTimes} 擷取當前迴圈次數
   echo "This is loop number: ${dag.loopTimes}"

5. 單擊儲存表徵圖完成儲存。

步驟二：定義允出準則

1. 返回 do-while 內部畫布，按右鍵 結束 節點，選擇 “開啟節點”。

2. 將語言切換為 Python。

3. 輸入以下 Python 代碼：

   # 當迴圈次數小於5時，輸出True，繼續迴圈
   # 當迴圈次數達到5時，輸出False，退出迴圈
   if ${dag.loopTimes} < 5:
       print True
   else:
       print False

4. 儲存結束節點。

步驟三：發布、運行與驗證

1. 返回主工作流程畫布，點擊工具列的 發布 按鈕，發布整個工作流程。

2. 進入 營運中心，定位到該 do-while 節點。

3. 按右鍵節點 → 補資料 > 當前節點，啟動一次測試回合。

4. 待執行個體運行成功後，再次右鍵 → “查看內部節點”。

5. 查看五次迴圈記錄，任意展開某次迴圈（如第5次），右鍵其內部的 print_loop_times 執行個體 → “查看作業記錄”，應可見輸出：

   This is loop number: 5

步驟一：配置上遊賦值節點

1. 建立一個 賦值節點（如命名 assign_sql_data），並設為 do-while 的上遊。

2. 在節點中使用 ODPS SQL 查詢資料：

   SELECT 'user_A', 'beijing'
   UNION ALL
   SELECT 'user_B', 'shanghai';

3. 儲存節點。其 outputs 參數將輸出一個包含兩行資料的二維數組。

步驟二：配置 do-while 節點消費資料

1. 在 do-while 節點右側的 “調度配置” 面板中，找到 “本節點輸入參數”。

2. 點擊 “添加”，配置如下參數：

   • 參數名：input（可自訂）

   • 取值來源：選擇 assign_sql_data.outputs

3. 在 do-while 的 迴圈體 中建立一個 Shell 節點，輸入以下指令碼處理當前行：

   # 擷取當前迴圈處理的行資料
   echo "Processing data row: ${dag.input[${dag.offset}]}"

4. 開啟 結束 節點，使用 Python 設定允出準則：

   # 若已執行次數小於資料總行數，則繼續迴圈
   if ${dag.loopTimes} < ${dag.input.length}:
       print True
   else:
       print False

5. 發布工作流程，並在營運中心 從 assign_sql_data 節點開始補資料，確保資料正確流入迴圈。