expand ile birden çok endpoint işleme
Ekibin, zamanla değişen birden fazla API endpoint'inden veri çekiyor ve her biri için ayrı bir görevi sabit kodlamak, her endpoint eklendiğinde veya kaldırıldığında Dag'i düzenlemek anlamına geliyor. Bu egzersizde o katı hattı veri odaklı bir yapıya çevireceksin: expand() ile Airflow, çalışma anında endpoint listesini okuyup listedeki her öğe için bir görev örneği başlatır; böylece endpoint sayısı değiştikçe hat otomatik olarak uyum sağlar.
Bu egzersiz, kursun bir parçasıdır
Airflow ile Veri İş Hatları Oluşturma
Uygulamalı etkileşimli egzersiz
Teoriyi etkileşime dönüştürün, interaktif egzersizlerimizden biriyle
Egzersize başla