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:
- Suche in der Dags-Ansicht nach
sales_producerundsales_consumerund aktiviere beide über den Kippschalter. - Trigger
sales_producer, indem du auf das Play-Symbol klickst, Single Run auswählst und dann Trigger. - Warte, bis der Producer-Lauf abgeschlossen ist (alle Tasks grün).
- Prüfe, ob
sales_consumerautomatisch 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>Interaktive praktische Übung
Verwandle Theorie mit einer unserer interaktiven Übungen in die Praxis
Übung starten