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

Connected

演習

コールバック関数の実装

あなたは最近、チームが作成した DAG に失敗時のコールバックを追加する担当になりました。まずは、sales_etl_dag が失敗したときに監査ログへメッセージを書き込む、シンプルな失敗コールバックを追加しましょう。

dag と task オブジェクトはすでにインポートされており、get_sales_data タスクと process_sales_data タスクも作成済みです。

指示

100 XP
  • alert_on_failure という名前のコールバック関数を作成してください。
  • Airflow が渡すすべてのオブジェクトを受け取れるように関数を定義してください。
  • alert_on_failure 関数を使って、失敗時のコールバックを指定してください。