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

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

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í