BaşlayınÜcretsiz Başlayın

Parametre seçeneklerini anlama

İş akışlarına şablon eklemek için birkaç farklı yöntem kullandın. Seçenekler arasındaki farkları düşünerek, neden belirli parametrelere sahip bireysel görevler (ör. BashOperator'lar) oluşturmayı, dosya listesini tek görevle çalıştırmaya tercih edersin?

Örneğin, neden şunu seçersin:

t1 = BashOperator(task_id='task1', bash_command=templated_command, params={'filename': 'file1.txt'}, dag=dag)
t2 = BashOperator(task_id='task2', bash_command=templated_command, params={'filename': 'file2.txt'}, dag=dag)
t3 = BashOperator(task_id='task3', bash_command=templated_command, params={'filename': 'file3.txt'}, dag=dag)

yerine şöyle bir döngü formu kullanmak yerine:

t1 = BashOperator(task_id='task1', 
                  bash_command=templated_command, 
                  params={'filenames': ['file1.txt', 'file2.txt', 'file3.txt']},
                  dag=dag)

Bu egzersiz

Python ile Apache Airflow'a Giriş

kursunun bir parçasıdır
Kursu Görüntüle

Uygulamalı interaktif egzersiz

İnteraktif egzersizlerimizden biriyle teoriyi pratiğe dökün

Egzersizi başlat