ComenzarEmpieza gratis

Creación de un BashOperator con plantilla

Has creado correctamente un BashOperator que limpia un archivo de datos ejecutando el script cleandata.sh. Funciona, pero por desgracia requiere que el script se ejecute solo para el día actual. Algunas de tus fuentes de datos a veces llegan con un retraso de un par de días y necesitan ejecutarse manualmente.

Has modificado el script cleandata.sh para que acepte un argumento: la fecha en formato YYYYMMDD. Las pruebas funcionan en la línea de comandos, pero ahora necesitas incorporar esto en tu DAG de Airflow. Por ahora, usa el término {{ ds_nodash }} en tu plantilla; más adelante verás exactamente qué significa.

Este ejercicio forma parte del curso

Introducción a Apache Airflow en Python

Ver curso

Ejercicio interactivo práctico

Pon en práctica la teoría con uno de nuestros ejercicios interactivos

Empezar ejercicio