Implementando uma função de callback
Você foi designado recentemente para adicionar callbacks de falha aos Dags criados pelo seu time. Para começar, você quer incluir um callback simples de falha que escreva uma mensagem no log de auditoria quando o sales_etl_dag falhar.
Os objetos dag e task já foram importados e as tarefas get_sales_data e process_sales_data já foram criadas.
Este exercicio faz parte do curso
Introdução ao Apache Airflow em Python
Instruções do exercicio
- Crie uma função de callback chamada
alert_on_failure. - Defina a função para aceitar quaisquer objetos que o Airflow passar para ela.
- Especifique um callback de falha usando a função
alert_on_failure.
exercicio interativo prático
Tente este exercicio completando este código de exemplo.
# Create the callback function
def ____(____):
dag_id = context["dag"].dag_id
task_id = context["task_instance"].task_id
print(f"Task {task_id} in Dag {dag_id} has failed.")
# Specify the Dag with a failure callback
@dag(dag_id='sales_etl_dag',
____=alert_on_failure
)
def sales_etl_dag():
get_sales_data() >> process_sales_data()
sales_etl_dag()