Naplánování consumer DAGu na Asset
Teď, když producer DAG pro prodejní data signalizuje, že jsou data připravená, potřebuješ consumer DAG, který se spustí automaticky při každé aktualizaci assetu. Definuj stejný asset (s3://data-lake/sales/daily.csv) a nastav na něj plán consumer DAGu, aby ho Airflow spustil po každé aktualizaci.
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í