Memahami opsi parameter
Anda telah menggunakan beberapa metode berbeda untuk menambahkan template ke alur kerja. Dengan mempertimbangkan perbedaan di antara opsi, mengapa Anda ingin membuat tugas individu (misalnya, BashOperator) dengan parameter spesifik dibandingkan daftar berkas?
Sebagai contoh, mengapa Anda memilih
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)
ketimbang menggunakan bentuk perulangan seperti
t1 = BashOperator(task_id='task1',
bash_command=templated_command,
params={'filenames': ['file1.txt', 'file2.txt', 'file3.txt']},
dag=dag)
Latihan ini adalah bagian dari kursus
Pengantar Apache Airflow dengan Python
Latihan interaktif praktis
Ubah teori menjadi tindakan dengan salah satu latihan interaktif kami.
Mulai berolahraga