DataWorks:do-while ノードのロジック

ループ状態変数

これらの変数は、代入ノードを使用するかどうかにかかわらず、常に利用可能です。

代入ノード変数

do-while ノードが 代入ノード に依存する場合、代入ノードの出力パラメーターを do-while ノードの [入力パラメーター] に渡すことができます。入力パラメーターは ${dag.<parameter-name>} フォーマットに従います。ここで <parameter-name> は、do-while ノードの [入力パラメーター] で設定した名前と一致します。

以下の表では、input は設定する実際のパラメーター名のプレースホルダーです。

代入ノードの出力パラメーターを、代入ノードの 出力パラメーター に追加し、次にそれらを do-while ノードの内側のシェルノード（do-while ノード自体ではなく）の [入力パラメーター] に追加します。内側のシェルノードは、コード内でこれらの変数を使用してデータを読み取ります。

代入ノードの種類ごとの変数の値

データ形式は、代入ノードで使用される言語によって異なります。

出力形式の詳細については、「出力パラメーターの出力形式」をご参照ください。

+----------------------------------------------+
| uid            | region         | age_range          | zodiac |
+----------------------------------------------+
| 0016359810821  | Hubei Province | 30 to 40 years old | Cancer |
| 0016359814159  | Unknown        | 30 to 40 years old | Cancer |
+----------------------------------------------+

ODPS SQL

10 回ループした後、またはテーブルが空の場合に終了します：

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';

このクエリは、行数と現在のオフセットを固定値と比較します。${dag.offset} が 9 を超える (10 回のループ後)、またはテーブルが行を返さない場合、終了ノードは false を返します。

シェル

5 回ループした後に終了します：

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

${dag.loopTimes} は、最初のループでは 1 であり、反復ごとに 1 ずつ増分します。5 回目のループが終了すると、${dag.loopTimes} は 5 になり、条件が満たされなくなるため、終了ノードは False を出力します。

Python 2

代入ノードの結果セット内のすべての行が処理されたときに終了します：

if ${dag.loopTimes} < ${dag.input.length}:
    print True
else:
    print False

${dag.input.length} は、データセット内のエントリ数です。ループは ${dag.loopTimes} がデータセットの長さに達するまで続行され、その時点ですべてのエントリが処理済みになります。

代入ノードを用いた結果セットの反復処理

代入ノードを使用してデータセットをクエリまたは計算し、その後、do-while ノードを用いてループ内で各エントリを処理します。

セットアップ：

1. データセットを出力する代入ノード（例： assign_node）を作成します。

2. assign_node に依存する do-while ノードを作成します。

   依存関係は、do-while ノード自体に対して設定する必要があります。内側のシェルノードに対しては設定しないでください。

3. assign_node の出力パラメーターを、assign_node の **[出力パラメーター]** に追加します。

4. 同様のパラメーターを、do-while ノード内のタスクノード（シェルノード）の **[入力パラメーター]** にも追加します。

   入力パラメーターは、do-while ノードではなく、内側のシェルノード上で設定してください。

5. 終了ノードのコード内で、すべてのエントリが処理された時点でループを終了するために、${dag.loopTimes} および ${dag.input.length} を使用します。

assign_node が出力を正しく渡していることを確認するには、オペレーションセンターのデータバックフィル機能を用いて、両方のノードを同時にデータバックフィルしてください。do-while ノード単体で実行すると、代入ノードの出力はスキップされます。

ブランチノードおよびマージノードとの連携

内側のワークフローで条件付きロジックや結果の走査が必要な場合、do-while ノード内にブランチノードおよびマージノードを追加します。

設定手順：

• do-while ノード内において、ブランチノード（branch_node）とマージノード（merge_node）を内側のワークフローの一部として接続します。

• ブランチノードおよびマージノードは、do-while ノード内では常にペアで使用する必要があります。