Programa un DAG con Python
Has aprendido bastante sobre cómo crear DAGs, pero ahora te gustaría programar un DAG concreto en un día específico de la semana a una hora determinada. Quieres que el código incluya esta información por si una persona del equipo necesita reinstalar el DAG en otro servidor.
El objeto DAG de Airflow y los métodos adecuados de datetime ya se han importado por ti.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Instrucciones del ejercicio
- Establece la fecha de inicio del DAG al 1 de noviembre de 2023.
- Configura
retry_delayen 20 minutos. Aprenderás más sobre el objeto timedelta en el Capítulo 3. Por ahora, solo necesitas saber que espera un valor entero. - Usa la sintaxis de cron para configurar una programación de todos los miércoles a las 12:30 p. m.
Ejercicio interactivo práctico
Prueba este ejercicio y completa el código de muestra.
# Update the scheduling arguments as defined
default_args = {
'owner': 'Engineering',
'start_date': datetime(____, ____, ____),
'email': ['[email protected]'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 3,
'retry_delay': timedelta(minutes=____)
}
dag = DAG('update_dataflows', default_args=default_args, schedule_interval='____')