二、使用paramiko远程执行命令</tr></table>
1.使用用户名、密码直接远程登陆demo:
====paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(hostname=host,username=username,password=passwd,)
paramiko.util.log_to_file()
stdin,stdout,stderr=ssh.exec_command(,timeout=10)
stdout,stderr==stdout stdout (res.decode())ssh.close()
2.使用公钥私钥远程连接
demo:
host==
<span style="color: #0000ff;">import
<span style="color: #000000;"> paramiko
ssh=<span style="color: #000000;">paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())<span style="color: #008000;">#<span style="color: #008000;">设置自动添加known_hosts,一定要在connection之前
ssh.connect(username=username,hostname=host,pkey=paramiko.RSAKey.from_private_key_file(<span style="color: #800000;">'<span style="color: #800000;">/Users/fangchaoliu/.ssh/id_rsa<span style="color: #800000;">'<span style="color: #000000;">))
stdin,stderr=ssh.exec_command(<span style="color: #800000;">'<span style="color: #800000;">ifconfig<span style="color: #800000;">'<span style="color: #000000;">)
stdout,stderr=<span style="color: #000000;">stdout.read(),stderr.read()
res=stdout <span style="color: #0000ff;">if stdout <span style="color: #0000ff;">else<span style="color: #000000;"> stderr
<span style="color: #0000ff;">print(res.decode())
3.使用SSHclient封装transport
host=(,22==
=paramiko.Transport(host)
tran.connect(username=user,password====ssh.exec_command(=stdout stdout (res.decode())tran.close()
私钥是字符串:
io key_str = <span style="color: #800000;">"""<span style="color: #800000;">-----BEGIN RSA PRIVATE KEY-----
MIIEpQIBAAKCAQEAq7gLsqYArAFco02/55IgNg0r7NXOtEM3qXpb/dabJ5Uyky/8
NEHhFiQ7deHIRIuTW5Zb0kD6h6EBbVlUMBmwJrC2oSzySLU1w+ZNfH0PE6W6fans
H80whhuc/YgP+fjiO+VR/gFcqib8Rll5UfYzf5H8uuOnDeIXGCVgyHQSmt8if1+e
7hn1MVO1Lrm9Fco8ABI7dyv8/ZEwoSfh2C9rGYgA58LT1FkBRkOePbHD43xNfAYC
tfLvz6LErMnwdOW4sNMEWWAWv1fsTB35PAm5CazfKzmam9n5IQXhmUNcNvmaZtvP
c4f4g59mdsaWNtNaY96UjOfx83Om86gmdkKcnwIDAQABAoIBAQCnDBGFJuv8aA7A
ZkBLe+GN815JtOyye7lIS1n2I7En3oImoUWNaJEYwwJ8+LmjxMwDCtAkR0XwbvY+
c+nsKPEtkjb3sAu6I148RmwWsGncSRqUaJrljOypaW9dS+GO4Ujjz3/lw1lrxSUh
IqVc0E7kyRW8kP3QCaNBwArYteHreZFFp6XmtKMtXaEA3saJYILxaaXlYkoRi4k8
S2/K8aw3ZMR4tDCOfB4o47JaeiA/e185RK3A+mLn9xTDhTdZqTQpv17/YRPcgmwz
zu30fhVXQT/SuI0sO+bzCO4YGoEwoBX718AWhdLJFoFq1B7k2ZEzXTAtjEXQEWm6
01ndU/jhAasdfasdasdfasdfa3eraszxqwefasdfadasdffsFIfAsjQb4HdkmHuC
OeJrJOd+CYvdEeqJJNnF6AbHyYHIECkj0Qq1kEfLOEsqzd5nDbtkKBte6M1trbjl
HtJ2Yb8w6o/q/6Sbj7wf/cW3LIYEdeVCjScozVcQ9R83ea05J+QOAr4nAoGBAMaq
UzLJfLNWZ5Qosmir2oHStFlZpxspax/ln7DlWLW4wPB4YJalSVovF2Buo8hr8X65
lnPiE41M+G0Z7icEXiFyDBFDCtzx0x/RmaBokLathrFtI81UCx4gQPLaSVNMlvQA
539GsubSrO4LpHRNGg/weZ6EqQOXvHvkUkm2bDDJAoGATytFNxen6GtC0ZT3SRQM
WYfasdf3xbtuykmnluiofasd2sfmjnljkt7khghmghdasSDFGQfgaFoKfaawoYeH
C2XasVUsVviBn8kPSLSVBPX4JUfQmA6h8HsajeVahxN1U9e0nYJ0sYDQFUMTS2t8
RT57+WK/0ONwTWHdu+KnaJECgYEAid/ta8LQC3p82iNAZkpWlGDSD2yb/8rH8NQg
9tjEryFwrbMtfX9qn+8srx06B796U3OjifstjJQNmVI0qNlsJpQK8fPwVxRxbJS/
pMbNICrf3sUa4sZgDOFfkeuSlgACh4cVIozDXlR59Z8Y3CoiW0uObEgvMDIfenAj
98pl3ZkCgYEAj/UCSni0dwX4pnKNPm6LUgiS7QvIgM3H9piyt8aipQuzBi5LUKWw
DlQC4Zb73nHgdREtQYYXTu7p27Bl0Gizz1sW2eSgxFU8eTh+ucfVwOXKAXKU5SeI
+MbuBfUYQ4if2N/BXn47+/ecf3A4KgB37Le5SbLDddwCNxGlBzbpBa0=
-----END RSA PRIVATE KEY-----<span style="color: #800000;">"""<span style="color: #000000;">
private_key
= paramiko.RSAKey(file_obj=<span style="color: #000000;">StringIO(key_str))
transport = paramiko.Transport((<span style="color: #800000;">'<span style="color: #800000;">10.0.1.40<span style="color: #800000;">',22<span style="color: #000000;">))
transport.connect(username=<span style="color: #800000;">'<span style="color: #800000;">wupeiqi<span style="color: #800000;">',pkey=<span style="color: #000000;">private_key)
ssh =<span style="color: #000000;"> paramiko.SSHClient()
ssh._transport =<span style="color: #000000;"> transport
stdin,stderr = ssh.exec_command(<span style="color: #800000;">'<span style="color: #800000;">df<span style="color: #800000;">'<span style="color: #000000;">)
result =<span style="color: #000000;"> stdout.read()
transport.close()
<span style="color: #0000ff;">print(result)
<table style="height: 30px; background-color: #afeeee; width: 1266px; ; width: 1266px;" border="0">
<span style="color: #0000ff;">from paramiko.py3compat <span style="color: #0000ff;">import<span style="color: #000000;"> u
<span style="color: #008000;">#<span style="color: #008000;"> windows does not have termios...
<span style="color: #0000ff;">try<span style="color: #000000;">:
<span style="color: #0000ff;">import<span style="color: #000000;"> termios
<span style="color: #0000ff;">import<span style="color: #000000;"> tty
has_termios =<span style="color: #000000;"> True
<span style="color: #0000ff;">except<span style="color: #000000;"> ImportError:
has_termios =<span style="color: #000000;"> False
<span style="color: #0000ff;">def<span style="color: #000000;"> interactive_shell(chan):
<span style="color: #0000ff;">if<span style="color: #000000;"> has_termios:
posix_shell(chan)
<span style="color: #0000ff;">else<span style="color: #000000;">:
windows_shell(chan)
<span style="color: #0000ff;">def<span style="color: #000000;"> posix_shell(chan):
<span style="color: #0000ff;">import<span style="color: #000000;"> select
oldtty </span>=<span style="color: #000000;"> termios.tcgetattr(sys.stdin)
</span><span style="color: #0000ff;">try</span><span style="color: #000000;">:
tty.setraw(sys.stdin.fileno())
tty.setcbreak(sys.stdin.fileno())
chan.settimeout(</span>0.0<span style="color: #000000;">)
log </span>= open(<span style="color: #800000;">'</span><span style="color: #800000;">handle.log</span><span style="color: #800000;">'</span>,<span style="color: #800000;">'</span><span style="color: #800000;">a+</span><span style="color: #800000;">'</span>,encoding=<span style="color: #800000;">'</span><span style="color: #800000;">utf-8</span><span style="color: #800000;">'</span><span style="color: #000000;">)
flag </span>=<span style="color: #000000;"> False
temp_list </span>=<span style="color: #000000;"> []
</span><span style="color: #0000ff;">while</span><span style="color: #000000;"> True:
r,w,e </span>=<span style="color: #000000;"> select.select([chan,sys.stdin],[],[])
</span><span style="color: #0000ff;">if</span> chan <span style="color: #0000ff;">in</span><span style="color: #000000;"> r:
</span><span style="color: #0000ff;">try</span><span style="color: #000000;">:
x </span>= u(chan.recv(1024<span style="color: #000000;">))
</span><span style="color: #0000ff;">if</span> len(x) ==<span style="color: #000000;"> 0:
sys.stdout.write(</span><span style="color: #800000;">'</span><span style="color: #800000;">rn*** EOFrn</span><span style="color: #800000;">'</span><span style="color: #000000;">)
</span><span style="color: #0000ff;">break</span>
<span style="color: #0000ff;">if</span><span style="color: #000000;"> flag:
</span><span style="color: #0000ff;">if</span> x.startswith(<span style="color: #800000;">'</span><span style="color: #800000;">rn</span><span style="color: #800000;">'</span><span style="color: #000000;">):
</span><span style="color: #0000ff;">pass</span>
<span style="color: #0000ff;">else</span><span style="color: #000000;">:
temp_list.append(x)
flag </span>=<span style="color: #000000;"> False
sys.stdout.write(x)
sys.stdout.flush()
</span><span style="color: #0000ff;">except</span><span style="color: #000000;"> socket.timeout:
</span><span style="color: #0000ff;">pass</span>
<span style="color: #0000ff;">if</span> sys.stdin <span style="color: #0000ff;">in</span><span style="color: #000000;"> r:
x </span>= sys.stdin.read(1<span style="color: #000000;">)
</span><span style="color: #0000ff;">import</span><span style="color: #000000;"> json
</span><span style="color: #0000ff;">if</span> len(x) ==<span style="color: #000000;"> 0:
</span><span style="color: #0000ff;">break</span>
<span style="color: #0000ff;">if</span> x == <span style="color: #800000;">'</span><span style="color: #800000;">t</span><span style="color: #800000;">'</span><span style="color: #000000;">:
flag </span>=<span style="color: #000000;"> True
</span><span style="color: #0000ff;">else</span><span style="color: #000000;">:
temp_list.append(x)
</span><span style="color: #0000ff;">if</span> x == <span style="color: #800000;">'</span><span style="color: #800000;">r</span><span style="color: #800000;">'</span><span style="color: #000000;">:
log.write(</span><span style="color: #800000;">''</span><span style="color: #000000;">.join(temp_list))
log.flush()
temp_list.clear()
chan.send(x)
</span><span style="color: #0000ff;">finally</span><span style="color: #000000;">:
termios.tcsetattr(sys.stdin,termios.TCSADRAIN,oldtty)
<span style="color: #0000ff;">def<span style="color: #000000;"> windows_shell(chan):
<span style="color: #0000ff;">import<span style="color: #000000;"> threading
sys.stdout.write(</span><span style="color: #800000;">"</span><span style="color: #800000;">Line-buffered terminal emulation. Press F6 or ^Z to send EOF.rnrn</span><span style="color: #800000;">"</span><span style="color: #000000;">)
</span><span style="color: #0000ff;">def</span><span style="color: #000000;"> writeall(sock):
</span><span style="color: #0000ff;">while</span><span style="color: #000000;"> True:
data </span>= sock.recv(256<span style="color: #000000;">)
</span><span style="color: #0000ff;">if</span> <span style="color: #0000ff;">not</span><span style="color: #000000;"> data:
sys.stdout.write(</span><span style="color: #800000;">'</span><span style="color: #800000;">rn*** EOF ***rnrn</span><span style="color: #800000;">'</span><span style="color: #000000;">)
sys.stdout.flush()
</span><span style="color: #0000ff;">break</span><span style="color: #000000;">
sys.stdout.write(data)
sys.stdout.flush()
writer </span>= threading.Thread(target=writeall,args=<span style="color: #000000;">(chan,))
writer.start()
</span><span style="color: #0000ff;">try</span><span style="color: #000000;">:
</span><span style="color: #0000ff;">while</span><span style="color: #000000;"> True:
d </span>= sys.stdin.read(1<span style="color: #000000;">)
</span><span style="color: #0000ff;">if</span> <span style="color: #0000ff;">not</span><span style="color: #000000;"> d:
</span><span style="color: #0000ff;">break</span><span style="color: #000000;">
chan.send(d)
</span><span style="color: #0000ff;">except</span><span style="color: #000000;"> EOFError:
</span><span style="color: #008000;">#</span><span style="color: #008000;"> user hit ^Z or F6</span>
<span style="color: #0000ff;">pass</span>
<span style="color: #0000ff;">def<span style="color: #000000;"> run():
default_username =<span style="color: #000000;"> getpass.getuser()
username = input(<span style="color: #800000;">'<span style="color: #800000;">Username [%s]: <span style="color: #800000;">' %<span style="color: #000000;"> default_username)
<span style="color: #0000ff;">if len(username) ==<span style="color: #000000;"> 0:
username =<span style="color: #000000;"> default_username
hostname </span>= input(<span style="color: #800000;">'</span><span style="color: #800000;">Hostname: </span><span style="color: #800000;">'</span><span style="color: #000000;">)
</span><span style="color: #0000ff;">if</span> len(hostname) ==<span style="color: #000000;"> 0:
</span><span style="color: #0000ff;">print</span>(<span style="color: #800000;">'</span><span style="color: #800000;">*** Hostname required.</span><span style="color: #800000;">'</span><span style="color: #000000;">)
sys.exit(</span>1<span style="color: #000000;">)
tran </span>= paramiko.Transport((hostname,22<span style="color: #000000;">,))
tran.start_client()
default_auth </span>= <span style="color: #800000;">"</span><span style="color: #800000;">p</span><span style="color: #800000;">"</span><span style="color: #000000;">
auth </span>= input(<span style="color: #800000;">'</span><span style="color: #800000;">Auth by (p)assword or (r)sa key[%s] </span><span style="color: #800000;">'</span> %<span style="color: #000000;"> default_auth)
</span><span style="color: #0000ff;">if</span> len(auth) ==<span style="color: #000000;"> 0:
auth </span>=<span style="color: #000000;"> default_auth
</span><span style="color: #0000ff;">if</span> auth == <span style="color: #800000;">'</span><span style="color: #800000;">r</span><span style="color: #800000;">'</span><span style="color: #000000;">:
default_path </span>= os.path.join(os.environ[<span style="color: #800000;">'</span><span style="color: #800000;">HOME</span><span style="color: #800000;">'</span>],<span style="color: #800000;">'</span><span style="color: #800000;">.ssh</span><span style="color: #800000;">'</span>,<span style="color: #800000;">'</span><span style="color: #800000;">id_rsa</span><span style="color: #800000;">'</span><span style="color: #000000;">)
path </span>= input(<span style="color: #800000;">'</span><span style="color: #800000;">RSA key [%s]: </span><span style="color: #800000;">'</span> %<span style="color: #000000;"> default_path)
</span><span style="color: #0000ff;">if</span> len(path) ==<span style="color: #000000;"> 0:
path </span>=<span style="color: #000000;"> default_path
</span><span style="color: #0000ff;">try</span><span style="color: #000000;">:
key </span>=<span style="color: #000000;"> paramiko.RSAKey.from_private_key_file(path)
</span><span style="color: #0000ff;">except</span><span style="color: #000000;"> paramiko.PasswordRequiredException:
password </span>= getpass.getpass(<span style="color: #800000;">'</span><span style="color: #800000;">RSA key password: </span><span style="color: #800000;">'</span><span style="color: #000000;">)
key </span>=<span style="color: #000000;"> paramiko.RSAKey.from_private_key_file(path,password)
tran.auth_publickey(username,key)
</span><span style="color: #0000ff;">else</span><span style="color: #000000;">:
pw </span>= getpass.getpass(<span style="color: #800000;">'</span><span style="color: #800000;">Password for %s@%s: </span><span style="color: #800000;">'</span> %<span style="color: #000000;"> (username,hostname))
tran.auth_password(username,pw)
</span><span style="color: #008000;">#</span><span style="color: #008000;"> 打开一个通道</span>
chan =<span style="color: #000000;"> tran.open_session()
</span><span style="color: #008000;">#</span><span style="color: #008000;"> 获取一个终端</span>
<span style="color: #000000;"> chan.get_pty()
<span style="color: #008000;">#<span style="color: #008000;"> 激活器
<span style="color: #000000;"> chan.invoke_shell()
interactive_shell(chan)
chan.close()
tran.close()
<span style="color: #0000ff;">if <span style="color: #800080;">name == <span style="color: #800000;">'<span style="color: #800000;">main<span style="color: #800000;">'<span style="color: #000000;">:
run()
?带密钥方式:
<span style="color: #0000ff;">from paramiko.py3compat <span style="color: #0000ff;">import<span style="color: #000000;"> u
<span style="color: #008000;">#<span style="color: #008000;"> windows does not have termios...
<span style="color: #0000ff;">try<span style="color: #000000;">:
<span style="color: #0000ff;">import<span style="color: #000000;"> termios
<span style="color: #0000ff;">import<span style="color: #000000;"> tty
has_termios =<span style="color: #000000;"> True
<span style="color: #0000ff;">except<span style="color: #000000;"> ImportError:
has_termios =<span style="color: #000000;"> False
<span style="color: #0000ff;">def<span style="color: #000000;"> interactive_shell(chan):
<span style="color: #0000ff;">if<span style="color: #000000;"> has_termios:
posix_shell(chan)
<span style="color: #0000ff;">else<span style="color: #000000;">:
windows_shell(chan)
<span style="color: #0000ff;">def<span style="color: #000000;"> posix_shell(chan):
<span style="color: #0000ff;">import<span style="color: #000000;"> select
oldtty </span>=<span style="color: #000000;"> termios.tcgetattr(sys.stdin)
</span><span style="color: #0000ff;">try</span><span style="color: #000000;">:
tty.setraw(sys.stdin.fileno())
tty.setcbreak(sys.stdin.fileno())
chan.settimeout(</span>0.0<span style="color: #000000;">)
log </span>= open(<span style="color: #800000;">'</span><span style="color: #800000;">handle.log</span><span style="color: #800000;">'</span>,pw)
</span><span style="color: #008000;">#</span><span style="color: #008000;"> 打开一个通道</span>
chan =<span style="color: #000000;"> tran.open_session()
</span><span style="color: #008000;">#</span><span style="color: #008000;"> 获取一个终端</span>
<span style="color: #000000;"> chan.get_pty()
<span style="color: #008000;">#<span style="color: #008000;"> 激活器
<span style="color: #000000;"> chan.invoke_shell()
interactive_shell(chan)
chan.close()
tran.close()
<span style="color: #0000ff;">if <span style="color: #800080;">name == <span style="color: #800000;">'<span style="color: #800000;">main<span style="color: #800000;">'<span style="color: #000000;">:
run()
(编辑:李大同)
【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!