python的paramiko模块 支持连接交换机吗 如何利用Python的paramiko模块实现ssh互信

python \u7684paramiko\u6a21\u5757\u62a5\u9519\u95ee\u9898

\u770b\u8fd9\u91cc\uff1a
http://www.cnblogs.com/gannan/archive/2012/02/06/2339883.html

import os
import paramiko

def check(output):
# output=os.popen('service ntpd status')
for file in output:
if 'stopped' in file:
print "ntpd is stopped"
else:
print "ntpd is running"

if __name__ == 'main':
for ip in ('10.0.0.1','10.0.0.2'):
ssh = paramiko.SSHClient\uff08\uff09
ssh.set_missing_host_key_policy\uff08paramiko.AutoAddPolicy\uff08\uff09\uff09
ssh.connect\uff08ip\uff09
# check()
stdin\uff0c stdout\uff0c stderr = ssh.exec_command("service ntpd status")
check(stdout.readlines())
ssh.close()

paramiko使用

paramiko模块是基于python实现了SSH2远程安全连接，支持认证和密钥方式，可以实现远程连接、命令执行、文件传输、中间SSH代理功能

安装

pip install paramiko
或 easy_install paramiko
paramiko依赖第三方的Crypto，Ecdsa和pyhton-devel,所以需要安装

paramiko核心组件

SSHClient类

SSHClient类是SSH服务会话的高级表示，该类实现了传输、通道、以及SFTP的校验、建立的方法

• connect 方法

  connect方法实现了远程ssh连接并作校验

• hostname 连接的目标主机

• port=SSH_PORT 指定端口

• username=None 验证的用户名

• password=None 验证的用户密码

• pkey=None 私钥方式用于身份验证

• key_filename=None 一个文件名或文件列表，指定私钥文件

• timeout=None 可选的tcp连接超时时间

• allow_agent=True, 是否允许连接到ssh代理，默认为True 允许

• look_for_keys=True 是否在~/.ssh中搜索私钥文件，默认为True 允许

• compress=False, 是否打开压缩

• sock=None,

• gss_auth=False,

• gss_kex=False,

• gss_deleg_creds=True,

• gss_host=None,

• banner_timeout=None

• 参数

• exec_command方法

  远程执行命令的方法，该命令的输入与输出流为标准输入、标出输出、标准错误输出

• command 执行的命令

• bufsize=-1 文件缓冲区大小

• timeout=None

• get_pty=False

• 参数

• load_system_host_key方法

  夹在本地公钥文件，默认为~/.ssh/known_hosts

• filename=None 指定本地公钥文件

• 参数

• set_missing_host_key_policy方法
  设置连接的远程主机没有本地主机密钥或HostKeys对象时的策略，目前支持三种：

  用法：
  set_missing_host_key_policy(paramiko.AutoAddPolicy())

• AutoAddPolicy 自动添加主机名及主机密钥到本地HostKeys对象，不依赖load_system_host_key的配置。即新建立ssh连接时不需要再输入yes或no进行确认

• WarningPolicy 用于记录一个未知的主机密钥的python警告。并接受，功能上和AutoAddPolicy类似，但是会提示是新连接

• RejectPolicy 自动拒绝未知的主机名和密钥，依赖load_system_host_key的配置。此为默认选项

SFTPClient类

SFTPCLient作为一个sftp的客户端对象，根据ssh传输协议的sftp会话，实现远程文件操作，如上传、下载、权限、状态

• from_transport(cls,t) 创建一个已连通的SFTP客户端通道

• put(localpath, remotepath, callback=None, confirm=True) 将本地文件上传到服务器 参数confirm：是否调用stat()方法检查文件状态，返回ls -l的结果

• get(remotepath, localpath, callback=None) 从服务器下载文件到本地

• mkdir() 在服务器上创建目录

• remove() 在服务器上删除目录

• rename() 在服务器上重命名目录

• stat() 查看服务器文件状态

• listdir() 列出服务器目录下的文件

远程连接并执行命令

实现远程连接主机，并执行命令，同时记录日志
* 直接验证方式

• import paramiko



• host = '172.16.200.45'port = 22user = 'root'passwd = '123123'# 创建SSH对象ssh = paramiko.SSHClient()# 允许连接不在know_hosts文件中的主机ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())# 连接服务器ssh.connect(hostname=host, port=port, username=user, password=passwd)


• paramiko.util.log_to_file('syslogin.log')  #将登录信息记录日志


• # 执行命令stdin, stdout, stderr = ssh.exec_command('df')# 获取命令结果result = stdout.read()print(result)# 关闭连接ssh.close()



• SSHClient 封装 Transport

• import paramiko




• host = '172.16.200.45'port = 22user = 'root'passwd = '123123'transport = paramiko.Transport((host, port))


• transport.connect(username=user, password=passwd)



• ssh = paramiko.SSHClient()


• ssh._transport = transport



• stdin, stdout, stderr = ssh.exec_command('df')print(stdout.read())



• 基于公钥密钥连接

• import paramiko


• private_key = paramiko.RSAKey.from_private_key_file('/home/fuzengjie/.ssh/id_rsa')


• # 创建SSH对象ssh = paramiko.SSHClient()# 允许连接不在know_hosts文件中的主机ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())# 连接服务器ssh.connect(hostname='172.16.200.45', port=22, username='fuzengjie', key=private_key)


• # 执行命令stdin, stdout, stderr = ssh.exec_command('df')# 获取命令结果result = stdout.read()


• # 关闭连接ssh.close()



• SSHClient 封装 Transport 使用公钥方式

• import paramiko



• private_key = paramiko.RSAKey.from_private_key_file('/home/fuzengjie/.ssh/id_rsa')



• transport = paramiko.Transport(('172.16.200.45', 22))


• transport.connect(username='fuzengjie', pkey=private_key)



• ssh = paramiko.SSHClient()


• ssh._transport = transport



• stdin, stdout, stderr = ssh.exec_command('df')



• transport.close()



远程连接实现文件上传下载

• 基于用户名密码上传下载

• import paramiko




• host = '172.16.200.45'port = 22user = 'root'passwd = '123123'transport = paramiko.Transport((host,port))


• transport.connect(username=user,password=passwd)



• sftp = paramiko.SFTPClient.from_transport(transport)# 将location.py 上传至服务器 /tmp/test.pya = sftp.put('/Users/fuzengjie/1', '/tmp/fuzj123',confirm=True)print(a)  #打印上传到服务器上的文件状态# 将remove_path 下载到本地 local_pathsftp.get('/root/tesst.py', '/Users/fuzengjie/test.py')



• transport.close()



• 基于公钥密钥上传下载

• import paramiko




• private_key = paramiko.RSAKey.from_private_key_file('/home/fuzengjie/.ssh/id_rsa')




• transport = paramiko.Transport(('172.16.200.45', 22))


• transport.connect(username='fuzengjie', pkey=private_key )




• sftp = paramiko.SFTPClient.from_transport(transport)# 将location.py 上传至服务器 /tmp/test.pysftp.put('/tmp/location.py', '/tmp/test.py')# 将remove_path 下载到本地 local_pathsftp.get('/root/123.txt', '/tmp/123')




• transport.close()



堡垒机实现

• 架构

堡垒机的主要作用权限控制和用户行为审计，堡垒机就像一个城堡的大门，城堡里的所有建筑就是你不同的业务系统 ， 每个想进入城堡的人都必须经过城堡大门并经过大门守卫的授权，每个进入城堡的人必须且只能严格按守卫的分配进入指定的建筑，且每个建筑物还有自己的权限访问控制，不同级别的人可以到建筑物里不同楼层的访问级别也是不一样的。还有就是，每个进入城堡的人的所有行为和足迹都会被严格的监控和纪录下来，一旦发生犯罪事件，城堡管理人员就可以通过这些监控纪录来追踪责任人。 


• 堡垒机执行流程：

管理员为用户在服务器上创建账号（将公钥放置服务器，或者使用用户名密码）
用户登陆堡垒机，输入堡垒机用户名密码，现实当前用户管理的服务器列表
用户选择服务器，并自动登陆
执行操作并同时将用户操作记录

• 代码

• import paramikoimport sysimport osimport socketimport getpassfrom paramiko.py3compat import u# windows does not have termios...try:    import termios    import tty


•    has_termios = Trueexcept ImportError:


•    has_termios = Falsedef interactive_shell(chan):    if has_termios:


•        posix_shell(chan)    else:


•        windows_shell(chan)def posix_shell(chan):    import select



•    oldtty = termios.tcgetattr(sys.stdin)    try:


•        tty.setraw(sys.stdin.fileno())


•        tty.setcbreak(sys.stdin.fileno())


•        chan.settimeout(0.0)


•        log = open('handle.log', 'a+', encoding='utf-8')


•        flag = False


•        temp_list = []        while True:


•            r, w, e = select.select([chan, sys.stdin], [], [])            if chan in r:                try:


•                    x = u(chan.recv(1024))                    if len(x) == 0:


•                        sys.stdout.write('
  *** EOF
  ')                        break


•                    if flag:                        if x.startswith('
  '):                            pass


•                        else:


•                            temp_list.append(x)


•                        flag = False


•                    sys.stdout.write(x)


•                    sys.stdout.flush()                except socket.timeout:                    pass


•            if sys.stdin in r:


•                x = sys.stdin.read(1)                import json                if len(x) == 0:                    break



•                if x == '':


•                    flag = True                else:


•                    temp_list.append(x)                if x == '':


•                    log.write(''.join(temp_list))


•                    log.flush()


•                    temp_list.clear()


•                chan.send(x)    finally:


•        termios.tcsetattr(sys.stdin, termios.TCSADRAIN, oldtty)def windows_shell(chan):    import threading



•    sys.stdout.write("Line-buffered terminal emulation. Press F6 or ^Z to send EOF.
  
  ")    def writeall(sock):        while True:


•            data = sock.recv(256)            if not data:


•                sys.stdout.write('
  *** EOF ***
  
  ')


•                sys.stdout.flush()                break


•            sys.stdout.write(data)


•            sys.stdout.flush()



•    writer = threading.Thread(target=writeall, args=(chan,))


•    writer.start()    try:        while True:


•            d = sys.stdin.read(1)            if not d:                break


•            chan.send(d)    except EOFError:        # user hit ^Z or F6


•        passdef run():


•    default_username = getpass.getuser()


•    username = input('Username [%s]: ' % default_username)    if len(username) == 0:


•        username = default_username




•    hostname = input('Hostname: ')    if len(hostname) == 0:        print('*** Hostname required.')


•        sys.exit(1)



•    tran = paramiko.Transport((hostname, 22,))


•    tran.start_client()



•    default_auth = "p"


•    auth = input('Auth by (p)assword or (r)sa key[%s] ' % default_auth)    if len(auth) == 0:


•        auth = default_auth    if auth == 'r':


•        default_path = os.path.join(os.environ['HOME'], '.ssh', 'id_rsa')


•        path = input('RSA key [%s]: ' % default_path)        if len(path) == 0:


•            path = default_path        try:


•            key = paramiko.RSAKey.from_private_key_file(path)        except paramiko.PasswordRequiredException:


•            password = getpass.getpass('RSA key password: ')


•            key = paramiko.RSAKey.from_private_key_file(path, password)


•        tran.auth_publickey(username, key)    else:


•        pw = getpass.getpass('Password for %s@%s: ' % (username, hostname))


•        tran.auth_password(username, pw)    # 打开一个通道


•    chan = tran.open_session()    # 获取一个终端    chan.get_pty()    # 激活器    chan.invoke_shell()



•    interactive_shell(chan)



•    chan.close()


•    tran.close()if __name__ == '__main__':


•    run()


•  

绾共璐!python 鍦ㄨ繍缁翠腑鐨勫簲鐢 (涓):鎵归噺 ssh/sftp
绛旓細涓嶈兘鐩存帴浼犵洰褰曪紝閭ｆ崲涓濊矾锛岄亶鍘嗚矾寰勪腑鐨勭洰褰曞拰鏂囦欢锛屽厛鍒涘缓鐩綍鍐嶄紶鏂囦欢灏辫兘杈惧埌涓鏍风殑鏁堟灉浜嗐傚湪paramiko鐨剆ftp涓璼ftp.listdir_attr()鏂规硶鍙互鑾峰彇杩滅▼璺緞涓殑鏂囦欢銆佺洰褰曚俊鎭傞偅涔堟垜浠彲浠ュ啓涓涓掑綊鏉ラ亶鍘嗚繙绋嬭矾寰勪腑鐨勬墍鏈夋枃浠跺拰鐩綍(浼犲叆涓涓垪琛ㄦ槸涓轰簡鎺ユ敹閫掑綊杩斿洖鐨勫)銆python鑷甫鐨刼s妯″潡涓殑...

paramiko pip瀹夎鍜屾簮鐮佸畨瑁呮湁浠涔堝尯鍒
绛旓細Distribute 鍜 PIP閮芥槸python瀹夎鍖呯殑宸ュ叿锛宲ython瀹夎鍖呯殑宸ュ叿鏈塭asy_install, setuptools, pip锛宒istribute銆備娇鐢ㄨ繖浜涘伐鍏烽兘鑳戒笅杞藉苟瀹夎django銆侱istribute鏄鏍囧噯搴揹isutils妯″潡鐨勫寮猴紝鎴戜滑鐭ラ亾disutils涓昏鏄敤鏉ユ洿鍔犲鏄撶殑鎵撳寘鍜屽垎鍙戝寘锛岀壒鍒槸瀵瑰叾浠栫殑鍖呮湁渚濊禆鐨勫寘銆傚畨瑁匘istribute 鍙互閫氳繃distribute_setup...

python paramiko ssh鐧诲綍鎬濈浜ゆ崲鏈烘墽琛屽懡浠ゅ鏉″懡浠ら棶棰
绛旓細瑙ｅ喅浜嗗晩锛屼笉杩囦笉鏄敤鐨 stdin,stdout,stderr=client.exec_command('show arp;show clock')鐢ㄨ繖绉嶆柟娉曞彧鑳藉紕涓鏉″懡浠 鐢ㄤ笅闈㈣繖涓 chan= client.invoke_shell()chan.send('en\n')chan.send("password\n")chan.send('show log\n')result = chan.recv(100000).decode()鐢ㄤ簡杩欎釜鍙兘杩樻湁鍒殑闂...

python閫氳繃paramiko妯″潡ssh鐧婚檰linux瀹㈡埛绔,鎵ц闇瑕佽緭鍏 yes/no 鎴...
绛旓細r = raw_input('[y]es/[n]o')if r[0] == 'y':...elif r[0] == 'n':...

瀹岀編鍥介檯鍜嬭 鏂囦欢绌块棬鍟
绛旓細闄や簡浣跨敤涓撻棬鐨勮蒋浠跺伐鍏峰锛岃繕鍙互閫氳繃缂栧啓鑴氭湰鏉ュ疄鐜版枃浠剁┛闂ㄣ備緥濡傦紝鍙互浣跨敤Python鐨刾aramiko搴撴潵缂栧啓涓涓嚜鍔ㄥ寲鑴氭湰锛岄氳繃SSH杩炴帴鍒拌繙绋嬫湇鍔″櫒骞朵紶杈撴枃浠躲傝繖绉嶆柟娉曢渶瑕佷竴瀹氱殑缂栫▼鐭ヨ瘑锛屼絾鍙互瀹炵幇鏇村鏉傜殑鏂囦欢浼犺緭闇姹傦紝骞跺彲浠ヤ笌鍏朵粬绯荤粺鎴栧伐鍏疯繘琛岄泦鎴愩傛荤殑鏉ヨ锛屽疄鐜板畬缇庡浗闄呬腑鐨勬枃浠剁┛闂ㄩ渶瑕佹牴鎹叿浣撶殑...

CRT绠鏄撹剼鏈?
绛旓細涓轰簡瀹炵幇杩欎釜鍔熻兘锛屾垜浠渶瑕佺敤鍒 Python 鐨涓浜涘熀纭妯″潡锛屽 os銆乼ime 鍜 paramiko銆傛垜浠彲浠ヤ娇鐢 paramiko 妯″潡鏉ヨ繛鎺ュ埌鏈嶅姟鍣ㄥ拰绔彛锛屽苟鎵ц鍛戒护銆俹s 妯″潡鍙互鐢ㄦ潵璇诲彇璁颁簨鏈枃浠朵腑鐨勫懡浠わ紝骞朵娇鐢 time 妯″潡鏉ヨ缃墽琛屽懡浠ょ殑鏃堕棿闂撮殧銆備互涓嬫槸涓涓ず渚嬭剼鏈紝瀹冨疄鐜颁簡涓婅堪鍔熻兘锛氶渶瑕佹敞鎰忕殑鏄紝涓婇潰鐨勮剼鏈笉...

瀛︿細浜python鑳藉仛浠涔?
绛旓細Python瀵逛簬鏈嶅姟鍣ㄨ繍缁磋岃█涔熸湁鍗佸垎閲嶈鐨勭敤閫斻傜敱浜庣洰鍓嶅嚑涔庢墍鏈塋inux鍙戣鐗堜腑閮借嚜甯︿簡Python瑙ｉ噴鍣紝浣跨敤Python鑴氭湰杩涜鎵归噺鍖栫殑鏂囦欢閮ㄧ讲鍜岃繍琛岃皟鏁撮兘鎴愪簡Linux鏈嶅姟鍣ㄤ笂寰堜笉閿欑殑閫夋嫨銆Python涓涔熷寘鍚澶氭柟渚跨殑宸ュ叿锛屼粠璋冩帶ssh/sftp鐢鐨刾aramiko锛屽埌鐩戞帶鏈嶅姟鐢ㄧ殑supervisor锛屽啀鍒癰azel绛夋瀯寤哄伐鍏凤紝鐢氳嚦conan绛夌敤浜...

Python 甯哥敤鐨勬爣鍑嗗簱浠ュ強绗笁鏂瑰簱鏈夊摢浜
绛旓細cProfile python鎬ц兘娴嬮噺妯″潡 glob 绫讳技涓巐istfile锛屽彲浠ョ敤鏉ユ煡鎵炬枃浠 atexit 鏈変竴涓敞鍐屽嚱鏁帮紝鍙敤浜庢濂藉湪鑴氭湰閫鍑鸿繍琛屽墠鎵ц涓浜涗唬鐮 dis python 鍙嶆眹缂栵紝褰撳鏌愭潯璇彞涓嶇悊瑙ｅ師鐞嗘椂锛屽彲浠ョ敤dis.dis 鍑芥暟鏉ユ煡鐪嬩唬鐮佸搴旂殑python 瑙ｉ噴鍣ㄦ寚浠ょ瓑绛夈3th libs:paramiko https://github.com/paramiko/paramiko ...

python鑾峰彇telnet灞忔樉
绛旓細Python鑾峰彇telnet灞忔樉鐨勫師鍥犳槸閫氳繃telnetlib搴撴彁渚涚殑Telnet绫伙紝鍙互瀹炵幇涓巘elnet鏈嶅姟鍣ㄥ缓绔嬭繛鎺ワ紝骞堕氳繃send鍜宔xpect鏂规硶鍙戦佸拰鎺ユ敹鏁版嵁銆俆elnet绫讳腑鐨剅ead_very_eager()鏂规硶鍙互鑾峰彇telnet灞忓箷涓婄殑杈撳嚭淇℃伅銆傛嫇灞曪細Telnet鏄竴绉嶅熀浜嶵CP/IP鍗忚鐨勮繙绋嬬櫥褰曞拰绠＄悊鍗忚锛岄氳繃Telnet鍙互杩滅▼鐧诲綍鍒版湇鍔″櫒鎴栫綉缁滆澶囪繘琛...

濡備綍瀹夎pycrypto-2.6.win-amd64-py2.7
绛旓細1锛夊皢python2.x瀹夎璺緞鍔犲叆鐜鍙橀噺path銆2锛夋寜鐓yCrypto readme 鐨勬寚绀哄畨瑁 python setup.py build -> python setup.py install -> python setup.py test.鏈鍚庢祴璇曠殑鏃跺欏彲鑳戒細鏄剧ず鏈夐敊锛屾病鍏崇郴锛屼笉绠″畠銆備负 浜嗗噺灏戦敊璇紝鏈濂戒笅杞絇yCrypto绋冲畾鐗堛傚畨瑁呭畬鎴怭yCrypto鍚庡畨瑁協abric浠ュ強Paramiko閮戒笉浼氭湁...

扩展阅读：paypal官网入口 ... photoshop永久免费版 ... 黑马java视频 ... paperpass免费入口 ... 中文版pubmed破解版 ... pubmed官方官网入口 ... wordpress永久免费 ... ph官网下载入口 ... python网站入口免费 ...