python paramiko多线程批量修改主机账号密码

sdfwe

#!/usr/bin/env python
#-*- coding:utf:8 -*-
import paramiko,time,threading
def reset_passwd(line):
    try:
        test=paramiko.Transport((line.split()[0],22))
        test.connect(username='username',password='password')
        chan=test.open_session()
        chan.settimeout(5)
        chan.get_pty()
        chan.invoke_shell()
        chan.send('passwd\n')
        time.sleep(1)
        chan.send('password\n')
        time.sleep(1)
        chan.send('newpassword\n')
        time.sleep(1)
        chan.send('newpassword\n')
        time.sleep(1)
        chan.close()
        lock.acquire()
        successful_ip_list.append('%s: 连接成功'%(line.split()[0]))
        lock.release()
    except Exception, e:
        lock.acquire()
        failure_ip_list.append('%s: 连接失败'%(line.split()[0]))
        lock.release()
successful_ip_list = []
failure_ip_list = []
if __name__ == '__main__':
    lock = threading.Lock()
    threads = []
    start = time.time()
    # info.txt文件只有IP地址，每行一个IP地址
    info = file('info.txt','r+')
    for line in info.readlines():
        t = threading.Thread(target=reset_passwd,args=(line,))
        threads.append(t)
        t.start()
    for t in threads:t.join()
    if not successful_ip_list:print '没有成功连接信息'
    else:
        for line in successful_ip_list:print line
    print '-'*20
    if not failure_ip_list:print '没有失败连接信息'
    else:
        for line in failure_ip_list:print line
    successful_number = len(successful_ip_list)
    failure_number = len(failure_ip_list)
    end = time.time()
    print "成功连接 %s 台服务器，失败连接 %s 台服务器。共用时 %s 秒"%(successful_number,failure_number,(end - start))