Začněte nyníZačněte zdarma

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:

  1. V přehledu DAGů najdi sales_producer i sales_consumer a aktivuj je pomocí přepínače.
  2. Spusť sales_producer kliknutím na ikonu play, vyber Single Run a pak Trigger.
  3. Počkej, až producerův běh skončí (všechny tasky jsou zelené).
  4. Zkontroluj, jestli se sales_consumer spustil 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

Zobrazit kurz

Interaktivní praktické cvičení

Proměňte teorii v praxi s jedním z našich interaktivních cvičení

Začít cvičení