ComenzarEmpieza gratis

Crear un BashOperator con plantilla

Has creado correctamente un BashOperator que limpia un archivo de datos ejecutando un script llamado cleandata.sh. Funciona, pero por desgracia obliga a ejecutar el script solo para el día actual. Algunas de tus fuentes de datos a veces llegan con 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 te funcionan en la línea de comandos, pero ahora tienes que integrarlo 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