■ はじめに
色々と Airflow を触っていると 設定値を保持する仕組み・機構が揃っているので、 その内の Connection について扱う
Apache Airflow ~ Variable ~
https://dk521123.hatenablog.com/entry/2023/12/17/000000
目次
【0】コネクションの保持 - Connection 【1】Web UIからデータの追加方法 【2】設定例 【3】サンプル
【0】コネクションの保持 - Connection
* DBの接続情報 や Slack webhook用の接続情報を保持できる仕組み * AWS Glue でいう Glue connectionみたいなもの。
【1】Web UIからデータの追加方法
a) 値を追加
[1] Airflow の Web UI ページにアクセスし、[Admin]-[Connections]を選択 [2] 「+ (Add a new record)」押下 [3] Conn id/Conn Typeなど にそれぞれ入力し「Save」ボタン押下
【2】設定例
例1:SlackのWebhook
Slack の Webhook URLが、 https://hooks.slack.com/services/A00000000/B111111/XXXXXXXXXXXXXXXXXXXXXXXX の場合は、設定手順は以下の通り。 [1] 上記の「a) 値を追加」の[1]~[2] を実行 [2] 以下をそれぞれ入力し「Save」ボタン押下 + Conn id : 任意の名前 (今回は「slack_webhook_demo」) + Conn Type : HTTP + Host : https://hooks.slack.com/services + Extra : {"webhook_token":"/A00000000/B111111/XXXXXXXXXXXXXXXXXXXXXXXX"}
【3】サンプル
SlackWebhookOperatorを使ってSlackへ通知
* 以下の関連記事を参照のこと。
https://dk521123.hatenablog.com/entry/2021/10/09/000000
参考文献
https://blog.imind.jp/entry/2019/02/08/170332
https://k11i.biz/blog/2019/04/23/slack-notification-airflow-1-10-3/
関連記事
Apache Airflow ~ 基礎知識編 ~
https://dk521123.hatenablog.com/entry/2021/09/28/135510
Apache Airflow ~ 環境構築編 ~
https://dk521123.hatenablog.com/entry/2021/07/18/004531
Apache Airflow ~ 環境構築 / Docker 編 ~
https://dk521123.hatenablog.com/entry/2021/10/11/134840
Apache Airflow ~ 入門編 ~
https://dk521123.hatenablog.com/entry/2021/07/24/233012
Apache Airflow ~ 基本編 ~
https://dk521123.hatenablog.com/entry/2021/07/28/234319
Apache Airflow ~ CLI ~
https://dk521123.hatenablog.com/entry/2021/10/21/130702
Apache Airflow ~ Variable ~
https://dk521123.hatenablog.com/entry/2023/12/17/000000
Apache Airflow ~ リトライ ~
https://dk521123.hatenablog.com/entry/2021/10/10/000000
Apache Airflow ~ タイムアウト ~
https://dk521123.hatenablog.com/entry/2021/10/12/000000
Apache Airflow ~ あれこれ編 ~
https://dk521123.hatenablog.com/entry/2021/09/30/163020
Apache Airflow ~ 通知あれこれ編 ~
https://dk521123.hatenablog.com/entry/2021/10/06/141323
Apache Airflow ~ 通知サンプル編 ~
https://dk521123.hatenablog.com/entry/2021/10/09/000000
Apache Airflow に関するトラブル
https://dk521123.hatenablog.com/entry/2021/10/03/000000
MWAA ~ 入門編 ~
https://dk521123.hatenablog.com/entry/2021/09/29/131101