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_producer och sales_consumer – aktivera dem med växlingsknappen.
Trigga sales_producer genom 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_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?

Arbetsflöden med mänsklig kontroll

Create Your Free Account