Einfache Serverüberwachung mit AWS Lambda (Python) und Ergebnisbenachrichtigung mit Slack

Was ich erreichen wollte

• Als einfacher Monitor des Betriebssystemservers möchte ich regelmäßig einen HTTP-Zugriff durchführen und das Ergebnis überprüfen.
• Ich möchte ohne Server laufen.
• Da die IP, die auf den Zielserver zugreift, eingeschränkt ist, muss die Überwachungsquelle eine feste IP haben. ――Ich möchte, dass Sie vollständig automatisieren und nur über die Überwachungsergebnisse informiert werden.

Was wurde endlich erreicht

• Gesamtbild

• Platzieren Sie die überwachten Serverdaten in "S3".

• Das Datenformat ist wie folgt.

   ```json:servers.json
   {
       "servers": [
           {"name": "Google", "url": "http://www.google.co.jp"},
           {"name": "Yahoo", "url": "http://www.yahoo.co.jp"}
       ]
   }
   ```
  

• Lesen Sie die obigen Daten von AWS Lambda (Python) und stellen Sie HTTP-Zugriff auf jeden Server.

• Benachrichtigen Sie "Slack" über das Überwachungsergebnis.

• Führen Sie die obigen Schritte regelmäßig mit "CloudWatch Events --Schedule" aus.

Details einstellen

VPC-Einstellungen

――Siehe, was du erreichen wolltest, da es unten vollständig behandelt wurde. - https://www.joyzo.co.jp/blog/2325

IAM-Einstellungen

--Wenn Sie "Lambda" erstellen, wählen Sie "Einfache Microservice-Berechtigungen" als Rollenvorlage aus.

• Fügen Sie die Richtlinie "AmazonS3ReadOnlyAccess" hinzu, um auf "S3" zuzugreifen.
• Fügen Sie die Richtlinie von "AWSLambdaVPCAccessExecutionRole" hinzu, um "Lambda" auf "VPC" auszuführen.

CloudWatch-Ereignisse - Zeitplaneinstellungen

• Tutorial: Schedule Lambda Functions Using CloudWatch Events - Amazon CloudWatch Events

Slack

• Beziehen Sie sich auf Eingehende Webhooks, um die URL für die Benachrichtigung an "Slack" zu erhalten.

AWS Lambda(Python)

• Bei der Fehlerbehandlung gibt es Verbesserungspotenzial.

lambda_function.py

import json
import requests
import boto3

BUCKET_NAME = 'xxxxxxxxxx'
OBJECT_NAME = 'xxxxxxxxxx/servers.json'
SLACK_POST_URL = 'https://hooks.slack.com/services/xxxxxxxxxx/xxxxxxxxxx/xxxxxxxxxxxxxxxxxxxx'

def lambda_handler(event, context):
    json_data = __getServers()
    __check_server(json_data)

def __getServers():
   s3 = boto3.resource('s3')
   obj = s3.Object(BUCKET_NAME, OBJECT_NAME)
   response = obj.get()
   body = response['Body'].read()
   return body.decode('utf-8')

def __check_server(json_data):
    data = json.loads(json_data)
    servers = data['servers']

    has_error = False

    for server in servers:
        name = server['name']
        url = server['url']
        print("Check: " + name)

        try:
            r = requests.get(url)
            if r.status_code != 200:
                __send_error_message(name, url)
                has_error = True
        except requests.exceptions.RequestException as e:
            __send_request_error_message(name, url)
            has_error = True

    if has_error == False:
        __send_success_message()

def __send_error_message(name, url):
    payload = {
        "text": name + '\n' + url + '\n' + '*ERROR!*',
        "icon_emoji": ":x:"
    }
    __send_message(payload)

def __send_request_error_message(name, url):
    payload = {
        "text": name + '\n' + url + '\n' + '*Request Error!*',
        "icon_emoji": ":warning:"
    }
    __send_message(payload)

def __send_success_message():
    payload = {
        "text": "All Servers OK!",
        "icon_emoji": ":o:"
    }
    __send_message(payload)

def __send_message(payload):
    try:
        return requests.post(SLACK_POST_URL, json=payload)
    except requests.exceptions.RequestException as e:
        return None

Vorsichtsmaßnahmen beim Einstellen von AWS Lambda (Python)

• Platzieren Sie die Bibliothek im selben Verzeichnis wie der Quellcode.

pip install requests -t .

• Sammeln Sie den Quellcode und die Bibliothek und platzieren Sie sie in einer Zip.

zip -r lambda_function.zip *

• Programming Model for Authoring Lambda Functions in Python - AWS Lambda

Verschiedene Gefühle

――Wenn es möglich ist, VPC in AWS Lambda einzustellen, ist es möglich, Lambda mit einer festen IP-Adresse als Datenquelle auszuführen, sodass die Verwendung erweitert wurde. ――Die Zusammenarbeit mit Slack ist als bequemes Benachrichtigungsziel zu einfach und bequem.

• Ich habe auch eine Methode ausprobiert, bei der der Inhalt von servers.json in den Body gepackt und über ein API-Gateway ausgeführt wird, das durch HTTP-POST-Kommunikation ausgelöst wird. Letztendlich ist das aktuelle Formular jedoch einfach regelmäßig auszuführen.