python抓取cacti的流量图-创新互联

  有一个功能需求,每天在cacti上爬取昨天一整天的流量图,并将流量图上的min、max、average流量做成表格,用邮件发出。 (python2.7.5)

成都网络公司-成都网站建设公司创新互联公司十余年经验成就非凡,专业从事成都网站设计、网站建设,成都网页设计,成都网页制作,软文营销广告投放等。十余年来已成功提供全面的成都网站建设方案,打造行业特色的成都网站建设案例,建站热线:13518219792,我们期待您的来电!

  1、需要使用的模块

#!/usr/bin/env python
#-*- coding: UTF-8 -*-
import time,datetime,cookielib,requests,sys,re,urllib2,urllib,socket,csv,heapq
import smtplib
import mimetypes
import time
from email.mime.text import MIMEText
from email.mime.multipart import MIMEMultipart
from email.mime.base import MIMEBase
from email import encoders
from email.MIMEImage import MIMEImage
default_encoding = 'utf-8'
if sys.getdefaultencoding() != default_encoding:
    reload(sys)

  2、登陆cacti的函数

def Login1():
    socket.setdefaulttimeout(10)
    global headers
    headers={}
    cj = cookielib.CookieJar()
    global opener
    opener = urllib2.build_opener(urllib2.HTTPCookieProcessor(cj))

    # cacti使用的账号密码
    data = urllib.urlencode( {'action':'login','login_username':'admin','login_password':'123456' })
    # 打开cacti主页
    page = urllib2.Request("http://100.0.102.3/index.php", data ,headers)
    # 爬取页面数据
    html = opener.open(page).read()
    # 如果页面数据中有graph_settings.php链接,说明登陆成功(返回1),反之登陆失败(返回0)
    if re.findall("graph_settings.php",html):
        return 1
    else:
        return 0

  3、再定义几个需要用到的函数

# 日期转换为时间戳(cacti的图片网址需要指定开始和结束时间)
def datetime_timestamp(dt):
     time.strptime(dt, '%Y-%m-%d %H:%M:%S')
     s = time.mktime(time.strptime(dt, '%Y-%m-%d %H:%M:%S'))
     return int(s)

# 将bit换算成Gbit/Mbit/Kbit(各级相差1000倍,保留2位小数)
def tobit(x):
    if x>=1000000000:
        return str(round(x/1000000000,2))+'G'
    elif x>=1000000:
        return str(round(x/1000000,2))+'M'
    elif x>=1000:
        return str(round(x/1000,2))+'K'
    else:
        return str(round(x,2))

  4、开始抓取图片和csv(如下图,图片右边的蓝色下载箭头就是csv)。
python抓取cacti的流量图
python抓取cacti的流量图

try:
    # 如果登陆成功
    if Login1()==1:
        # 流量图的开始时间,昨天的00:00:00
        start_time=str(datetime_timestamp((datetime.datetime.today()-datetime.timedelta(days=1)).strftime('%Y-%m-%d 00:00:00')))
        # 流量图的结束时间,今天的00:00:00
        end_time=str(datetime_timestamp(datetime.datetime.today().strftime('%Y-%m-%d 00:00:00')))

        # 昨天一整天的流量图网址(2687是图片id)
        url1="http://100.0.102.3/graph_image.php?action=zoom&local_graph_id=2687&rra_id=0&view_type=&graph_start="+start_time+"&graph_end="+end_time
        # 下载图片,保存到本地
        request = urllib2.Request(url1, None ,headers)
        res = opener.open(request).read()
        f=open("/myftpdir/2687.png","wb")
        f.write(res)
        f.close()
        # 下载图片对应的csv(用于读取max、min等数值)
        url2="http://100.0.102.3/graph_xport.php?local_graph_id=2687&rra_id=0&view_type=&graph_start="+start_time+"&graph_end="+end_time
        request = urllib2.Request(url2, None ,headers)
        res = opener.open(request).read()
        f=open("/myftpdir/2687.csv","wb")
        f.write(res)
        f.close()

        # 读取这个csv文件
        f=open('/myftpdir/2687.csv','rb')
        reader = csv.reader(f)
        # csv保存了每5分钟的平均上传(outbound)和下载(inbound)速率(共288行),生成2个列表来存储所有的上传速率和下载速率
        inbounds=[]
        outbounds=[]

        n=0
        for row in reader:
            # 该表格的第11行到298行是速率
            if n>=10 and n<=297:
                # 如果数据显示NaN,则表示cacti当时获取数据失败,这种情况不做存储
                # csv第1列是时间,第2列是inbound,第3列是outbound
                if row[1]!='NaN':
                    inbounds.append(float(row[1]))
                if row[2]!='NaN':
                    outbounds.append(float(row[2]))            
            n+=1

        # inbound平均速率=inbounds列表的所有速率总和/列表长度(就是存储的速率个数),并换算单位
        inbound_ave1=tobit(float(reduce(lambda x,y:x+y,inbounds)/len(inbounds)))
        # inbounds列表的最小值
        inbound_min1=tobit(heapq.nsmallest(1,inbounds)[0])
        # inbounds列表的大值
        inbound_max1=tobit(heapq.nlargest(1,inbounds)[0])
        # 同样方法计算outbound的平均速率、大速率、最小速率
        outbound_min1=tobit(heapq.nsmallest(1,outbounds)[0])
        outbound_max1=tobit(heapq.nlargest(1,outbounds)[0])
        outbound_ave1=tobit(float(reduce(lambda x,y:x+y,outbounds)/len(outbounds)))

  5、发送邮件


        # 指定发件人、收件人、标题等
        msg = MIMEMultipart('related')
        msg['From'] = "1111111@qq.com"
        # 邮件标题按要求做成”X年X月X日报表“
        msg['Subject'] =str((datetime.datetime.today()-datetime.timedelta(days=1)).strftime('%Y'))+u'年'+str((datetime.datetime.today()-datetime.timedelta(days=1)).strftime('%m'))+u'月'+str((datetime.datetime.today()-datetime.timedelta(days=1)).strftime('%d'))+u'日报表'
        msg['To']="111111@qq.com"
        toaddrs = [msg['To']]

        msgAlternative = MIMEMultipart('alternative')
        msg.attach(msgAlternative)

        # 流量图加入邮件正文
        fp = open('/myftpdir/2687.png', 'rb')
        msgImage = MIMEImage(fp.read())
        fp.close()
        msgImage.add_header('Content-ID', '')
        msg.attach(msgImage)

        # 邮件正文,因为要添加图片和表格,所以不能用纯文本格式,改用html格式
        msgText = MIMEText('''
            
流量图:

出口 最小值 平均值 大值
inbound %s %s %s
outbound %s %s %s
''' % (inbound_min1,inbound_ave1,inbound_max1,outbound_min1,outbound_ave1,outbound_max1), 'html', 'utf-8') msgAlternative.attach(msgText) # 连接邮箱服务器 server = smtplib.SMTP() server.connect('smtp.qq.com',25) server.ehlo() server.login('111111@qq.com','123456') server.sendmail(msg['From'],toaddrs,msg.as_string()) server.quit() except: # 登陆失败 pass

  邮件内容:

python抓取cacti的流量图

另外有需要云服务器可以了解下创新互联cdcxhl.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


本文名称:python抓取cacti的流量图-创新互联
本文URL:http://scyanting.com/article/djdioo.html