7、Zabbix微信告警

lzf79

现实生产环境中，我们通常使用邮件和短信接受zabbix报警信息，但是邮件经常被工作人员搁置在角落中甚至被设置为垃圾邮件被过滤掉。公司的短信接口又太贵，复杂环境中使用短息报警会使运维成本增加很多。微信提供了很好的第三方接口，我们可以利用微信报警以求降低运维成本。
　　

　　 微信的第三方接口要求我们先申请一个企业号——传送门：https://qy.weixin.qq.com/
　　

　　

1.通讯录添加企业成员


我们要提前把成员信息添加进组织部门，必填项+手机号或者微信号，这样别人扫描二维码的时候才能成功关注企业号。
注意：这里有两个我们要用到信息，一个组织部门的ID，一个部门成员的账号（账号是自己手动指定的，不同于微信号，最好是字母加数字）

　　

　　添加成员后，成员通过扫描二维码关注企业微信号公众号。

　　

2.应用中心创建应用
我们要在这里创建应用，因为要通过应用发送消息给部门成员
注意：这里要记住一个值，应用ID

　　

　　

　　

3.给部门设置管理员
设置--->功能设置---->权限管理---->新建管理组
管理员必须事先已经关注了企业号，并且已经设置好邮箱地址

　　

　　

我们要准备这些东西：

•     一个微信企业号
  
•     企业号已经被部门成员关注
  
•     企业号里有一个可以发消息的应用
  
•     一个授权管理员，可以使用该应用给成员发消息
  

我们要取到这些信息：

•     CropID
  
•     Secret
  

4、创建微信告警的python脚本


#!/usr/bin/python2.7
# -*- coding: utf-8 -*-
import sys
import logging
import qyweixin
import json
import argparse
class Logger:
    def __init__(self, path, Slevel = logging.DEBUG, Flevel = logging.DEBUG):
        self.logger = logging.getLogger(path)
        self.logger.setLevel(logging.DEBUG)
        fmt = logging.Formatter('[%(asctime)s] [%(levelname)s] %(message)s', '%Y-%m-%d %H:%M:%S')
        #设置CMD日志
        sh = logging.StreamHandler()
        sh.setFormatter(fmt)
        sh.setLevel(Slevel)
        #设置文件日志
        fh = logging.FileHandler(path)
        fh.setFormatter(fmt)
        fh.setLevel(Flevel)
        self.logger.addHandler(sh)
        self.logger.addHandler(fh)
    def debug(self,message):
        self.logger.debug(message)
    def info(self,message):
        self.logger.info(message)
    def warning(self,message):
        self.logger.warning(message)
    def error(self,message):
        self.logger.error(message)
    def critical(self,message):
        self.logger.critical(message)
def main():
    # 发送短信日志文件
    log = Logger('/var/log/weixin.log',logging.ERROR,logging.DEBUG)
    # 微信基本参数
    corpid = "******"
    corpsecret = "********"
    qy = qyweixin.AccessToken(corpid, corpsecret)
    token = qy.get_token()
    push_msg = qyweixin.WeixinPush()
    # 用户所传参数
    parser = argparse.ArgumentParser()
    parser.add_argument("--zabbix_test", help="is test")
    parser.add_argument("--host", help="host name")
    parser.add_argument("--ip", help="host ip")
    parser.add_argument("--trigger", help="trigger name")
    parser.add_argument("--status", help="trigger status")
    parser.add_argument("--time", help="trigger time")
    parser.add_argument("--lastvalue", help="trigger lastvalue")
    parser.add_argument("--itemid", help="item id")
    parser.add_argument("--msg", help="msg content")
    # 解析所传入的参数
    args = parser.parse_args()
    host = args.host
    ip = args.ip
    trigger = args.trigger
    status = args.status
    time = args.time
    lastvalue = args.lastvalue
    itemid = args.itemid
    #TODO: 告警分类,特定告警只发送给指定人员,待实现中
    # push_msg.push_text_msg(token=token, agentid=0, content='test msg', touser='test', toparty='test_group', totag='', safe=0)
    # push_msg.push_text_msg(token=token, agentid=0, content=msg, toparty="28|29")
    msg = "HOST: %s \nIP: %s \nTrigger: %s \nLastValue: %s \nTime: %s \nStatus: %s" %(host, ip, trigger, lastvalue, time, status)
    # 用户通过命令行发送消息
    if args.msg:
        msg = args.msg
        push_msg.push_text_msg(token=token, agentid=0, content=msg)
        return
    # zabbix 所发的测试报警
    if args.zabbix_test:
        push_msg.push_text_msg(token=token, agentid=0, content=msg, touser="liuganglin")
        return
    # zabbix 所发的故障告警
    if not args.zabbix_test and not args.msg:
        push_msg.push_text_msg(token=token, agentid=0, content=msg)
        log.info(msg.replace("\n", " "))
        return
if __name__ == '__main__':
    main()

　　注意：这个脚本需要安装python2.7 ,并且用python2.7安装pip2.7。然后用pip2.7安装qyweixin (0.1.3)
[root@ZabbixServer alertscripts]# pip2.7 list
pip (8.0.2)
qyweixin (0.1.3)
setuptools (19.4)　　

　　将脚本放在Zabbix Server 的/etc/zabbix/alertscripts路径下
　　

　　

　　5、Zabbix WEB端配置
　　Configuration--Actions--Create Action
　　在Action页面中设置name即可，其他的默认
　　

　　

　　在Conditions页面设置告警条件，将要告警的主机组加入进来

　　在Operations中，设置Type为Custom Script，Commands中设置告警的参数。

　　

　　收到的微信告警消息如下：

　　

　　

　　

　　参考文档：http://wuhf2015.blog.运维网.com/8213008/1688614