资讯

精准传达 • 有效沟通

从品牌网站建设到网络营销策划,从策略到执行的一站式服务

python多线程ping2秒ping完500个ip地址

系统运维

使用模块queue 队列控制访问全局变量

创新互联建站专注为客户提供全方位的互联网综合服务,包含不限于成都网站制作、成都网站建设、南县网络推广、微信小程序开发、南县网络营销、南县企业策划、南县品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等,从售前售中售后,我们都将竭诚为您服务,您的肯定,是我们大的嘉奖;创新互联建站为所有大学生创业者提供南县建站搭建服务,24小时服务热线:028-86922220,官方网址:www.cdcxhl.com

suprocess 创建子进程生成多个shell

此脚本可用于网络割接改造时 判断各个设备的网络连通性,ip地址和设备名字均从企业配置库读取。利用队列控制变量读取。2秒之内快速ping完

#!/usr/bin/python
#-*- coding: utf-8 -*- 
from threading import Thread
import subprocess
from Queue import Queue
import pymysql
num_threads=10
q=Queue()
def pingme(i,queue):
    while True:
        ip=queue.get()
        ret=subprocess.call(\'ping -c 1 %s\' % ip[0],shell=True,stdout=open(\'/dev/null\',\'w\'),stderr=subprocess.STDOUT)
        #[接受变量字符串为命令,ping发送一个ICMP请求,并且将标准输出重定向到/dev/null,相当于丢弃,并且将标准错误输出重新定向到标准输出。
        这条语句返回其实就是ping值,就是python程序先创建shell进程,shell创建ping进程,ping进程运行返回值被shell等待,shell返回值给
        python程序wait,如果成功则为0.]
        if ret==0:  
            print \'%s-%s is up!\' %(ip[1],ip[0])
        elif ret==1:
            print \'%s is down...\'%(ip[1],ip[0])
        queue.task_done()
#start num_threads threads  
for i in range(num_threads):
    t=Thread(target=pingme,args=(i,q))#多线程调用
    t.setDaemon(True) #设置守护线程
    t.start()
db = pyMysql.connect(
    host=10.50.99.247,
    user=network,
    passwd=xxxx,
    port=3306,
    db=network,
    charset=\'utf8\')
cursor = db.cursor()
cursor.execute(select ipadd,name from net_dev where `group` like \'xxx%\' )
data = cursor.fetchall()
for i in data:
    q.put(i) #上传列表
q.join();
print \'完成\'
~

批量测试脚本


本文标题:python多线程ping2秒ping完500个ip地址
网页网址:http://cdkjz.cn/article/cheieo.html
多年建站经验

多一份参考,总有益处

联系快上网,免费获得专属《策划方案》及报价

咨询相关问题或预约面谈,可以通过以下方式与我们联系

业务热线:400-028-6601 / 大客户专线   成都:13518219792   座机:028-86922220