nagios网络linux平台网络流量监控插件

作者:容易

 

 

#!/usr/bin/python
from optparse import OptionParser
import re,time,sys
usage = "Usage: %prog -i INTERFACE -t TIME [-w] [-c]"
parser = OptionParser(usage=usage)
parser.add_option("-i", "--interface",
                  type="string",
                  dest="interface",
                  default='eth0',
                  help="please specify a interface,default eth0,example eth0")
parser.add_option("-t", "--time",
                  type="int",
                  dest="time",
                  default=5,
                  help="please specify time interval (s),default 5,example 5")
parser.add_option("-l", "--loop",
                  type="int",
                  dest="loop",
                  default=0,
                  help="please specify loop value,value is 1 will loop print network flow,default 0")
parser.add_option("-w", "--warning",  
                  type="int",
                  dest="warning",
                  default=6000,  
                  help="please specify the warnig thresholds for transmit,receive unit is KB,default 6000,example 1000") 
parser.add_option("-c", "--critical",  
                  type="int",
                  dest="critical",
                  default=8000,
                  help="please specify the warnig thresholds for transmit,receive unit is KB,default 8000,example 1000") 
(options, args) = parser.parse_args()
eth=options.interface
loop=options.loop
t=options.time
warning=options.warning
critical=options.critical
def get_eth_info():
        re_eth=eth + ':.*'
        eth_info=open('/proc/net/dev')
        info=eth_info.read()
        eth_info.close()
        r_eth=re.compile(re_eth)
        try:
                receive=r_eth.findall(info)[0].split(":")[1].split()[0]
        except:
                print "please specify a effective interface!"
                sys.exit(3)
        transmit=r_eth.findall(info)[0].split(":")[1].split()[8]
        return(transmit,receive)
def eth_flow():
        time1=get_eth_info()
        time.sleep(t)
        time2=get_eth_info()
        if int(time2[0]) < int(time1[0]):
             eth_transmit=int((4294967295+int(time2[0]) - int(time1[0]))/1024/t)
        else:
             eth_transmit=int((float(time2[0])-float(time1[0]))/1024/t)
        if int(time2[1]) < int(time1[1]):
             eth_receive=int((4294967295+int(time2[1]) - int(time1[1]))/1024/t)
        else:
             eth_receive=int((float(time2[1])-float(time1[1]))/1024/t)
        if eth_transmit > critical or eth_receive > critical:
                print "CRITICAL!!!%s in %d seconds network transmit and receive average(KB),transmit=%d,receive=%d |transmit=%dKB;%d;%d;receive=%dKB;%d;%d" % (eth,t, eth_transmit,eth_receive,eth_transmit,warning,critical,eth_receive,warning,critical)
                sys.exit(2)
        if eth_transmit  > warning or eth_receive > warning:
                print "warning!!%s in %d seconds network transmit and receive average(KB),transmit=%d,receive=%d |transmit=%dKB;%d;%d;receive=%dKB;%d;%d" % (eth,t, eth_transmit,eth_receive,eth_transmit,warning,critical,eth_receive,warning,critical)
                sys.exit(1)
        if eth_transmit < warning and eth_receive < warning:
                print "OK!%s in %d seconds network transmit and receive average(KB),transmit=%d,receive=%d |transmit=%dKB;%d;%d;receive=%dKB;%d;%d" % (eth,t, eth_transmit,eth_receive,eth_transmit,warning,critical,eth_receive,warning,critical)
                sys.exit(0)
        else:
                print usage
                sys.exit(3)
def loop_eth_flow ():
    time1=get_eth_info()
    print "IN %d seconds network transmit and receive average(KB)" % t
    while True:
            time.sleep(t)
            time2=get_eth_info()
            if int(time2[0]) < int(time1[0]):
                eth_transmit=int((4294967295+int(time2[0]) - int(time1[0]))/1024/t)
            else:
                eth_transmit=int((float(time2[0])-float(time1[0]))/1024/t)
            if int(time2[1]) < int(time1[1]):
                eth_receive=int((4294967295+int(time2[1]) - int(time1[1]))/1024/t)
            else:
                eth_receive=int((float(time2[1])-float(time1[1]))/1024/t)
            print "transmit=%s,receive=%s" % (eth_transmit,eth_receive)
            time1=time2
if loop==1:
    try:
        loop_eth_flow()
    except KeyboardInterrupt:
      print "User Press Ctrl+C,Exit" 
    except EOFError:
      print "User Press Ctrl+D,Exit"
else:
    try:
        eth_flow()
    except KeyboardInterrupt:
              print "User Press Ctrl+C,Exit" 
    except EOFError:
      print "User Press Ctrl+D,Exit"

 

One Response


    还没有评论!
1  

Leave your comment

请留下您的姓名(*)

请输入正确的邮箱地址(*)

请输入你的评论(*)


感谢开源 © 2016. All rights reserved.&3Q Open Source&^_^赣ICP备15012863号-1^_^
乐于分享共同进步 KreativeThemes