Tillgångsbaserad schemaläggning i praktiken
Både sales_producer- och sales_consumer-DAG:arna från tidigare övningar har laddats in i Airflow-gränssnittet. Producenten skriver försäljningsdata och uppdaterar tillgången s3://data-lake/sales/daily.csv. Konsumenten är schemalagd på den tillgången.
Följ dessa steg:
- I DAG-vyn hittar du både
sales_producerochsales_consumer– aktivera dem med växlingsknappen. - Trigga
sales_producergenom att klicka på uppspelningsikonen, välj Single Run och sedan Trigger. - Vänta tills producentkörningen är klar (alla uppgifter är gröna).
- Kontrollera om
sales_consumertriggas automatiskt utan att du behöver klicka på något.
Vad händer med sales_consumer när sales_producer-körningen är klar?
Den här övningen är en del av kursen
Bygg datapipelines med Airflow
Interaktiv övning med praktiskt arbete
Gör teori till handling med en av våra interaktiva övningar
Starta övningen