LoslegenKostenlos starten

Asset-basierte Planung in Aktion sehen

Sowohl die Dags sales_producer als auch sales_consumer aus den vorherigen Übungen wurden in die Airflow-UI geladen. Der Producer schreibt Verkaufsdaten und aktualisiert das Asset s3://data-lake/sales/daily.csv. Der Consumer wird auf Basis dieses Assets geplant.

Gehe so vor:

  1. Suche in der Dags-Ansicht nach sales_producer und sales_consumer und aktiviere beide über den Kippschalter.
  2. Trigger sales_producer, indem du auf das Play-Symbol klickst, Single Run auswählst und dann Trigger.
  3. Warte, bis der Producer-Lauf abgeschlossen ist (alle Tasks grün).
  4. Prüfe, ob sales_consumer automatisch ausgelöst wurde, ohne dass du etwas angeklickt hast.

Was passiert mit sales_consumer, nachdem der Lauf von sales_producer abgeschlossen ist?

Diese Übung ist Teil des Kurses

<Kurs>Data-Pipelines mit Airflow aufbauen</Kurs>
Kurs ansehen

Interaktive praktische Übung

Verwandle Theorie mit einer unserer interaktiven Übungen in die Praxis

Übung starten