Define el orden de los BashOperators
Ahora que has aprendido sobre los operadores de desplazamiento de bits, es hora de modificar tu flujo de trabajo para incluir un paso de pull y el orden de las tareas. Tienes tres componentes ya definidos: cleanup, consolidate y push_data.
El DAG analytics_dag está disponible como antes y el BashOperator ya está importado.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Instrucciones del ejercicio
- Define un
BashOperatorllamadopull_salescon el comando bashwget https://salestracking/latestinfo?json. - Haz que el operador
pull_salesse ejecute antes de la tareacleanup. - Configura
consolidatepara que se ejecute a continuación, usando el operador downstream. - Establece
push_datapara que se ejecute al final usando cualquiera de los operadores de desplazamiento de bits.
Ejercicio interactivo práctico
Prueba este ejercicio y completa el código de muestra.
# Define a new pull_sales task
pull_sales = ____(
task_id='pullsales_task',
____
)
# Set pull_sales to run prior to cleanup
pull_sales ____ cleanup
# Configure consolidate to run after cleanup
____
# Set push_data to run last
consolidate ____