Volgorde van BashOperators definiëren

Nu je de bitshift-operators kent, is het tijd om je workflow aan te passen zodat er een pull-stap in zit en de volgorde van de taken is vastgelegd. Je hebt drie al gedefinieerde componenten: cleanup, consolidate en push_data.

De DAG analytics_dag is zoals eerder beschikbaar en de BashOperator is al geïmporteerd.

Deze oefening maakt deel uit van de cursus

Introductie tot Apache Airflow in Python

Cursus bekijken

Oefeninstructies

Definieer een BashOperator met de naam pull_sales met als bash-commando wget https://salestracking/latestinfo?json.
Laat de operator pull_sales draaien vóór de taak cleanup.
Stel consolidate zo in dat die daarna draait, met de downstream-operator.
Laat push_data als laatste draaien met een van beide bitshift-operators.

Praktische interactieve oefening

Probeer deze oefening eens door deze voorbeeldcode in te vullen.

# 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 ____

Code bewerken en uitvoeren