AWS Lambdaを監視してDiscordに通知する

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

{
   "Records":[
      {
         "EventSource":"aws:sns",
         "EventVersion":"1.0",
         "EventSubscriptionArn":"arn:aws:sns:ap-northeast-1:<省略>",
         "Sns":{
            "Type":"Notification",
            "MessageId":"<省略　なんかID>",
            "TopicArn":"arn:aws:sns:ap-northeast-1:<省略>",
            "Subject":"ALARM: \"compile error\" in Asia Pacific (Tokyo)",
            "Message":"{<省略 (次に詳細を記載)>}",
            "Timestamp":"2021-02-15T15:53:14.501Z",
            "SignatureVersion":"1",
            "Signature":"<省略 なんか証明>",
            "SigningCertUrl":"<省略 なんかpem>",
            "UnsubscribeUrl":"https://sns.ap-northeast-1.amazonaws.com/?Action=Unsubscribe<省略>",
            "MessageAttributes":{
               
            }
         }
      }
   ]
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

{
    "AlarmName": "アラーム名",
    "AlarmDescription": "アラーム詳細",
    "AWSAccountId": "アカウントID",
    "NewStateValue": "ALARM",
    "NewStateReason": "Threshold Crossed: 1 out of the last 1 datapoints [1.0 (15/02/21 14:52:00)] was greater than or equal to the threshold (1.0) (minimum 1 datapoint for OK -> ALARM transition).",
    "StateChangeTime": "2021-02-15T14:57:14.419+0000",
    "Region": "Asia Pacific (Tokyo)",
    "AlarmArn": "アラームのARN",
    "OldStateValue": "INSUFFICIENT_DATA",
    "Trigger": {
        "MetricName": "Errors",
        "Namespace": "AWS/Lambda",
        "StatisticType": "Statistic",
        "Statistic": "MAXIMUM",
        "Unit": null,
        "Dimensions": [
            {
                "value": "Lambda関数名",
                "name": "FunctionName"
            }
        ],
        "Period": 300,
        "EvaluationPeriods": 1,
        "ComparisonOperator": "GreaterThanOrEqualToThreshold",
        "Threshold": 1,
        "TreatMissingData": "- TreatMissingData:                    ignore",
        "EvaluateLowSampleCountPercentile": ""
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

from __future__ import print_function
import urllib.request
import json

print('Loading function')

# === :: 設定項目 :: ===========================
endpoint = "https://あなたのdiscordのwebhookURL"
accountName = 'AWSの組織名'
accountImage = 'なんかアイコンのURL'
# ==============================================

def post(url, data, headers ={}):
    req = urllib.request.Request(url,
                                 data=json.dumps(data).encode('utf-8'),
                                 headers=headers,
                                 method='POST')
    return urllib.request.urlopen(req)

def lambda_handler(event, context):
    message = json.loads(event['Records'][0]['Sns']['Message'])
    fields = [
        {'name': 'メトリック名', 'value': message['Trigger']['MetricName'], 'inline': True},
        {'name': '条件', 'value': message['Trigger']['ComparisonOperator'], 'inline': True}
    ]
    fields.extend([{'name': elem['name'], 'value': elem['value']} for elem in message['Trigger']['Dimensions']])
    data = {
        'embeds': [
            {
                'title': 'アラーム発生: ' + message['AlarmName'],
                'description': message['AlarmDescription'],
                'color': 0xFF0000,
                'timestamp': message['StateChangeTime'],
                'fields': fields,
                'author': {
                    'name': accountName,
                    'icon_url': accountImage
                }
            }
        ]
    }
    
    post(endpoint, data=data, headers={'Content-Type': 'application/json', "User-Agent": "curl/7.64.1"})
    
    return {
        'statusCode': 200
    }