ПочатиПочніть безкоштовно

Змінні налаштовані не зовсім правильно

Ваш керівник просить розібратися, чому не генерується звіт про продажі. Ви нещодавно додали змінні в один із ваших Dag'ів (process_sales), який обробляє різні дані про продажі та записує той самий звіт, про який питає керівник. Переглядаючи журнали, ви помічаєте, що файл записується не в потрібне місце, а в типове.

Завдання, що обробляє звіт, робить таке:

@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}")

Файл має зберігатися як /data/sales/sales_report.pdf.

Спробуйте виконати команду airflow dags test process_sales, щоб переглянути вивід журналу.

Що з наведеного є причиною помилки і як це виправити?

Ця вправа є частиною курсу

Вступ до Apache Airflow на Python

Переглянути курс

Практична інтерактивна вправа

Перетворіть теорію на практику за допомогою однієї з наших інтерактивних вправ

Почати вправу