Kom igångKom igång gratis

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:

  1. I DAG-vyn hittar du både sales_producer och sales_consumer – aktivera dem med växlingsknappen.
  2. Trigga sales_producer genom att klicka på uppspelningsikonen, välj Single Run och sedan Trigger.
  3. Vänta tills producentkörningen är klar (alla uppgifter är gröna).
  4. Kontrollera om sales_consumer triggas 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

Visa kurs

Interaktiv övning med praktiskt arbete

Gör teori till handling med en av våra interaktiva övningar

Starta övningen