Atât DAG-ul sales_producer, cât și sales_consumer din exercițiile anterioare au fost încărcate în interfața Airflow. Producătorul scrie date de vânzări și actualizează Asset-ul s3://data-lake/sales/daily.csv. Consumatorul este planificat pe baza acelui Asset.

Urmează acești pași:

În vizualizarea DAG-urilor, găsește atât sales_producer, cât și sales_consumer și activează-le folosind butonul de comutare.
Declanșează sales_producer făcând clic pe iconița de redare, selectând Single Run, apoi Trigger.
Așteaptă finalizarea rulării producătorului (toate task-urile verzi).
Verifică dacă sales_consumer a fost declanșat automat, fără să fi dat clic pe nimic.

După ce rularea sales_producer se finalizează, ce se întâmplă cu sales_consumer?

Planificarea bazată pe date cu Assets

Create Your Free Account