1. 学ぶ
    2. /
  2. コース
    3. /
  3. Pythonで学ぶ Apache Airflow 入門
Connected

演習

PythonOperator を使う

これまでに BashOperator を使っていくつかの Airflow タスクを実装しましたが、特定のタスクは Python で実装したほうが適していることに気づきました。ここでは、Airflow 内でファイルをダウンロードしてシステムに保存するタスクを実装します。

requests ライブラリはすでにインポート済みで、DAG process_sales_dag も定義済みです。

指示1 / 3

undefined XP
    1
    2
    3
  • URL と savepath の 2 つのパラメーターを取る pull_file 関数を定義します。
  • print() 関数と Python の f-string を使って、ログにメッセージを書き出します。