35 lines
1.3 KiB
Python
35 lines
1.3 KiB
Python
import paramiko
|
||
|
||
'''
|
||
思路：使用paramiko工具连接服务器，并将执行命令的结果返回给程序，这里我们使用了sshclient方法\
|
||
首先定义类，构造函数中传入了需要用到的属性 账号信息，定义op方法实现执行命令功能。
|
||
'''
|
||
class sshd():
|
||
def __init__(self,hostname,passwd,port=22,username='root'): # 定义函数传入连接远程用到的属性
|
||
self.ssh = paramiko.SSHClient() # 调用sshclient方法
|
||
self.hostname=hostname # 转换属性
|
||
self.port = port
|
||
self.username = username
|
||
self.passwd = passwd
|
||
def op(self,cmd):
|
||
self.ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) # 允许连接不在know_hosts里的主机
|
||
self.ssh.connect(hostname=self.hostname,
|
||
port=self.port,
|
||
username=self.username,
|
||
password=self.passwd)
|
||
stdin, stdout, stderr = self.ssh.exec_command(cmd)
|
||
self.stdin = stdin
|
||
self.stdout= str(stdout.read(),encoding='utf-8') #将结果返回并解码
|
||
self.stderr= str(stderr.read(),encoding='utf-8')
|
||
self.ssh.close()
|
||
if self.stdout:
|
||
return self.stdout
|
||
else:
|
||
return self.stderr
|
||
def __str__(self):
|
||
return 'QianFeng cloud computing testing'
|
||
if __name__ == '__main__':
|
||
aa = sshd(hostname='172.16.147.151',passwd='1')
|
||
s = aa.op('ls /root')
|
||
print(s,end="")
|