Zwracanie danych z funkcji TaskFlow
Twój zespół przechowuje konfigurację potoku w osobnym tasku, żeby można było z niej korzystać w kolejnych krokach. Centralizowanie konfiguracji w ten sposób to powszechna praktyka w środowisku produkcyjnym: jeden task definiuje ustawienia, a wszystkie pozostałe odczytują te same wartości zamiast wpisywać je na sztywno. Task get_config już zwraca słownik z konfiguracją, a run_pipeline jest gotowy, żeby z niego skorzystać.
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