Programa un DAG mediante Python
Has aprendido bastante sobre la creación de DAGs, pero ahora te gustaría programar un DAG específico un día concreto de la semana a una hora determinada. Te gustaría que el código incluyera esta información por si un colega necesita reinstalar el DAG en un servidor diferente.
Se han importado para ti el objeto Airflow DAG y los métodos datetime correspondientes.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Instrucciones del ejercicio
- Fija la fecha de inicio de la DAG en el 1 de noviembre de 2023.
- Configura el
retry_delaya 20 minutos. Aprenderás más sobre el objeto timedelta en el capítulo 3. Por ahora, basta con que sepas que espera un valor entero. - Utiliza la sintaxis cron para configurar un horario de todos los miércoles a las 12:30 h.
Ejercicio interactivo práctico
Prueba este ejercicio completando 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='____')