DataWorks:Logika node do-while

Variabel status loop

Variabel berikut selalu tersedia, terlepas dari apakah Anda menggunakan node assignment atau tidak.

Variabel node assignment

Jika node do-while bergantung pada node assignment, Anda dapat meneruskan parameter output node assignment tersebut ke Input Parameters node do-while. Parameter input mengikuti format ${dag.<parameter-name>}, di mana <parameter-name> sesuai dengan nama yang Anda tetapkan di Input Parameters untuk node do-while.

Dalam tabel berikut, input adalah placeholder untuk nama parameter aktual yang Anda konfigurasi.

Tambahkan parameter output node assignment ke Output Parameters untuk node assignment tersebut, lalu tambahkan ke Input Parameters untuk node shell internal node do-while (bukan node do-while itu sendiri). Node shell internal membaca data menggunakan variabel ini dalam kodenya.

Nilai variabel berdasarkan jenis node assignment

Format data bergantung pada bahasa yang digunakan oleh node assignment.

Untuk detail lebih lanjut mengenai format output, lihat Format output parameter outputs.

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

ODPS SQL

Keluar setelah 10 loop atau ketika tabel kosong:

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

Kueri ini membandingkan jumlah baris dan offset saat ini terhadap nilai tetap. Ketika ${dag.offset} melebihi 9 (setelah 10 loop) atau tabel tidak mengembalikan baris apa pun, node end mengembalikan false.

Shell

Keluar setelah 5 loop:

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

${dag.loopTimes} bernilai 1 pada loop pertama dan bertambah 1 setiap iterasi. Saat loop kelima selesai, ${dag.loopTimes} sama dengan 5, kondisi tidak lagi terpenuhi, dan node end mengembalikan False.

Python 2

Keluar ketika semua baris dalam set hasil node assignment telah diproses:

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

${dag.input.length} adalah jumlah entri dalam set data. Loop berlanjut hingga ${dag.loopTimes} mencapai panjang set data, yang berarti setiap entri telah diproses.

Lakukan iterasi atas set hasil dengan node assignment

Gunakan node assignment untuk mengkueri atau menghitung set data, lalu gunakan node do-while untuk memproses setiap entri dalam loop.

Persiapan:

1. Buat node assignment (misalnya, assign_node) yang menghasilkan set data.

2. Buat node do-while yang bergantung pada assign_node.

   Dependensi harus mengarah ke node do-while itu sendiri, bukan ke node shell internalnya.

3. Tambahkan parameter output assign_node ke Output Parameters untuk assign_node.

4. Tambahkan parameter yang sama ke Input Parameters untuk node task internal (node shell) dari node do-while.

   Konfigurasikan parameter input pada node shell internal, bukan pada node do-while.

5. Dalam kode node end, gunakan ${dag.loopTimes} dan ${dag.input.length} untuk keluar ketika semua entri telah diproses.

Untuk memverifikasi bahwa assign_node meneruskan outputnya dengan benar, gunakan fitur pengisian ulang data di Operation Center untuk mengisi ulang data kedua node tersebut secara bersamaan. Menjalankan node do-while saja akan melewatkan output dari node assignment.

Gabungkan dengan node branch dan node merge

Ketika alur kerja internal memerlukan logika kondisional atau traversal hasil, tambahkan node branch dan node merge di dalam node do-while.

Persiapan:

• Di dalam node do-while, hubungkan node branch (branch_node) dan node merge (merge_node) sebagai bagian dari alur kerja internal.

• Node branch dan node merge harus selalu digunakan bersama di dalam node do-while.