ComenzarEmpieza gratis

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

Ver curso

Ejercicio interactivo práctico

Pon en práctica la teoría con uno de nuestros ejercicios interactivos

Empezar ejercicio