Étant donné que le système de surveillance des opérations est géré de manière centralisée par Zabbix, je voulais informer Zabbix Server de l'erreur d'exécution de la fonction AWS Lambda, alors je l'ai essayé.
Paramètres> Hôtes> Créer un hôte
--Nom de l'hôte: lambda-trapper --Créer un nouveau groupe: Lambda
[Paramètres]> [Hôtes]> [Articles]> [Créer un élément] de lambda-trapper dans la liste d'hôtes
--Nom: ErrorLog --Type: Trappeur Zabbix --Clé: journal des erreurs --Type de données: chaîne
[Settings]> [Hosts]> [Trigger]> [Create Trigger] de lambda-trapper dans la liste d'hôtes
--Name: erreur d'exécution de la fonction Lambda --Expression conditionnelle: {lambda-trapper: errorlog.str (exemple)} = 0 et {lambda-trapper: errorlog.nodata (30)} = 0 --Continuer à générer des événements d'échec: On
Ajoutez le traitement de journalisation à la fonction AWS Lambda existante (la fonction dont vous souhaitez intercepter les erreurs d'exécution) comme suit.
lambda_function.py
# (réduction)
import logging
# (réduction)
#Initialisation de l'enregistreur
logger = logging.getLogger()
logger.setLevel(logging.INFO)
def lambda_handler(event, context):
try:
# (réduction)
logger.info("Execution succeeded.")
except Exception, e:
logger.error(e)
raise(e) #Décrit lorsque vous souhaitez enregistrer la trace de la pile Python dans le journal CloudWatch
En ajoutant le processus de journalisation, le résultat de l'exécution de la fonction AWS Lambda sera envoyé à CloudWatch. Exemple de journal de fin normal)
[INFO] 2017-03-01T08:18:31.149Z a7afba37-fe57-11e6-a428-371557c5f4e7 Execution succeeded.
Exemple de journal de terminaison anormale)
[ERROR] 2017-03-01T09:38:37.966Z d8c7ede3-fe62-11e6-b58a-7dce3a95f14a cannot concatenate 'str' and 'int' objects
Créez une nouvelle fonction AWS Lambda pour envoyer Zabbix expulsé de CloudWatch. D'ailleurs, le module Zabbix Sender est publié dans "here". J'ai détourné le code.
cwl-to-zabbix
handler.py
import os
import json
from StringIO import StringIO
import base64
import gzip
from ZabbixSender import ZabbixSender
import logging
ZBX_SERVER = os.environ['ZBX_SERVER']
ZBX_HOST = os.environ['ZBX_HOST']
ZBX_ITEM = os.environ['ZBX_ITEM']
logger = logging.getLogger()
logger.setLevel(logging.INFO)
def sender(event, context):
log_b64 = event['awslogs']['data']
log_gz = StringIO(base64.b64decode(log_b64))
jsonData = json.load(gzip.GzipFile(fileobj=log_gz, mode='rb'))
status = jsonData['logEvents'][0]['extractedFields']['status']
message = jsonData['logEvents'][0]['extractedFields']['event']
timestamp = int(jsonData['logEvents'][0]['timestamp']) / 1000
func = os.path.basename(jsonData['logGroup'])
try:
if status == "ERROR":
errlog = func + ': ' + message
sender = ZabbixSender(ZBX_SERVER)
sender.add(ZBX_HOST, ZBX_ITEM, errlog, timestamp)
sender.send()
logger.info("Execution Succeeded.")
except Exception, e:
logger.error(e)
raise(e)
ZabbixSender.py
import socket
import struct
import time
import json
class ZabbixSender:
log = True
def __init__(self, host='127.0.0.1', port=10051):
self.address = (host, port)
self.data = []
def __log(self, log):
if self.log: print log
def __connect(self):
self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
try:
self.sock.connect(self.address)
except:
raise Exception("Can't connect server.")
def __close(self):
self.sock.close()
def __pack(self, request):
string = json.dumps(request)
header = struct.pack('<4sBQ', 'ZBXD', 1, len(string))
return header + string
def __unpack(self, response):
header, version, length = struct.unpack('<4sBQ', response[:13])
(data, ) = struct.unpack('<%ds'%length, response[13:13+length])
return json.loads(data)
def __request(self, request):
self.__connect()
try:
self.sock.sendall(self.__pack(request))
except Exception as e:
raise Exception("Failed sending data.\nERROR: %s" % e)
response = ''
while True:
data = self.sock.recv(4096)
if not data:
break
response += data
self.__close()
return self.__unpack(response)
def __active_checks(self):
hosts = set()
for d in self.data:
hosts.add(d['host'])
for h in hosts:
request = {"request":"active checks", "host":h}
self.__log("[active check] %s" % h)
response = self.__request(request)
if not response['response'] == 'success': self.__log("[host not found] %s" % h)
def add(self, host, key, value, clock=None):
if clock is None: clock = int(time.time())
self.data.append({"host":host, "key":key, "value":value, "clock":clock})
def send(self):
if not self.data:
self.__log("Not found sender data, end without sending.")
return False
self.__active_checks()
request = {"request":"sender data", "data":self.data}
response = self.__request(request)
result = True if response['response'] == 'success' else False
if result:
for d in self.data:
self.__log("[send data] %s" % d)
self.__log("[send result] %s" % response['info'])
else:
raise Exception("Failed send data.")
return result
--ZBX_SERVER =
※ Créez à l'avance un rôle avec les droits d'accès suivants et attribuez-lui ce rôle.
[status =" ERROR ", timestamp = * Z, request_id =" * - * ", event] `Recommended Posts