Amazon CloudWatchメトリクスのグラフをSlackで参照してみた

import boto3
import json
import requests
import xmltodict
import urllib.parse
import datetime

def alert(event, context):

    # 時間設定
    today_time = datetime.date.today()
    yesterday_time = today_time - datetime.timedelta(days = 1)

    ## parse_data関数を呼び出す
    result_today_datas = parse_data(today_time.strftime("%Y%m%d"))
    result_yesterday_datas = parse_data(yesterday_time.strftime("%Y%m%d"))

    # S3にファイルをアップロード。（省略してもOK。ただのデータバックアップのため）
    s3 = boto3.resource('s3')
    bucket_name = "corona-log"
    file_name = "%s.json" % (today_time.strftime("%Y%m%d"))    
    obj_name = s3.Object(bucket_name, file_name)    
    obj_name.put(Body=json.dumps(result_today_datas))

    message_text = ""   #Incoming Webhooksに送信するテキスト

    for i in range(0, len(result_today_datas)): #データの加工
        region = result_today_datas[i]["region"]
        today_confirmed = result_today_datas[i]["confirmed"]
        inc_confirmed = int(result_today_datas[i]["confirmed"]) - int(result_yesterday_datas[i]["confirmed"])

        add_message = "*%s : %s名* （前日と比べ%s" % (region, today_confirmed, abs(inc_confirmed)) + ("名増加）" if inc_confirmed >=0 else "名減少）")
        if region == "Total":
            line = "========================================="
            message_text = (line + "\n").join([message_text, add_message])
        else:
            message_text = "\n".join([message_text, add_message])

    # Incoming Webhooksの設定  
    url = "<Incoming WebhooksのURL>"
    payload = {
        "attachments": [{
            "pretext" : "私が韓国の新型コロナウイルス感染者発生状況を告げに来た!! (%s)" % str(today_time),
            "color" : "#0099A6",
            "text" : message_text
        }]
    }
    headers = {
        "Content-Type" : "application/json; charset=UTF-8"
    }

    # Incoming Webhooksにデータ送信
    response = requests.post(url, data=json.dumps(payload), headers = headers)

    return response


def parse_Data(time):

    # Open APIのリクエストURL作成
    api_url = "http://openapi.data.go.kr/openapi/service/rest/Covid19/getCovid19SidoInfStateJson"
    queryParams = {
        "ServiceKey" :  "<Open APIの認証キー>",
        "startCreateDt" : time,
        "endCreateDt" : time
        }
    query_string = urllib.parse.urlencode(queryParams)
    url = api_url + "?" + query_string

    # 分析しやすくするため、JSON形式に変換
    raw_data_result = requests.get(url).text
    dict_data = xmltodict.parse(raw_data_result)
    json_datas = json.loads(json.dumps(dict_data))

    result_datas = []

    for json_data in json_datas["response"]["body"]["items"]["item"]:

        data = {}
        data["region"] = json_data["gubunEn"]   #地域
        data["confirmed"] = json_data["incDec"] #感染者数

        result_datas.append(data)

    store_as_Metric(result_datas)

    return result_datas

def store_as_Metric(result_datas):

    cloudwatch = boto3.client('cloudwatch')

    # CloudWatchにカスタムメトリクスとしてデータを格納
    for data in result_datas:
        response = cloudwatch.put_metric_data(
            Namespace='corona_alert',
            MetricData = [
                {
                    'MetricName' : "confirmed_cases",
                    'Dimensions' : [
                        {
                            'Name' : 'region',
                            'Value' : data["region"]
                        },
                    ],
                    'Value' : int(data["confirmed"]),
                    'Unit' : 'None'
                },
            ]
        )

def store_as_Metric(result_datas):

    cloudwatch = boto3.client('cloudwatch')

    # CloudWatchにカスタムメトリクスとしてデータを格納
    for data in result_datas:
        response = cloudwatch.put_metric_data(
            Namespace='corona_alert',
            MetricData = [
                {
                    'MetricName' : "confirmed_cases",
                    'Dimensions' : [
                        {
                            'Name' : 'region',
                            'Value' : data["region"]
                        },
                    ],
                    'Value' : int(data["confirmed"]),
                    'Unit' : 'None'
                },
            ]
        )

@aws cloudwatch get-metric-widget-image --region <region> --metric-widget <string>