MulaiMulai sekarang secara gratis

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

Lihat Kursus

Latihan interaktif praktis

Ubah teori menjadi tindakan dengan salah satu latihan interaktif kami.

Mulai berolahraga