ComeçarComece de graça

Entendendo opções de parâmetros

Você já usou alguns métodos diferentes para adicionar templates aos seus workflows. Considerando as diferenças entre as opções, por que você escolheria criar tarefas individuais (ou seja, BashOperators) com parâmetros específicos em vez de uma lista de arquivos?

Por exemplo, por que você escolheria

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)

em vez de usar uma forma com loop como

t1 = BashOperator(task_id='task1', 
                  bash_command=templated_command, 
                  params={'filenames': ['file1.txt', 'file2.txt', 'file3.txt']},
                  dag=dag)

Este exercício faz parte do curso

Introdução ao Apache Airflow em Python

Ver curso

Exercício interativo prático

Transforme a teoria em ação com um de nossos exercícios interativos

Começar o exercício