import paramiko# 创建SSH对象
ssh = paramiko.SSHClient()
# 允许连接不在know_hosts文件中的主机
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
# 连接服务器
ssh.connect(hostname='192.168.30.129', port=22, username='sunqi', password='43797189')# 执行命令
stdin, stdout, stderr = ssh.exec_command('df')
# 获取命令结果
result = stdout.read()# 关闭连接
ssh.close()

 1 import paramiko
 2
 3 ssh = paramiko.SSHClient()
 4 ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy)
 5 ssh.connect(hostname='192.168.30.129',port=22,username='root',password='43797189')#测试机器为Linux虚拟机（CentOS 7）
 6 while True:
 7     cmd = input('>>:')
 8     stdin,stdout,stderr = ssh.exec_command(cmd)
 9     result = stdout.read()
10     if stdout:
11         print(str(result,'utf8'))
12     else:
13         print(str(stderr.read(),'utf8'))
14
15 ssh.close()

import paramiko'''
从windows上传文件到Linux虚拟机
IP地址： 192.168.30.129
端口：22
'''
host = '192.168.30.129'
port = 22t = paramiko.Transport((host,port))
t.connect(username="root",password='43797189',)
sftp = paramiko.SFTPClient.from_transport(t)
target_path = '/var/log/windows.log'
local_path = 'E:\\sunqi.log'
sftp.put(local_path,target_path)
t.close()

host_dic = {'group1':{'C1':{'host':'192.168.30.129','port':22,'username':'root','password':'43797189'},'C2':{'host':'192.168.30.130','port':22,'username':'root','password':'43797189'},'C3':{'host':'192.168.30.131','port':22,'username':'root','password':'43797189'}},'group2':{'C4':{'host':'192.168.30.132','port':22,'username':'root','password':'43797189'},'C5':{'host':'192.168.30.134','port':22,'username':'root','password':'43797189'},'C6':{'host':'192.168.30.135','port':22,'username':'root','password':'43797189'},}
}

import threading
import paramiko
import os
from paramiko模块.批量主机管理小项目.host_dir import host_dic'''
主机批量管理程序
实现多个主机的同时管理
利用多线程以及paramiko模块
实现多个主机同时执行命令，上传或下载文件
'''
class host_manage():def __init__(self,host,port,username,password):self.host = hostself.port = portself.username = usernameself.password = passworddef command(self,cmd):ssh = paramiko.SSHClient()ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy)ssh.connect(hostname=self.host,port=self.port,username=self.username,password=self.password)#cmd = input(">>:")stdin, stdout, stderr = ssh.exec_command(cmd)result = stdout.read()if stdout:print(str(result, 'utf8'))else:print(str(stderr.read(), 'utf8'))def upload(self):t = paramiko.Transport(self.host,self.port)t.connect(username=self.username,password=self.password)sftp = paramiko.SFTPClient.from_transport(t)target_path = '/var/log/windows.log'local_path = 'E:\\sunqi.log'sftp.put(local_path,target_path)t.close()passdef download(self):pass
def choose_group():print('可管理主机分组')for k in host_dic:print(k)for i in host_dic[k]:print(host_dic[k][i])group_num = input('>>:选择主机编号')return  group_num
def run():num = choose_group()print('已选组号：%s' %num)selected = input(">>:输入即将进行的操作：command、upload、download")if selected =="command":cmd = input('>>:请输入要批量操作的命令：')thread_conut = []for i in host_dic[num]:func = host_manage(host=host_dic[num][i]['host'],port=host_dic[num][i]['port'],username=host_dic[num][i]['username'],password=host_dic[num][i]['password'])if hasattr(func,selected):p = threading.Thread(target=getattr(func,selected),args=(cmd,))thread_conut.append(p)p.start()for i in thread_conut:i.join()if __name__ == '__main__':run()