Zacznij terazZacznij za darmo

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

Zobacz kurs

Interaktywne ćwiczenie praktyczne

Przekształć teorię w praktykę dzięki jednemu z naszych interaktywnych ćwiczeń

Rozpocznij ćwiczenie