Asset-gebaseerde planning in actie zien
Zowel de sales_producer- als de sales_consumer-Dags uit de vorige oefeningen zijn geladen in de Airflow-UI. De producer schrijft verkoopdata weg en werkt de asset s3://data-lake/sales/daily.csv bij. De consumer is op die asset ingepland.
Volg deze stappen:
- Zoek in de Dags-weergave zowel
sales_produceralssales_consumeren activeer ze met de schakelaar. - Trigger
sales_producerdoor op het afspeelicoon te klikken, kies Single Run, en vervolgens Trigger. - Wacht tot de run van de producer is voltooid (alle taken groen).
- Controleer of
sales_consumerautomatisch is getriggerd zonder dat jij iets hebt geklikt.
Wat gebeurt er met sales_consumer nadat de run van sales_producer is voltooid?
Deze oefening maakt deel uit van de cursus
Data-pijplijnen bouwen met Airflow
Interactieve oefening met praktijkervaring
Zet theorie om in actie met een van onze interactieve oefeningen
Begin oefening