Implementar una función de callback
Te han asignado recientemente añadir callbacks de error a los Dags creados por tu equipo. Para empezar, quieres añadir un callback sencillo que escriba un mensaje en el registro de auditoría cuando falle el sales_etl_dag.
Los objetos dag y task ya están importados y las tareas get_sales_data y process_sales_data ya se han creado.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Instrucciones del ejercicio
- Crea una función de callback llamada
alert_on_failure. - Define la función para aceptar cualquier objeto que Airflow le pase.
- Especifica un callback de error usando la función
alert_on_failure.
ejercicio interactivo práctico
Prueba este ejercicio completando este código de ejemplo.
# 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()