Planowanie konsumenckiego DAG-a na podstawie zasobu
Skoro producent danych sprzedażowych sygnalizuje gotowość danych, czas skonfigurować DAG-a konsumenta, który uruchomi się automatycznie po każdej aktualizacji zasobu. Zdefiniuj ten sam zasób (s3://data-lake/sales/daily.csv) i ustaw harmonogram konsumenta tak, aby Airflow uruchamiał DAG-a po każdej aktualizacji.
To ćwiczenie jest częścią kursu
Budowanie potoków danych z Airflow
Interaktywne ćwiczenie praktyczne
Przekształć teorię w praktykę dzięki jednemu z naszych interaktywnych ćwiczeń
Rozpocznij ćwiczenie