Entender las opciones de parámetros
Has usado varios métodos para añadir plantillas a tus flujos de trabajo. Teniendo en cuenta las diferencias entre opciones, ¿por qué querrías crear tareas individuales (p. ej., BashOperators) con parámetros específicos en lugar de usar 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)
en lugar de usar una forma con 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
Pon en práctica la teoría con uno de nuestros ejercicios interactivos
Empezar ejercicio