python 实现监测consul服务状态，发送邮件短信

Posted 2020-11-20

# -*-coding:utf-8-*-
import redis
import urllib2
import json
import smtplib
import time
from qcloudsms_py import SmsMultiSender
from qcloudsms_py.httpclient import HTTPError
from email.mime.text import MIMEText
from email.header import Header

#consul 配置
Url='http://127.0.0.1:8500/v1/health/state/any'

#腾讯短信配置
appid = xxx
appkey = "xxx"
phone_numbers = ["xxx", "xxx"]
template_id = xxx

#mail配置
mail_user='xx'
mail_passwd='xx'
mail_host='xx'
mail_port=xx

#redis配置
redis_host='127.0.0.1'
redis_port=6379
redis_db=1
redis_sms_key='96ca8302-7b68-11e8-bc4a-1e00b000003e'
redis_email_key='7203896e-7b69-11e8-abd0-1e00b000003e'

#收件人列表
to_list=["xxx","xxx","xxx"]
#邮件主题
title="%s  Consul异常通知"%(time.strftime('%Y-%m-%d', time.localtime(time.time())))

#初始化短信
ssender = SmsMultiSender(appid, appkey)
#初始化redis
redis_connect = redis.Redis(host=redis_host, port=redis_port,db=redis_db)
#连接consul api
req = urllib2.Request(Url)
resp = urllib2.urlopen(req)

def send_mail(to_list,subject,content):
    me = mail_user
    msg = MIMEText(content,'html',_charset='utf-8')
    msg['Subject'] = Header(subject, 'utf-8')
    msg['From'] = me
    msg['to'] = to_list
    try:
        s = smtplib.SMTP_SSL(mail_host, mail_port)
        s = smtplib.SMTP()
        s.connect(mail_host)
        s.login(mail_user,mail_passwd)
        s.sendmail(me,to_list,msg.as_string())
        s.close()
        return True
    except Exception,e:
        print str(e)
        return False

data=[]
for server in json.loads(resp.read()):
    if server['Name'] != 'Serf Health Status'  and server['Status'] != 'passing':
        data.append({"Node":server['Node'],"Service":server['Name'].replace('Service '','').replace('' check',''),"Status":server['Status']})


html='''
<style type="text/css">
table.gridtable {
    font-family: verdana,arial,sans-serif;
    font-size:15px;
    color:#333333;
    border-width: 1px;
    border-color: #666666;
    border-collapse: collapse;
}
table.gridtable th {
    border-width: 1px;
    padding: 12px;
    border-style: solid;
    border-color: #666666;
    background-color: #dedede;
}
table.gridtable td {
    border-width: 1px;
    padding: 12px;
    border-style: solid;
    border-color: #666666;
    background-color: #ffffff;
}
</style>
<div>
<table class="gridtable">
<tr><th>主机</th>  <th>服务</th> <th>状态</th>
<tr>

'''

for i in data:
    html = html + u"""
        <tr>
        <td>%s</td>  <td>%s</td>  <td>%s</td>
    </tr>
        """%(i['Node'],i['Service'],i['Status'])

html+=u"""
</table>
</div>
"""


if len(data) >=1:

    if redis_connect.get(redis_sms_key) is None:
        result = ssender.send_with_param(86, phone_numbers,template_id, [])
        redis_connect.set(redis_sms_key,"")
        redis_connect.expire(redis_sms_key,60*60*24)

    if redis_connect.get(redis_email_key) is None:
        redis_connect.set(redis_email_key,"")
        redis_connect.expire(redis_email_key,60*60)
        for i in to_list:
            send_mail(i,title,html)

添加计划任务

*/1 * * * * /usr/bin/python /data/bin/consul.py

短信间隔24小时发一次，邮件间隔1小时发送一次，如需修改更改Key过期时间