Reihenfolge von BashOperators festlegen

Nachdem du die Bitshift-Operatoren kennengelernt hast, ist es Zeit, deinen Workflow anzupassen: Füge einen Pull-Schritt hinzu und lege die Aufgabenreihenfolge fest. Es gibt drei bereits definierte Komponenten: cleanup, consolidate und push_data.

Der DAG analytics_dag ist wie zuvor verfügbar, und der BashOperator ist bereits importiert.

Diese Übung ist Teil des Kurses

Einführung in Apache Airflow mit Python

Kurs anzeigen

Anleitung zur Übung

Definiere einen BashOperator namens pull_sales mit dem Bash-Befehl wget https://salestracking/latestinfo?json.
Setze den Operator pull_sales so, dass er vor der Aufgabe cleanup läuft.
Konfiguriere consolidate so, dass es als Nächstes läuft, und nutze dafür den Downstream-Operator.
Setze push_data so, dass es zuletzt läuft, und verwende dafür einen der Bitshift-Operatoren.

Interaktive Übung

Vervollständige den Beispielcode, um diese Übung erfolgreich abzuschließen.

# 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 bearbeiten und ausführen