Definir el orden de los BashOperators
Ahora que ya conoces los operadores de desplazamiento de bits, es el momento de modificar tu flujo de trabajo para incluir un paso de extracción e incluir la ordenación de tareas. Tienes tres componentes definidos actualmente, 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 de ejercicio
- Define un
BashOperatorllamadopull_salescon un comando bash dewget https://salestracking/latestinfo?json. - Configura el operador
pull_salespara que se ejecute antes que la tareacleanup. - Configura
consolidatepara que se ejecute a continuación, utilizando el operador descendente. - Configura
push_datapara que se ejecute en último lugar utilizando cualquiera de los operadores de desplazamiento de bits.
Ejercicio interactivo práctico
Pruebe este ejercicio completando este 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 ____