슬랙 링크

• 새로운 워크스페이스를 생성합니다.
• monitoring 채널을 생성해봅니다.

슬랙 apps

• Create a New app 클릭
• 앱을 만들고, Incoming Web Hooks를 활성화합니다.

• 활성화 한 뒤에, Add new webhook to Workspace를 클릭해서, 워크스페이스에 앱을 연결할 수 있도록 합니다.
  

• 그리고 생성된 webHook URL을 활용합니다.

https://hooks.slack.com/services/~/~/~

Airflow Script

---

• connection
  

아까 생성된 URL을 통해서, 해당 URL로 connection을 설정합니다.
기본적으로 host는 https://hooks.slack.com/services
extra에 그 뒷 부분을, { "webhook_token" : "url 나머지 부분" } 적어줍니다.

from airflow.providers.slack.operators.slack_webhook import SlackWebhookOperator

def _get_message() -> str:
    return "Hi from forex_data_pipeline"
    
send_slack_notification = SlackWebhookOperator(
        task_id="send_slack_notification",
        http_conn_id="slack_conn",
        message=_get_message(),
        channel="#monitoring",
    )

task를 테스트 해봅니다.