#!/usr/bin/env python #-*- coding:utf-8 -*- #多線程批量遠(yuǎn)程執(zhí)行一條命令 # made in chinaimport threading import sys,os import subprocess#cmd = sys.argv[2] ip_list=[] ip_fail=[]def subprocess_caller(cmd):try:p = subprocess.Popen(cmd, stdout = subprocess.PIPE, stderr = subprocess.PIPE, shell = True)output, error = p.communicate()except OSError, e:print 'SUBPROCEEE_CALLER function: execute command failed, message is %s' % ereturn dict(output = [], error = [], code = 1)else:return dict(output = output, error = error, code = 0)#cmd def run_cmd(num,ip):cmd = sys.argv[2]tmp_cmd = "ssh -o ConnectTimeout=3 -o StrictHostKeyChecking=no root@%s 2>/dev/null \"%s\" "%(ip,cmd.strip())res=subprocess_caller(tmp_cmd)#print "===================="#print "The %s is %s success"%(ip,num)#print "===================="if res['output'] != '':print "\033[1;35m The %s is succeed \033[0m \n %s \n"%(ip,res['output'])else:print "\033[1;31m The %s is failed \040"%(ip)ip_fail.append(ip)#ip def get_ip():ip_file = sys.argv[1]input = open(ip_file,'r')while True:tmp_ip = input.readline()if tmp_ip != '':#print type(tmp_ip)ip_list.append(tmp_ip.strip())else:breakinput.close()#print ip_list#多線程 def main():get_ip()threads = []nloops = range(len(ip_list))for i in nloops:t = threading.Thread(target=run_cmd,args=(i, ip_list[i]))threads.append(t)for i in nloops:threads[i].start()for i in nloops:threads[i].join()if len(ip_fail) != 0: print ip_failif __name__ == '__main__':main()

　　

轉(zhuǎn)載于:https://www.cnblogs.com/bill2014/p/8336437.html

總結(jié)

以上是生活随笔為你收集整理的python2.7多线程的批量操作远程服务器的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。