Asset-based scheduling v praxi
Do Airflow UI byly načteny oba DAGy z předchozích cvičení: sales_producer i sales_consumer. Producer zapisuje prodejní data a aktualizuje asset s3://data-lake/sales/daily.csv. Consumer je naplánován na základě tohoto assetu.
Postupuj takto:
- V přehledu DAGů najdi
sales_producerisales_consumera aktivuj je pomocí přepínače. - Spusť
sales_producerkliknutím na ikonu play, vyber Single Run a pak Trigger. - Počkej, až producerův běh skončí (všechny tasky jsou zelené).
- Zkontroluj, jestli se
sales_consumerspustil automaticky – bez toho, aniž bys na cokoli klikl/a.
Co se stane s sales_consumer po dokončení běhu sales_producer?
Toto cvičení je součástí kurzu
Tvorba datových pipeline s Airflow
Interaktivní praktické cvičení
Proměňte teorii v praxi s jedním z našich interaktivních cvičení
Začít cvičení