【Airflow】Apache Airflow ~ Connection ~

■ はじめに

 色々と 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