Nieprawidłowe zmienne
Twój szef prosi cię o zbadanie problemu, w którym raport sprzedaży nie jest generowany. Niedawno wdrożyłeś zmienne w jednym ze swoich DAG-ów (process_sales), który przetwarza różne dane sprzedażowe i generuje raport, o którym mówi szef. Analizując logi, zauważasz, że plik nie jest zapisywany we właściwym miejscu, lecz w domyślnej lokalizacji.
Zadanie przetwarzające raport wykonuje następujące operacje:
@task()
def parse_file():
output_path = Variable.get("Output_Path", default="/home")
output_fn = Variable.get("Output_Filename", default="sales_report.pdf")
save_file("{output_path}/{output_fn}")
Plik powinien być zapisany pod ścieżką /data/sales/sales_report.pdf.
Spróbuj uruchomić polecenie airflow dags test process_sales, aby wyświetlić dane wyjściowe z logów.
Która z poniższych odpowiedzi wskazuje przyczynę błędu i sposób jego naprawy?
To ćwiczenie jest częścią kursu
Wprowadzenie do Apache Airflow w Pythonie
Interaktywne ćwiczenie praktyczne
Przekształć teorię w praktykę dzięki jednemu z naszych interaktywnych ćwiczeń
Rozpocznij ćwiczenie