始める無料で始める

変数の設定に問題あり

上司から、売上レポートが生成されていないという問題を調査するよう依頼されました。最近、各種の売上データを処理して上司が求めているレポートを出力する 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 コマンドを実行して、ログ出力を確認してみましょう。

エラーの原因と修正方法として正しいものはどれですか?

この演習はコースの一部です

Python で学ぶ Apache Airflow 入門

コースを見る

実践的なインタラクティブ演習

理論を実践に変える、インタラクティブな演習のひとつをお試しください

演習を開始する