Definisci l'ordine dei BashOperator

Ora che hai imparato a usare gli operatori di bitshift, è il momento di modificare il tuo workflow per includere uno step di pull e l'ordinamento dei task. Hai tre componenti attualmente definiti: cleanup, consolidate e push_data.

Il DAG analytics_dag è disponibile come prima e il BashOperator è già importato.

Questo esercizio fa parte del corso

Introduzione ad Apache Airflow in Python

Visualizza il corso

Istruzioni dell'esercizio

Definisci un BashOperator chiamato pull_sales con il comando bash wget https://salestracking/latestinfo?json.
Imposta l'operatore pull_sales per essere eseguito prima del task cleanup.
Configura consolidate per essere eseguito dopo, usando l'operatore downstream.
Imposta push_data per essere eseguito per ultimo usando uno qualsiasi dei due operatori di bitshift.

Esercizio pratico interattivo

Prova a risolvere questo esercizio completando il codice di esempio.

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

Modifica ed esegui il codice