Comprender las opciones de los parámetros
Has utilizado varios métodos diferentes para añadir plantillas a tus flujos de trabajo. Teniendo en cuenta las diferencias entre las opciones, ¿por qué querrías crear tareas individuales (es decir, BashOperators) con parámetros específicos frente a una lista de archivos?
Por ejemplo, ¿por qué elegirías
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)
mediante una forma de bucle como
t1 = BashOperator(task_id='task1',
bash_command=templated_command,
params={'filenames': ['file1.txt', 'file2.txt', 'file3.txt']},
dag=dag)
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Ejercicio interactivo práctico
Convierte la teoría en acción con uno de nuestros ejercicios interactivos
