1 #-*- coding: utf-8 -*-
2 #批量操作linux服务器（执行命令，上传，下载）
3 #!/usr/bin/python
4 import paramiko
5 import datetime
6 import os
7 import threading
8 def ssh2(ip,username,passwd,cmd):
9 try:
10 paramiko.util.log_to_file(‘paramiko________.log‘)
11 ssh = paramiko.SSHClient()
12 ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
13 ssh.connect(ip,22,username,passwd,timeout=5)
14 for m in cmd:
15 stdin,stdout,stderr = ssh.exec_command(m)
16 #stdin.write("Y") #简单交互，输入 ‘Y’
17 out = stdout.readlines()
18 # outerr = stderr.readlines()
19 #屏幕输出
20 for o in out:
21 print o,
22 # for i in outerr:
23 # print i,
24 print ‘%s\tOK\n‘%(ip)
25 ssh.close()
26 except :
27 print ‘%s\tError\n‘%(ip)
28 def download(ip, username, passwd, local_dir, remote_dir):
29 try:
30 paramiko.util.log_to_file(‘paramiko_download.log‘)
31 t = paramiko.Transport((ip,22))
32 t.connect(username=username,password=passwd)
33 sftp = paramiko.SFTPClient.from_transport(t)
34 files = sftp.listdir(remote_dir)
35
36
37 for f in files:
38 print ‘‘
39 print ‘############################‘
40 print ‘Beginning to download file from %s %s ‘ % (ip, datetime.datetime.now())
41 print ‘Downloading file:‘, os.path.join(remote_dir, f)
42 sftp.get(os.path.join(remote_dir, f), os.path.join(local_dir, f))#下载
43 print ‘Download file success %s ‘ % datetime.datetime.now()
44 print ‘‘
45 print ‘############################‘
46 t.close()
47 except:
48 print "connect error!"
49
50
51 def upload(ip, username, passwd, local_dir, remote_dir):
52 try:
53 paramiko.util.log_to_file(‘paramiko_upload.log‘)
54 t = paramiko.Transport((ip, 22))
55 t.connect(username=username, password=passwd)
56 sftp = paramiko.SFTPClient.from_transport(t)
57 #files = sftp.listdir(remote_dir)
58 files = os.listdir(local_dir)
59 for f in files:
60 print ‘‘
61 print ‘############################‘
62 print ‘Beginning to upload file to %s %s ‘ % (ip, datetime.datetime.now())
63 print ‘Uploading file:‘, os.path.join(local_dir, f)
64 sftp.put(os.path.join(local_dir, f), os.path.join(remote_dir, f))#上传
65 print ‘Upload file success %s ‘ % datetime.datetime.now()
66 print ‘‘
67 print ‘############################‘
68 t.close()
69 except:
70 print "connect error!"
71 print ip, "fail!"
72
73
74 if __name__==‘__main__‘:
75 # cmd = [‘ls -lh /export/servers/mysql/log/mysql.log‘]#你要执行的命令列表
76 cmds=open("D:\\batch\\cmds.txt") #从文件读取命令
77 cmd=cmds.readlines()
78 cmds.close()
79 username = "root" #用户名
80 #passwd = "xxxx" #单台服务器时启用----------------------
81 #ip=‘192.168.12.19‘ #单台服务器时启用----------------------
82 local_dir = "D:\\batch\\tmp" #本地服务器目录
83 remote_dir = "/tmp/" #远程服务器目录
84 #threads = [] #多线程
85 print "Begin......"
86 hosts=open("D:\\batch\\list.txt") #本地服务器列表
87 host=hosts.readlines()
88 hosts.close()
89 for list in host:
90 line = list.split()
91 ip = line[0].strip()
92 pwd = line[1].strip()
93 # print ip,
94 # print pwd,
95 # b=threading.Thread(target=upload,args=(ip,username,pwd,local_dir,remote_dir))
96 # b.start()
97 a=threading.Thread(target=ssh2,args=(ip,username,pwd,cmd))
98 a.start()
