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ırUygulamalı interaktif egzersiz
İnteraktif egzersizlerimizden biriyle teoriyi pratiğe dökün
Egzersizi başlat