Zacznij terazZacznij za darmo

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

Zobacz kurs

Interaktywne ćwiczenie praktyczne

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

Rozpocznij ćwiczenie