用企业微信实现预警（shell + python）

时间 2019-11-13

标签企业微信实现预警 shell python 栏目 Unix 繁體版

原文原文链接

目录python

一注册企业微信

本文全部内容是基于2018年12月26日时的企业微信版本所作的教程。后面可能因为企业微信界面规则更改致使部分流程不一致。（你们看文章时请注意这一点）shell

注册企业微信必备条件

微信号（实名认证了）
手机号

以前我有个误区，就是觉得注册企业微信就必定要有营业执照之类的证件才能够注册，实际是不须要也能够的，由于咱们直接注册后，即便不绑定企业，咱们也是能够正常使用的，未绑定实际企业的，有200人的数的上限（难道大家技术部有200人？不存在的，哈哈!）json

注册

注册连接：企业微信

企业名称能够随便填，建议填真实的啊，其余的你就按照实际状况填了。centos

二建立消息

建立部门

首先咱们须要建立一个部门，而后将成员添加到一个部门里面
api

邀请成员加入

咱们能够在首页点击进行邀请。
数组

也能够在选中要添加的部门后再选右边的添加成员或者微信邀请。
bash

建立应用

建立的时候指定下能够接收的消息的部门
服务器

关注微工做平台

在个人企业 ---》微工做平台 ---》邀请关注
微信

三实现预警

在完成的上面的全部准备工做后，咱们还须要获取三个东西：curl

1 企业ID

2 获取应用ID和Secret

获取企业ID

获取应用ID和Secret

经过shell 脚本实现监控预警

该shell 脚本实现的功能：检测端口是否在监听状态，不在则进行微信预警。

#!/bin/bash
###############
#$Auth= djx
#$Function= monitoring service
#Date= 2018-12-26
###############
# 日志储存文件
log_file='/var/log/ljf_status.log'
# 主机名
hostname=`hostname`
# 监听的端口数组
check_port=("3306" "3329" "4567")
# 数组长度
num=${#check_port[*]}
#  报警消息
msg=""
echo "--------------------------$(date +%F_%T)-----------------" >>$log_file

for i in  `seq 0 $num`
do
    netstat -tnlp|grep "${check_port[${i}]}"  >>/dev/null
    if [ $? -ne 0 ]
    then
        msg="\\n${hostname}:The Port ${check_port[${i}]} is down \\n"${msg}
        echo "$(date +%F_%T)  ${hostname}:The Port ${check_port[${i}]} is down">>$log_file
    fi
done
if [ "${msg}" !=  "" ]
then
    CropID=""   #填入企业ID值
    Secret=""   #填入认证密码
    GURL="https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=$CropID&corpsecret=$Secret"  
    # 获取token
    Gtoken=$(/usr/bin/curl -s -G $GURL | awk -F\" '{print $10}')  
    PURL="https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=$Gtoken" 
    body='{
    "touser": "@all",
    "msgtype": "text",
    "agentid": "1000002", #要更改成咱们的应用ID
    "text":{
          "content":"
    故障：'$msg' "
             },
    "safe":0
    }'
    /usr/bin/curl --data-ascii "$body" $PURL >>$log_file 2>&1
fi

经过python 脚本实现监控预警

因为centos7和centos6 默认安装的都是python2版本，因此下面的脚本是基于python2写的，这样咱们就能够直接拿到咱们的服务器上使用了。

# -*- coding: utf-8 -*-
# @Time    : 2018/12/27 0021 11:58
# @Author  : djx
# @Email   : 1120236774@qq.com
# @File    : 微信预警脚本.py
# @Software: PyCharm
import os
import time
import urllib2
import json


# 企业号ID
wxid = ""
# 应用ID
depid = ""
# 认证密码
secret = ""
# 获取主机的名称
hostname = os.popen("hostname").read()
# 日志储存文件
log_file = '/var/log/ljf_status.log'
# 监听的端口列表
check_port = (
    "8500",
    "3306")
# 发送的消息
msg = ""
# 获取当前的时间
date_time = time.strftime("%Y-%m-%d %X")
# 检查端口是否在监听
for i in check_port:
    shell = "netstat -nutlp |grep \"" + i + "\""
    recv = os.popen(shell).read()
    if recv == "":
        msg = msg  + hostname + ": The Port " + i + "is down \n"
# 预警判断
if msg != "":
    url = "https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=" + \
        wxid + "&corpsecret=" + secret
    request = urllib2.Request(url)
    response = urllib2.urlopen(request)
    recv_info = response.read()
    recv_info = eval(recv_info) 
    wx_token = recv_info['access_token']
    msg_url = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=" + wx_token
    send_msg = {
        "touser": "@all",
        "msgtype": "text",
        "agentid": depid,
        "text": {"content": msg},
        "safe": 0
    }
    send_msg_json = json.dumps(send_msg)
    request_post = urllib2.urlopen(msg_url,send_msg_json)
    recv_msg = request_post.read()
    with open(log_file,mode='a') as f:
        f.write(date_time)
        f.write("\n")
        f.write(msg)
        f.write(recv_msg)
        f.write("\n")

上面的脚本也能够应用在zabbix或者是Open-falcon。

最后送上一句以为不错的话： 立志要如山，行道要如水，如山能坚决，如水能曲达。