python实现自动监控网站并发送邮件告警


通过定时执行python脚本,可以实现定期批量访问网站,如果发现网站打不开,第一时间发邮件到管理员邮箱进行预警

这里用的是python3.5

需要安装的插件:

smtplib:发邮件需要用到

pycurl:访问网站时会需要用到

linecache:在读取txt网站清单时需要用到


具体思路:

python程序从txt里面批量读取到网站的信息,通过Curl.py模拟浏览器去访问网站,并且把访问的结果写入到以自己的网站名称-日期.txt格式的文件中记录;有几种情况:

1、如果发现打不开了,直接发邮件提示网站已经打不开

2、发现可以打开,读取文件中上一次访问的情况(读取txt文件最后一行),

    1)如果发现上一次是打不开的,发邮件提醒网站已经恢复了

    2)如果发现上一次是打得开的(200的返回码),只是记录网站访问的日志就可以了


总共4个文件,

Email.py是邮件类,主要用来发邮件的时候调用,这里需要按照你的情况改成你的邮箱(msg['From']),邮箱服务器地址(SMTP地址),和你的邮箱密码(SMTP.login)


Email.py

#!/usr/bin/python
#-*- coding:utf-8 -*-
import sys
import smtplib
from email.mime.text import MIMEText
from email.mime.multipart import MIMEMultipart
class Email_send(object):
    def __init__(self,msgTo,data2,Subject):
        self.msgTo=msgTo
        self.data2=data2
        self.Subject=Subject
    def sendEmail(self):
       # (attachment,html) = content
        msg = MIMEMultipart()
        msg['Subject'] = self.Subject
        msg['From'] = 'xxxx@xxxx.com.cn'
        msg['To'] = self.msgTo
        html_att = MIMEText(self.data2, 'html', 'utf-8')
        #att = MIMEText(attachment, 'plain', 'utf-8')
        msg.attach(html_att)
        #msg.attach(att)
        try:
            smtp = smtplib.SMTP()
            smtp.connect('smtp.xxxx.com', 25)
            smtp.login(msg['From'], 'xxxx') #改成自己的邮箱密码
            smtp.sendmail(msg['From'], msg['To'].split(','), msg.as_string())
            return('邮件发送成功')
        except Exception as e:
            print('--------------sss------',e)
    def curl(self):
        import pycurl
        c=pycurl.Curl()
        #url="www.luoan.com.cn"
        #indexfile=open(os.path.dirname(os.path.realpath(__file__))+"/content.txt","wb")
        c.setopt(c.URL,url)
        c.setopt(c.VERBOSE,1)
        c.setopt(c.ENCODING,"gzip")
        #模拟火狐浏览器
        c.setopt(c.USERAGENT,"Mozilla/5.0 (Windows NT 6.1; rv:35.0) Gecko/20100101 Firefox/35.0")
        return c

Curl.py 主要用来执行模拟浏览器访问网站并返回结果的文件

#!/usr/bin/python
#-*- coding:utf-8 -*-
import sys
import pycurl
class Curl(object):
    def __init__(self,url):
        self.url=url
    def Curl_site(self):
        c=pycurl.Curl()
        #url="www.luoan.com.cn"
        #indexfile=open(os.path.dirname(os.path.realpath(__file__))+"/content.txt","wb")
        c.setopt(c.URL,self.url)
        c.setopt(c.VERBOSE,1)
        c.setopt(c.ENCODING,"gzip")
        #模拟火狐浏览器
        c.setopt(c.USERAGENT,"Mozilla/5.0 (Windows NT 6.1; rv:35.0) Gecko/20100101 Firefox/35.0")
        return c

site_moniter.py 这个文件为主程序,主要执行调用上面的函数,读取txt文件中的网站清单,如果网站打不开就发邮件出来告警

需要注意:1、把xxxx@xxxx.com改成你自己的邮箱,

      2、把文件路径改成自己的真实路径

#!/usr/bin/python
#-*- coding:utf-8 -*-
import pycurl
import os
import sys
import linecache
import time  #引入事件类,用来获取系统当前时间
#from ceshi import Student
from Email import Email_send
from Curl import Curl

#bart = Student('mafei',59)
#bart.print_score()

def script(urls,type):
    msgTo = 'xxxx@xxxx.com'
    now_time=time.strftime("%Y-%m-%d %H:%M:%S",time.localtime(time.time()))
    j=1
#       data2=[{'aa':'aa'}]
    for url_split in urls:
        #print(url_split)
        url_1=url_split.split('---')
        url=url_1[1]
        recovery_title = "监控通知----%s url:%s" % (url_1[0], url) + "在" + time.strftime("%Y-%m-%d %H:%M:%S",time.localtime(time.time())) + "已经恢复"
        down_title = "监控通知----%s url:%s" % (url_1[0], url) + "在" + time.strftime("%Y-%m-%d %H:%M:%S",time.localtime(time.time())) + "无法打开"
        #print('~~~~~~~~~~~~~~~~~~~')
        #print(url)
        #引用爬去网站的类,调用结果
        url_result = Curl(url)
        c = url_result.Curl_site()
        try:
            c.perform()
            code = str(c.getinfo(c.HTTP_CODE))
            print(code+'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa')
        except Exception as e:
            print('--------错误信息:--------',e)
            #indexfile.close()
            #c.close()
        code = str(c.getinfo(c.HTTP_CODE))
        # print(code+'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa')
        filename = '%s-%s.txt' % (url_1[0], time.strftime("%Y-%m-%d", time.localtime(time.time())))
        #判断如果在网站无法打开的情况下
        if code == '0' or code=='400' or code=='500' or code=='404':
            resolveTime = 0
            Connection_Time = 0
            Transfer_Total_Time = 0
            Total_Time = 0
            # print('为000000000000000000000000000000000000000000')
            data3 = '网站:%s无法打开%s' % (url_1[0], url)
            # indexfile.close()
            # c.close()
            #判断网站如果挂了就发邮件
            stat3 = Email_send(msgTo, data3, down_title)
            resole=stat3.sendEmail()
            print(resole)
            print(data3 + '邮件已经发送')
        else:
            #resolveTime = str(c.getinfo(c.NAMELOOKUP_TIME) * 1000) + " ms"
            # Connection_Time=str(float(c.getinfo(c.CONNECT_TIME)*1000-c.getinfo(c.NAMELOOKUP_TIME)*1000))+" ms"
            #Connection_Time = str(c.getinfo(c.CONNECT_TIME) * 1000 - c.getinfo(c.NAMELOOKUP_TIME) * 1000) + " ms"
            # Connection_Time=round(float(Connection_Time))
            #Transfer_Total_Time = str(c.getinfo(c.TOTAL_TIME) * 1000 - c.getinfo(c.PRETRANSFER_TIME) * 1000) + " ms"
            #Total_Time = str(c.getinfo(c.TOTAL_TIME) * 1000) + " ms"
            # data2=data
            # data={'url':url,'HTTP CODE':code,'resolveTime':resolveTime,'Connection_Time':Connection_Time,'Transfer_Total_Time':Transfer_Total_Time,'Total_Time':Total_Time}
            print('网站可以正常打开')
            #f = open(filename, 'a',encoding='utf-8')
            file_exit=os.path.exists(filename)
            #print(file_exit)
            #判断这个日志文件存不存在
            if(file_exit):
                #读取文件最后一行,为了读取出来最后一次的状态值
                file = open(filename, 'r',encoding='utf-8')
                linecount = len(file.readlines())
                data = linecache.getline(filename, linecount)
                file.close
                if data == '':
                    print('这是'+data+'为空的数据')
                else:
                    print('其他信息%s'%(data))
                    explode = data.split('----')
                    #判断如果读取出来的值,最后一次是异常的情况就告警
                    if explode[3]=='0\n' or explode[3]=='400\n' or explode[3]=='500' or explode[3]=='404':
                        data3 = '网站:%s在%s已经恢复%s' % (url_1[0], now_time,url)
                        stat3 = Email_send(msgTo, data3, recovery_title)
                        resole = stat3.sendEmail()
                        print(resole)
                        print(data3 + '邮件已经发送')
                    else:
                        print('最后一次记录为其他值:%s'%(explode[3])+'-----')
            else:
                print('文件不存在')
        data2 = '\n' + url_1[0] + '----' + url + '-----' + time.strftime("%H:%M:%S", time.localtime(time.time())) + '-------' + code
        print('data2数据写入成功:' + data2)
        file = open(filename, 'a', encoding='utf-8')
        file.write(data2)
        file.close
#  bart = Student(data2,59)
#  bart.print_score()

if __name__ == "__main__":
    type = "监控通知-测试" + time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time()))
    data1=['公司门户---www.luoan.com.cn','公司平台---yun.luoan.com.cn']
    #script(data1,type)


  #中心层面的网站清单
    file=open('D:\python\site_moniter\zhongxin.txt')
    data2=[]
    while 1:
        line2 =file.readline()
        print(line2)
        if not line2:
            break
        data2.append(line2[0:-1])
    #data2=['www.luoan.com.cn','yun.luoan.com.cn','www.qq.com']
    print(data2)
    title="监控通知-中心"+ time.strftime("%Y-%m-%d %H:%M:%S",time.localtime(time.time()))
    script(data2,title)

本文出自 “马鹏飞——著” 博客,请务必保留此出处http://mapengfei.blog.51cto.com/1552412/1841731

本页内容版权归属为原作者,如有侵犯您的权益,请通知我们删除。
vSphere部署系列之09——HA和DRS群集管理 群集(Cluster)是将多台物理主机组织起来,群集管理其中所有主机的资源,形成一个大的资源池。群集中的所有的虚拟机可在池中的任意主机上自由移动,并且群集可做到快速扩容和HA故障冗余。群集的前提条件是要有共享存储,所有虚拟机及其配置文件必须驻留在共享存储器上。 在前面的博文章节中,已搭建了比较基础的实验环境,实现了vCenter对ESXi主机的管理,网络管理、共享存储管理。在这种情况下,各物理主机之间的计算资源(CPU、内存)是完全独立的,在某台主机出
昨天提交代码的时候自己的eclipse抽风了一下,发现自己的Web App Libraries里面的Jar包全部都不会自动加入到Web App Libraries中,导致之前配置的项目全都要重新手动配置,网上搜了一搜,找到了个解决方法: 参考链接http://blog.csdn.net/zhengzhb/article/details/6956130 定位到项目根目录中.settings里面的 org.eclipse.wst.common.component, 如下内容贴到里面保存一下,就能检测到WEB-

Linux NFS自动挂载autofs配置 - 2016-08-29 17:08:21

一、基于Linux下NFS文件系统的自动挂载方式, 前期准备环境两台Linux服务器: 准备一台NFS服务器端(系统环境centos6.5,ip地址192.168.100.100) 准备需要挂载NFS服务端的NFS客户端(系统环境centos6.5,ip地址192.168.100.101) 实施: 现在server端安装NFS保证能正常访问,我们这里通过yum工具安装即可 [root@nfsserver ~]# yum install nfs-utils rpcbind -y 通过修改NFS配置,共享/d
文本处理工具grep,正则表达式在Linux学习过程中很容易出现困惑与障碍的地方,这里分享下学习这方面内容的一些感受。 grep Global search REgular expression and Print out the line 作用:文本搜索工具,根据用户指定的‘ 模式(过滤条件) ’对目标文本逐行进行匹配检查;打印匹配到的行; ‘模式’:由 正则表达式 的元字符及文本字符所编写出的过滤条件。 grep [OPTIONS] PATTERN [FILE...] grep [OPTIONS] [
HAProxy高可用负载均衡集群部署 基本信息: 系统平台:VMware WorkStation 系统版本: CentOS Linux release 7.2.1511 (Core) 内核版本: 3.10.0-327.el7.x86_64 集群架构: 前端:HAProxy 1、虚拟FQDN:www.simpletime.net 2、VIP:192.168.39.1;DIP:172.16.39.50 3、调度服务器:Varnish1、Varnish2 4、调度算法:URL_Hash_Consistent 5
常见的文件系统 Linux文件系统: ext2, ext3, ext4, xfs, btrfs, reiserfs, jfs, swap swap: 交换分区 光盘:iso9660 Windows:fat32, ntfs Unix: FFS, UFS, JFS2 网络文件系统:NFS, CIFS 集群文件系统:GFS2, OCFS2 分布式文件系统:ceph, moosefs, mogilefs, GlusterFS, Lustre 实验环境CentOS7.2 Linux根据其是否支持"journal"功

部署Tomcat及其负载均衡 - 2016-08-29 17:08:51

应用场景 : 使用3台虚拟机操作系统为redhat6.5 Nginx 服务器s3 192.168.90.103 nginx-1.6.0.tar.gz Tomcat服务器s1 192.168.90.106 1.jdk-7u65-linux-x64.gz 2.apache-tomcat-7.0.54.tar.gz Tomcat服务器s2 192.168.90.107 1.jdk-7u65-linux-x64.gz 2.apache-tomcat-7.0.54.tar.gz 实施准备 启动后关闭防火墙 Serv
DNS(域名系统),用于解析域名和IP地址之间的映射关系 协议使用端口: udp 53正常查询解析情况下使用udp53 tcp53当进行主从之间的区域传送时使用tcp53 DNS域的空间划分 DNS的查询方式 递归查询 当主机A要向DNS服务器发送查询主机D的请求时,服务器返回给A最终结果,这种方式就是递归查询,如果客户端要查找的内容直接在服务器上得到结果,刚给出的答案是一个权威答案,否则就是一个参考答案。 迭代查询 NS服务器接收到A的请求后,本地没有D的解析,则会通过以下过程获得 1、NS向根域询问D

nginx的记录配置心得 - 2016-08-29 17:08:29

今天本来要去见自己喜欢的一个人的,唉,感觉自己的爱情龙卷风来了,来的很猛烈,我今天还把自己的胡子刮的很干净,悲催的是那位女士像木头一样,不知道她怎么想的,我发微信她也偶尔回复我,我真的很喜欢她,虽然刚认识没多久,这种感觉从来没有过,我每天都给她发很多消息,我现在都怕她烦了,会不会把我加黑啊,心里很矛盾,真的,找到一个自己喜欢的人和喜欢自己的人真的好难啊,好了悲催的心情就到这里吧。 我下面给大家带来的是NGINX的一些记录,因为可能要换工作了,面试的时候会问到,而且有个人老问我,他要给公司配置NGINX,我
需要使用到的服务:PXE + DHCP+TFTP+ Kickstart+ FTP 运行原理如下图: 原理和概念: 1、前言 首先,简单谈谈为什么要采用无人值守网络安装linux操作系统。一方面是运维管理的需要,因各种需要,安装操作系统在实验室内时有发生,有时候更出现批量安装某一型号操作系统的情形,这时候如果用光盘挨个安装将变得异常繁琐,并且需要人工值守。此外,因操作系统种类较多(主要是针对linux),内部人员使用频繁,也会带来管理上的问题。另一方面是当前MPX项目开发的需要,为打造一个精简、适用、高效、