DataWorks:Do-while düğümü

Düğüm bileşenleri

Bir do-while düğümüne çift tıklayarak iç tuvalini açın; bu tuval üç ana bölümden oluşur:

• Start: Döngünün giriş noktasını işaretler. Bu düğümü düzenleyemez veya silemezsiniz.

• Döngü gövdesi: Görevleriniz için özelleştirilebilir bir tuval. Tekrarlanabilir iş sürecini oluşturmak üzere Shell, SQL ve Python gibi çeşitli dahili düğüm türleri eklemek için Create Internal Node seçeneğine tıklayabilirsiniz.

• End: Döngü koşulunu değerlendirir. Bu düğüm, ODPS SQL, Shell veya Python kodu yazabileceğiniz bir atama düğümüdür. Döngünün devam edip etmeyeceğini belirlemek için True veya False dizesini çıktılar.

Yerleşik değişkenler

Do-while düğümünün döngü gövdesinde ve End düğümünde, geçerli döngü durumunu ve giriş verilerini almak için aşağıdaki yerleşik değişkenleri kullanabilirsiniz:

Örnek: ${dag.input[0][1]} ifadesi, ilk satır ve ikinci sütundan "beijing" değerini çıkarır.

1. Adım: Döngü gövdesini yapılandırma (Shell düğümü ekleme)

1. İş akışınızda bir do-while düğümü oluşturun.

2. Dahili tuvale girmek için düğüme çift tıklayın. Döngü gövdesi alanında Create Internal Node seçeneğine tıklayın, Shell öğesini seçin ve adını print_loop_times olarak belirleyin.

3. Düğüme sağ tıklayın ve Open Node seçeneğini belirleyin.

4. Kod düzenleyicisine aşağıdaki komutu girin:

   # Use the built-in variable ${dag.loopTimes} to get the current loop count
   echo "This is loop number: ${dag.loopTimes}"

5. Düğümü kaydetmek için kaydet simgesine tıklayın.

2. Adım: Çıkış koşulunu tanımlama

1. Do-while düğümünün dahili tuvaline dönün, End düğümüne sağ tıklayın ve Open Node seçeneğini belirleyin.

2. Dili Python olarak değiştirin.

3. Aşağıdaki Python kodunu girin:

   # When the loop count is less than 5, output True and continue looping
   # When the loop count reaches 5, output False and exit the loop
   if ${dag.loopTimes} < 5:
       print True
   else:
       print False

4. End düğümünü kaydedin.

3. Adım: Dağıtma, çalıştırma ve doğrulama

1. Ana iş akışı tuvaline dönün ve tüm iş akışını dağıtmak için araç çubuğundaki Deploy seçeneğine tıklayın.

2. Operation Center bölümüne gidin ve do-while düğümünü bulun.

3. Düğüme sağ tıklayın ve test çalıştırması başlatmak için Backfill Data > Current Node seçeneğini belirleyin.

4. Örnek başarıyla çalıştıktan sonra düğüme tekrar sağ tıklayın ve View Internal Nodes seçeneğini belirleyin.

5. Beş döngü yinelemesini görüntüleyin. Herhangi bir yinelemeyi (örneğin 5. yinelemeyi) genişletin, içindeki print_loop_times örneğine sağ tıklayın ve View Runtime Log seçeneğini belirleyin. Aşağıdaki çıktıyı görmeniz gerekir:

   This is loop number: 5

1. Adım: Yukarı akış atama düğümünü yapılandırma

1. Bir atama düğümü oluşturun (örneğin adı assign_sql_data olabilir) ve bunu do-while düğümünün yukarı akışı olarak ayarlayın.

2. Düğümde veri sorgulamak için ODPS SQL kullanın:

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

3. Düğümü kaydedin. outputs parametresi iki satır veri içeren iki boyutlu bir dizi çıktılar.

2. Adım: Veriyi tüketmek için do-while düğümünü yapılandırma

1. do-while düğümünün sağ tarafındaki Schedule Settings panelinde Input Parameters of This Node bölümünü bulun.

2. Add seçeneğine tıklayın ve aşağıdaki parametreyi yapılandırın:

   • Parameter Name: input (özelleştirilebilir)

   • Value Source: assign_sql_data.outputs seçeneğini belirleyin

3. do-while düğümünün döngü gövdesinde bir Shell düğümü oluşturun ve mevcut satırı işlemek için aşağıdaki betiği girin:

   # Get the data row being processed in the current loop iteration
   echo "Processing data row: ${dag.input[${dag.offset}]}"

4. End düğümünü açın ve çıkış koşulunu tanımlamak için Python kullanın:

   # If the number of times executed is less than the total number of data rows, continue looping
   if ${dag.loopTimes} < ${dag.input.length}:
       print True
   else:
       print False

5. İş akışını dağıtın ve Operation Center içinde verinin döngüye doğru aktığından emin olmak için geri doldurmayı **assign_sql_data düğümünden başlatın.