Overview

필자는 Amazon CloudWatch의 고유 기능만 사용하여 대시보드를 생성하여 프로젝트 모니터링을 진행해왔습니다. 하지만 점점 늘어나는 프로젝트마다 대시보드를 세팅하고 수시로 모니터링하는 것에 한계를 느끼게 되어, AWS SNS를 연결하여 Slack으로 알림을 받도록 모니터링 방법을 개선했습니다. (이제 스스로 대시보드를 들어가지 않아도 잠잘 때나 쉬고 있을 때나 Slack의 노예가 되어 프로젝트의 품질 유지에 힘쓸 수 있습니다! goooood!)

이번 글에서는 샘플 예제를 통해 수집되는 이벤트를 정의한 지표 기준으로 측정치를 초과할 경우 Slack으로 알림을 수신해보겠습니다.

이전 글 확인하기 : AWS 리소스를 효과적으로 모니터링하기

Lambda 함수를 실행하여 Slack 채널에 알림 전송

SNS 서비스에서 전송받은 알림에 대한 Lambda 함수를 실행하여 Slack 채널에 알림을 전송합니다.

1. 시스템 구성

2. SNS topic을 생성

3. CloudWatch Alarm 생성

CloudWatch 로그 그룹에서 지표 필터 추가하는 방법 및 Alarm 생성은 이전 글에서 설명하여 생략하겠습니다.

알림 받을 SNS (Simple Notification Service) 생성한 주제를 선택

4. Lambda 구현

4-1. CloudWatch Alarm 발생시 SNS에서 이벤트 전달 구조

{
    "Records": [
        {
            "EventSource": "aws:sns",
            "EventVersion": "1.0",
            "EventSubscriptionArn": "SNS Subscription Arn",
            "Sns": {
                "Type": "Notification",
                "MessageId": "1234-1234-1234-1234-1234",
                "TopicArn": "SNS Topic Arn",
                "Subject": "ALARM: \"[ERROR] Brandi-Lambda-Product-Info\" in Asia Pacific (Seoul)",
                "Message": "ALARM Detail Info",
                "Timestamp": "2020-03-21T12:01:18.533Z",
                "SignatureVersion": "1",
                "Signature": "",
                "SigningCertUrl": "",
                "UnsubscribeUrl": "",
                "MessageAttributes": {}
            }
        }
    ]
}

4-2. 전달받은 정보를 가공하여 슬랙 채널에 알림을 전송하는 Python 소스

# -*- coding: utf-8 -*-

import os
import json
import logging
logging.getLogger().setLevel(logging.INFO)

import requests


def lambda_handler(event, context):
    """
    에러로그 수집시 Slack 해당채널로 발송

    :param event: 수집 이벤트
    :return: dict
    """
    logging.info(event)

    records = event['Records'][0]

    dict_sns = records['Sns']
    subject = dict_sns.get('Subject')

    dict_message = json.loads(dict_sns.get('Message'))
    alarm_name = dict_message.get('AlarmName')
    alarm_description = dict_message.get('AlarmDescription')

    # 슬랙 발송 형식
    payload = {
        "text":subject,
        "attachments":[
            {
                "color":"#FF0000",
                "fields":[
                    {
                      "title":alarm_name,
                      "value":alarm_description,
                    }
                ]
            }
        ]
    }

    logging.info(payload)

    # 슬랙 채널 Incoming WebHooks Url
    webhook_url= "https://hooks.slack.com/services/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"

    requests.post(
        webhook_url, data=json.dumps(payload),
        headers={'Content-Type':'application/json'},
    )

    return {
        'statusCode': 200
    }

예제 소스를 Lambda에 저장 후 실행시켜보면 에러가 발생합니다. 에러를 해결하기 위해선 아래 2가지를 추가해야 합니다. 이에 대한 설명은 이 글에서는 생략하겠습니다.

- Slack App Incoming WebHooks 추가 - Python requests module 추가

4-3. “CloudWatch-Alarm-Slack-dev” Lambda 생성

5. SNS Topic (slack-notice)에 Subscriptions 추가

생성한 “CloudWatch-Alarm-Slack-dev” Lambda로 연결

6. Slack 발송 확인

그럼 이제 알림을 잘 발송되는지 Lambda 함수를 실행시켜 에러를 발생시켜 보겠습니다.

이와 같은 방법으로 약 3개월간 프로젝트들을 모니터링하고 있던 와중, AWS에서 대화형 서비스 기반으로 모니터링 기능을 제공하는 ‘Chatbot’을 베타 오픈했다는 소식을 들었습니다. 과연 AWS Chatbot에서 더 좋은 기능을 사용할 수 있을까 기대를 가지며 서비스 테스트를 했습니다.

2. AWS Chatbot

AWS Chatbot은 Slack 채널 및 Amazon Chime을 통해 AWS 리소스를 쉽게 모니터링하고 지표를 감시하여 측정치에 대한 알림을 수신하고 빠르게 이벤트에 대응할 수 있게 도와주는 대화형 서비스입니다.

기능으로 알림 수신, 진단 정보 검색 등이 있으며 사전 정의된 AWS 정책 템플릿을 선택할 수 있어 보다 빠르게 서비스 이용이 가능합니다.

AWS Chatbot은 현재 베타 버전으로 제공됩니다.

1. 시스템 구성

이 글에서는 Slack 채널을 통해 상호 작용하도록 구성하겠습니다.