archer05 发表于 2018-1-2 09:42:57

[置顶]zabbix通过lykchat发送告警信息配置过程

#! /usr/bin/python  # coding:utf-8
  # -*- coding : utf-8 -*-
  import sys, time, requests
  SEND_MESS_ID_LIST = re.split("," , sys.argv)
  # web页面的发送者可以同时支持多个微信号,通过逗号分割。在web页面的管理-用户-用户中配置
  VAR_LIST = sys.argv
  EVENT_MESSAGE = {}
  for VAR in VAR_LIST :
  VAR = str(VAR).replace("\r\n" , "")
  DICT = eval(VAR)
  EVENT_MESSAGE.update(DICT)
  # 参数过来的是数组,所以需要转化为字典
  IP = EVENT_MESSAGE["IP"]
  HOST = EVENT_MESSAGE["Host"]
  TRIGGER = EVENT_MESSAGE["Trigger"]
  STATUS = EVENT_MESSAGE["Status"].lower()
  TRIGGER_ID = EVENT_MESSAGE["Trigger_ID"]
  ITEM_NAME = EVENT_MESSAGE["Item_Name"]
  ITEM_KEY = EVENT_MESSAGE["Item_Key"]
  EVENT_ID = EVENT_MESSAGE["Event_ID"]
  ITEM_VALUE = EVENT_MESSAGE["Item_Value"]
  EVENT_AGE = EVENT_MESSAGE["Event_Age"]
  EVENT_DATETIME = EVENT_MESSAGE["Event_Date"].replace(r"." , "-")
  TRIGGER_LEVEL = EVENT_MESSAGE["Trigger_Level"]

  if TRIGGER_LEVEL == "Not>  TRIGGER_LEVEL = "Not_classified"
  if STATUS == "ok" :
  STATUS_CN = "恢复"
  else :
  STATUS_CN = "故障"
  SEND_MESSAGE_LEVEL = ["High" , "Disaster"]
  # 通过短信发送的报警信息的事件级别列表
  SEND_MAIL_LEVEL = ["Warning" , "Average" , "High" , "Disaster"]
  # SEND_MAIL_LEVEL = ["Not_classified" , "Information" , "Warning" , "Average" , "High" , "Disaster"]
  # 通过邮件发送的报警信息的事件级别列表
  TRIGGER_LEVEL_LIST = {"Not_classified" : "未定义" , "Information" : "通知" , "Warning" : "警告" , "Average" : "一般严重" , "High" : "严重" , "Disaster" : "灾难"}
  TRIGGER_LEVEL_CN = TRIGGER_LEVEL_LIST
  # 警告级别的中文
  MESSHEADER_QINZHUI_LIST = {"Not_classified" : "注意" , "Information" : "注意" , "Warning" : "处理" , "Average" : "尽快处理" , "High" : "立即处理" , "Disaster" : "立即处理灾难"}
  MESSHEADER_QINZHUI = MESSHEADER_QINZHUI_LIST
  # 告警信息标题前缀
  TIMEARRAY = time.strptime(EVENT_DATETIME, "%Y-%m-%d %H:%M:%S")
  EVENT_TIMESTAMP = int(time.mktime(TIMEARRAY))
  NOW_TIMESTAMP = time.time()
  NOW_TIMESTAMP = re.split("\." , str(NOW_TIMESTAMP))
  NOW_DATETIME = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(int(NOW_TIMESTAMP)))
  NOW_TIME = time.strftime("%H:%M", time.localtime(int(NOW_TIMESTAMP)))
  # 转化时间
  EVENT_TIEM = time.strftime("%H:%M", time.localtime(EVENT_TIMESTAMP))
  # 故障发送时间
  TIME_INTERVAL = int(NOW_TIMESTAMP) - int(EVENT_TIMESTAMP)
  # 这次故障时间和现在时间差
  if IP == "127.0.0.1" :
  IP_END = ""
  else :
  IP_END = "-" + re.split("\." , IP)[-1]
  def send_lykchat(SEND_MESS_ID) :
  TRIG_MESS = HOST.replace(" " , "") + r"的" + TRIGGER.replace(" " , "")
  VALUE_MESS = ITEM_VALUE.replace(" " , "")
  if STATUS == "ok" :
  SEND_CONTEXT = TRIG_MESS + r"在" + NOW_TIME + r"恢复,故障持续" + str(TIME_INTERVAL / 60) + "分钟" + r",值为" + VALUE_MESS
  else :
  SEND_CONTEXT = MESSHEADER_QINZHUI + ":" + TRIG_MESS + r"在" + EVENT_TIEM + r"发生" + TRIGGER_LEVEL_CN + r"故障,已持续" + str(TIME_INTERVAL / 60) + "分钟" + r"值为" + VALUE_MESS
  SEND_CONTEXT = SEND_CONTEXT + "\nIP地址 : " + IP + "\n"
  SEND_CONTEXT = SEND_CONTEXT + r"主机名 : " + HOST + "\n"
  SEND_CONTEXT = SEND_CONTEXT + r"故障级别 : " + TRIGGER_LEVEL_CN + "\n"
  SEND_CONTEXT = SEND_CONTEXT + r"发生时间 : " + EVENT_DATETIME + "\n"
  SEND_CONTEXT = SEND_CONTEXT + r"持续时长 : " + str(TIME_INTERVAL / 86400) + "天" + str((TIME_INTERVAL % 86400) / 3600) + "小时" + str((TIME_INTERVAL % 3600) / 60) + "分钟" + str(TIME_INTERVAL % 60) + "秒\n"
  SEND_CONTEXT = SEND_CONTEXT + r"目前状态 : " + STATUS_CN + "\n"
  SEND_CONTEXT = SEND_CONTEXT + r"触发器名 : " + TRIGGER + "\n"
  SEND_CONTEXT = SEND_CONTEXT + r"当前值 : " + ITEM_VALUE + "\n"
  SEND_CONTEXT = SEND_CONTEXT + r"发送时间:" + NOW_DATETIME + "\n\n"
  # 发送邮件正文
  try :
  url = 'http://127.0.0.1/sendmsg?username=zabbix&pwd=123456&friendfield=1&friend=' + str(SEND_MESS_ID) + '&content=' + str(SEND_CONTEXT)
  requests.get(url)
  except :
  pass
  for SEND_MESS_ID in SEND_MESS_ID_LIST :
  send_lykchat(SEND_MESS_ID)
页: [1]
查看完整版本: [置顶]zabbix通过lykchat发送告警信息配置过程