ComenzarEmpieza gratis

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

Ver curso

Ejercicio interactivo práctico

Convierte la teoría en acción con uno de nuestros ejercicios interactivos

Empieza a hacer ejercicio