（保姆级）服务器-Zabbix6.0使用Python脚本实现带图片的邮箱的报警

2024-01-24 11:15 由 alittlemc 发表于 #后端开发

前言

近期在琢磨Zabbix邮箱报警的功能，但是网上的教程通常是4.0或5.0版本Zabbix,并使用Python2.7环境，运行在新版本Zabbix6.0上有颇多问题，为此我基于原先教程修改基于Zabbix6.0并使用Python3+的解决方案。期间遇到不少坑，特此分享。

Zabbix自带报警

Zabbix是自带的邮箱的报警功能有限，比如不能实现诸如邮件插入图片的功能，而可以使用执行脚本功能则可以调用本地程序，调用Python脚本从而实现许多如发送企业微信、钉钉使用的功能。

前端设置

报警媒介

在zabbix中保存脚本文件的目录为/usr/lib/zabbix/alertscripts/,目前4.0\5.0\6.0都通用，将shell脚本文件保存于此可以直接在报警媒介类型调用。

参数需要传递给脚本，对于着Shell脚本中的$1、$2、$3。

{ALERT.SENDTO} //发件人(对应着用户\报警媒介中配置的发件人)
{ALERT.SUBJECT} //主题(对应着主题模版)
{ALERT.MESSAGE} //消息内容(对应着消息模版)

发件人

主题\消息内容

报警媒介消息模版

在消息模版中，添加问题发生

// 问题发生
// 主题
发生故障:服务器:{HOSTNAME}->{TRIGGER.NAME}警告!
// 消息
监控ID:{ITEM.ID}
告警主机:{HOST.NAME}
告警主机:{HOST.IP}
告警时间:{EVENT.DATE} {EVENT.TIME}
告警等级:{TRIGGER.SEVERITY}
告警信息: {TRIGGER.NAME}
告警项目:{TRIGGER.KEY}
问题详情:{ITEM.NAME}:{ITEM.VALUE}
当前状态:{TRIGGER.STATUS}:{ITEM.VALUE}
事件ID:{EVENT.ID}

添加问题恢复

//问题恢复
// 主题
问题恢复:服务器:{HOST.NAME}->{TRIGGER.NAME}已恢复!
// 消息
监控ID:{ITEM.ID}
告警主机:{HOST.NAME}
告警主机:{HOST.IP}
告警时间:{EVENT.DATE} {EVENT.TIME}
告警等级:{TRIGGER.SEVERITY}
告警信息: {TRIGGER.NAME}
告警项目:{TRIGGER.KEY}
问题详情:{ITEM.NAME}:{ITEM.VALUE}
当前状态:{TRIGGER.STATUS}:{ITEM.VALUE}
事件ID:{EVENT.ID}

设置用户报警媒介

在管理\用户<用户名>\报警媒介
如果有多个收件人,用,分割，我在python中做了定义

设置动作

要想要脚本触发问题后执行还需要设置

脚本实现

涉及到两个脚本

Shell脚本/usr/lib/zabbix/alertscripts/sedmail.zabbix.sh
主要是用于实现连接Python脚本，测试、删除图片
创建/usr/lib/zabbix/alertscripts/graph
Python脚本
主要是实现Zabbix中图片的下载、邮件发送

Shell脚本

新版本的Zabbix6.0貌似不支持直接执行Python脚本，为此我使用一个shell脚本作为中转，且可实现简单的测试、删除图片文件。

/usr/lib/zabbix/alertscripts/sedmail.zabbix.sh

#!/bin/bash
cd `dirname $0`
echo "{ALERT.SENDTO} = $1" > debug.txt
echo "{ALERT.SUBJECT} = $2" >> debug.txt
echo "{ALERT.MESSAGE} = $3" >> debug.txt
python3 sedmail.zabbix.py "$1" "$2" "$3" >> debug.txt
echo "shell success" >> debug.txt
find graph -type f -name "*.png" | xargs rm

Python脚本

主要是实现Zabbix中图片的下载、邮件发送，本Python脚本使用Python3环境，如果你需

脚本过程

解析传递过来的主题{ALERT.SENDTO}、主题{ALERT.SUBJECT}、消息{ALERT.MESSAGE}消息中的监控ID:后的数字，即itemid，此项极为重要

itemid=re.search(r'监控ID:(\d+)',sys.argv[3]).group(1)
# 如果你改了消息模版记得修改一下search匹配规则

登录Zabbix：使用Post登录http://zabbix:8080/index.php

 "name":user, # 用户
 "password":password, # 密码
 "autologin":"1", # 30天内自动登录
 "enter":"登录", # 请注意这个对应你语言,如果是英文为login on,可以抓包看看

故障的统计图下载，对应着先前的itemid参数，可以使用get请求http://zabbix:8080/chart.php后带的参数

 "from" :"now-30m",
 "to" : "now",
 "itemids[0]" : itemid,# 请注意,Zabbix6.0中是itemid[0],在更老的4.0\5.0使用的itemid
 "width" : "300",
 #对应的url,以itemid[0]=79672为例
 http://zabbix:8080/chart.php?from=now-30m&to=now&itemids%5B0%5D=79672&width=300

注意需要在登录的前提下，并且login的headers消息头一致，不然对提示错误
文件会保存在graph_path='/usr/lib/zabbix/alertscripts/graph'如果没有此文件夹需要创建

完整脚本

/usr/lib/zabbix/alertscripts/sedmail.zabbix.py

#!/usr/bin/python3
#coding=utf-8
from email.mime.text import MIMEText
from email.mime.multipart import MIMEMultipart
from email.mime.image import MIMEImage
import smtplib,sys,os,time,re,requests,logging
from smtplib import SMTP

user='Admin'    #定义zabbix用户名
password='password'    #定义zabbix用户密码
graph_path='/usr/lib/zabbix/alertscripts/graph'   #定义图片存储路径
graph_url='http://127.0.0.1:8080/chart.php'     #定义图表的url
loginurl="http://127.0.0.1:8080/index.php"          #定义登录的url
host='127.0.0.1'
to_email=sys.argv[1].split(',')    #传入的第一个参数为收件人邮箱
subject=sys.argv[2]  #传入的第二个参数为邮件主题
subject=subject.encode('utf-8').decode('utf-8')
smtp_host = 'smtp.xxx.net'  #定义smtp主机地址
from_email = 'alittlemc@xxx.com'     #定义发件人地址
mail_pass = 'xxx'       #发件人邮箱校验码\密码

def get_itemid():
    #获取报警的itemid
    itemid=re.search(r'监控ID:(\d+)',sys.argv[3]).group(1)
    return itemid

def get_graph(itemid):
    #获取报警的图表并保存
    session=requests.Session()   #创建一个session会话
    try:
        loginheaders={
        "Host":host,
        "Accept":"text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8"
        }
        #定义请求消息头

        payload = {
        "name":user,
        "password":password,
        "autologin":"1",
        "enter":"登录",
        }
        #定义传入的data
        login=session.post(url=loginurl,headers=loginheaders,data=payload)
        # print(login.text)
        #进行登录
        graph_params={
            "from" :"now-30m",
            "to" : "now",
            "itemids[0]" : itemid,
            "width" : "300",
        }
        # print(itemid)
        # http://zabbix:8080/chart.php?from=now-1m&to=now&itemids%5B0%5D=79672

        #定义获取图片的参数
        graph_req=session.get(url=graph_url,params=graph_params,headers=loginheaders)
        #发送get请求获取图片数据
        time_tag=time.strftime("%Y%m%d%H%M%S", time.localtime())
        graph_name='baojing_'+time_tag+'.png'
        #用报警时间来作为图片名进行保存
        graph_name = os.path.join(graph_path, graph_name)
        #使用绝对路径保存图片
        with open(graph_name,'wb') as f:
            f.write(graph_req.content)
            #将获取到的图片数据写入到文件中去
        return graph_name

    except Exception as e:
        # print(e)
        return False
def text_to_html(text):
    #将邮件内容text字段转换成HTML格式
    d=text.splitlines()
    #将邮件内容以每行作为一个列表元素存储在列表中
    html_text=''
    for i in d:
        i='' + i + '<br>'
        html_text+=i + '\n'
    #为列表的每个元素后加上html的换行标签
    return html_text

def send_mail(graph_name):
    #将html和图片封装成邮件进行发送
    msg = MIMEMultipart('related')  #创建内嵌资源的实例

    with open(graph_name,'rb') as f:
        #读取图片文件
        graph=MIMEImage(f.read())  #读取图片赋值一个图片对象
    graph.add_header('Content-ID','imgid1')  #为图片对象添加标题字段和值
    text=text_to_html(sys.argv[3])
    html="""
    <html>
      <body>
      %s  <br><img src="cid:imgid1">
      </body>
    </html>
    """ % text
    html=MIMEText(html,'html','utf-8')  #创建HTML格式的邮件体
    msg.attach(html)   #使用attach方法将HTML添加到msg实例中
    msg.attach(graph)  #使用attach方法将图片添加到msg实例中
    msg['Subject'] = subject
    msg['From'] = from_email
    try:
        server=SMTP(smtp_host,"587")   #创建一个smtp对象
        server.starttls()    #启用安全传输模式
        server.login(from_email,mail_pass)  #邮箱账号登录
        for x in to_email:
            server.sendmail(from_email,x,msg.as_string())  #发送邮件
        server.quit()   #断开smtp连接
    except smtplib.SMTPException as a:
        print(a)

def run():
    itemid=get_itemid()
    graph_name=get_graph(itemid)
    send_mail(graph_name)

if __name__ =='__main__':
    run()
    print('success',sys.argv[1],sys.argv[2],sys.argv[3])

测试

可以直接使用报警媒介的测试功能，对应的传输主题{ALERT.SENDTO}、主题{ALERT.SUBJECT}、消息{ALERT.MESSAGE}消息

热门相关：暖君布衣官道恶明恶明霍先生结婚吧

探讨Java死锁的现象和解决方法

死锁是多线程编程中常见的问题，它会导致线程相互等待，无法继续执行。在Java中，死锁是一个需要注意和解决的重要问题。让我们通过一系列详细的例子来深入了解Java死锁的现象和解决方法。 1. 什么是死锁？死锁是指两个或多个线程在互相等待对方释放锁资源的情况下，导致程序无法继续执行的现象。这通常发生在 ...阅读全文

node+vue开发环境下接口数据传递中的跨域问题

跨域问题产生原因原因大部分浏览器自带的保护措施，限制用户在一个域名下请求另一个域名的数据一、关于跨域跨域对于前后端开发者来说，就像一块狗皮膏药，无论是面试还是开发中，都会经常遇到。之所以出现跨域问题，是因为浏览器的同源策略，为了隔离潜在的恶意文件，为了防御来自歪门邪道的攻击，浏览器限制了从 ...阅读全文

接口数据传递中的跨域问题

记一次linux复制病毒处理过程

某天我的阿里云突然发信息告诉我服务器有自变异木马,我用远程工具连接服务器异常卡顿甚至掉线,reboot也不好使.用阿里云的网页控制台会好些,但还是卡,我又用阿里云控制台重启服务器,重启之后发现服务器完全连不上了,ping也ping不通了,我问了客服说可以用救援连接试试,果然能连上,起初发现连不上的原 ...阅读全文

Java开发者的Python快速进修指南：探索15种独特的Python特殊方法

Python中的特殊方法（魔术方法）是由Python解释器自动调用的，用于实现对象的特定功能。常用的特殊方法包括`__init__`、`__str__`、`__repr__`、`__len__`、`__getitem__`、`__setitem__`、`__delitem__`、`__iter__`... ...阅读全文

44从零开始用Rust编写nginx，命令行参数的设计与解析及说明

好的命令行可以执行更强大的功能，也能让人更好的理解你的程序，这需要有一个好的帮助系统，也需要有一个强大的解析能力。此章讲述了命令行的执行功能，希望可以帮助到你的使用。 ...阅读全文

图数据库Neo4j（最详细教程）

图数据库Neo4j实战（全网最详细教程） 1. 图数据库Neo4j介绍 1.1 什么是图数据库（graph database）随着社交、电商、金融、零售、物联网等行业的快速发展，现实社会织起了了一张庞大而复杂的关系网，传统数据库很难处理关系运算。大数据行业需要处理的数据之间的关系随数据量呈几何 ...阅读全文

Java实现对象转成字节数组（整型支持按位写入，字符串则按字节写入）

闲着无聊，写了一个对象转换成byte[]的工具类，支持整型按位写入(大大节省空间)，具体步骤如下： 1. 定义实体类和注解 public class User { /** * ID,4个字节，32bit */ @JSONField(ordinal = 1) @BitPos(offset=0,size ...阅读全文

用户画像系列——在线服务调优实践

前面文章讲到画像的应用的几个方面，其中画像的在线服务应用主要是在推荐场景、策略引擎场景，这两部分场景都是面向线上的c端服务。推荐场景：根据不同的用户推荐不同的内容，做到个性化推荐，需要读取画像的一些偏好数据，推荐感兴趣的内容。策略引擎：根据用户的属性进入到不同的页面或者给出不同的策略，比如：普通 ...阅读全文

Rust 编写自动化测试

本文在原文基础上有删减，原文请参考目录如何编写测试测试函数剖析使用 assert! 宏来检查结果使用 assert_eq! 和 assert_ne! 宏来测试相等自定义失败信息使用 should_panic 检查 panic将 Result<T, E> 用于测试控制测试如何运行并行或连续的运行测试显 ...阅读全文