标签：python sse ext user back utf-8 string param 实现
# -*-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过期时间
标签：python sse ext user back utf-8 string param 实现
原文地址：http://blog.51cto.com/11889458/2134225
