概要 Airflowのタスクが失敗した際にSlackにメッセージを送るようにする。 トークン等はVariablesに保存して扱う。 バージョン情報 Python 3.6.7 apache-airflow==1.10.1 slackclient==1.3.0 導入 slackclientが必要になるので入れておく。 $ pip install slackclient Variablesの設定 下記あたりを参考にSlackのトークンを取得しておく。 https://api.slack.com/incoming-webhooks AirflowのWebサーバーを立ち上げる $ airflow webserver -p8080 Admin → Variablesを選択。 CreateタブからVariableを生成する。 公式ドキュメントによるとVariableのキー名がパスワードっぽいものについて
![Airflowでタスク失敗時にSlackへメッセージを送る - iMind Developers Blog](https://cdn-ak-scissors.b.st-hatena.com/image/square/1e7341da7582f2735420d6f715fca9480ede0441/height=288;version=1;width=512/https%3A%2F%2Fcdn-ak.f.st-hatena.com%2Fimages%2Ffotolife%2Fi%2Fimind%2F20181215%2F20181215180833.png)