Create check_ping.py

joe011 · joe011 · commit 8fe783c8e8f0 · 2013-11-20T17:59:00.000+08:00
ping&#20540;&#27979;&#35797;
diff --git a/check_ping.py b/check_ping.py
@@ -0,0 +1,36 @@
+#!/usr/bin/python 
+import multiprocessing
+import re 
+import sys
+import commands
+import datetime
+def  pinger(ip):
+	cmd='ping -c 2 %s' % (ip.strip())
+	ret = commands.getoutput(cmd)
+	loss_re=re.compile(r"received, (.*) packet loss")
+	packet_loss=loss_re.findall(ret)[0]
+	rtt_re=re.compile(r"rtt min/avg/max/mdev = (.*) ")
+	rtts=rtt_re.findall(ret)
+	#rtt.split(["/"])
+	rtt=rtts[0].split('/')
+	rtt_min=rtt[0]
+	rtt_avg=rtt[1]
+	rtt_max=rtt[2]
+	print "%s\t\t%s\t\t%s\t\t%s\t\t%s"%(ip,packet_loss,rtt_min,rtt_max,rtt_avg)
+
+def test(ip):
+    print ip
+
+if __name__ == "__main__":
+    now=datetime.datetime.now()
+    file=open('hosts.txt','r')
+    pool=multiprocessing.Pool(processes=4)
+    result=[]
+    print "########%s###########"%now
+    print "IPADDRSS\t\t\tLOSS\t\tMIN\t\tMAX\t\tAVG"
+    for i in file.readlines():
+        if len(i)==1 or i.startswith("#"):
+           continue
+        result.append(pool.apply_async(pinger,(i.strip(),))) 
+    pool.close()           
+    pool.join()
