1. 학습
    2. /
  2. 강의
    3. /
  3. Pythonで学ぶ Apache Airflow 入門
Connected

연습 문제

EmailOperator と依存関係

ワークフロー用の PythonOperator を定義できたので、ワークフロー完了時にパース済みの JSON ファイルをメールで送ってほしいとマネージャーから依頼がありました。これまでのタスクは引き続き定義されており、DAG process_sales_dag も設定済みです。なお、このタスクは旧来の DAG 定義方法を使用しており、すでに追加されています。

지침

100 XP
  • メール送信用のクラスをインポートします。
  • Operator を定義し、適切な引数（to、subject、files）を指定します。
  • タスクの実行順序を設定し、順番に動くようにします（ファイルを取得し、ファイルをパースし、その後マネージャーにメール送信）。