建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
利用paramiko庫執(zhí)行命令時如何在超出給定的時間后強制退出-創(chuàng)新互聯(lián)
利用paramiko庫執(zhí)行命令時如何在超出給定的時間后強制退出？很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細講解，有這方面需求的人可以來學習下，希望你能有所收獲。
實現(xiàn)方式：
線程+事件，在線程中執(zhí)行ssh命令，給事件配置超時時間。
代碼示例：
1 from threading import Thread, Event
2 import paramiko
class SshClient(object): def __init__(self, ip, port, username, password): self.ip = ip self.host = host self.username = username self.password = password def exec_command(cmd, timeout): log.info(u"在ip:%s上執(zhí)行命令%s" % (self.ip, cmd)) sc = paramiko.SSHClient() sc.set_missing_host_key_policy(paramiko.AutoAddPolicy()) # 用來接收stdout stderror status信息 res = [None, None, None] def get_return(start_event, res_list): _, cmd_stdout, cmd_stderr = sc.exec_command(command=cmd, timeout=timeout) channel = cmd_stdout.channel cmd_status = channel.recv_exit_status() res_list[0] = cmd_stdout res_list[1] = cmd_stderr res_list[2] = cmd_status start_event.set() # 表示線程已經(jīng)執(zhí)行完畢 try: sc.connect(hostname=self.ip, port=self.port, username=self.username, password=self.password, timeout=30) # 這里的timeout是連接使用的，與我們要的不同 start_evt = Event() t = Thread(target=get_return, args=(start_evt, res)) t.start() start_evt.wait(timeout=timeout) # 執(zhí)行到這里說明線程已經(jīng)退出 if None in res: raise Exception(u"命令超時退出") stdout, stderr, status = res if status != 0: raise Exception(u"命令執(zhí)行返回非0！返回值為%s,錯誤信息為%s" % (status, stdout.read() + stderr.read())) return stdout.read() + stderr.read() finally: sc.close() }
知識點補充：
python paramiko的使用介紹
一： 使用paramiko
#設置ssh連接的遠程主機地址和端口
t=paramiko.Transport((ip,port))
#設置登錄名和密碼
t.connect(username=username,password=password)
#連接成功后打開一個channel
chan=t.open_session()
#設置會話超時時間
chan.settimeout(session_timeout)
#打開遠程的terminal
chan.get_pty()
#激活terminal
chan.invoke_shell()
然后就可以通過chan.send('command')和chan.recv(recv_buffer)來遠程執(zhí)行命令以及本地獲取反饋。
二： paramiko的兩個模塊介紹
paramiko有兩個模塊SSHClient()和SFTPClient()
SSHClient()的使用代碼:
import paramiko
ssh = paramiko.SSHClient() # 創(chuàng)建SSH對象
# 允許連接不在know_hosts文件中的主機
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
# 連接服務器
ssh.connect(hostname='192.168.2.103', port=22, username='root', password='123456')
stdin, stdout, stderr = ssh.exec_command('ls') # 執(zhí)行命令
result = stdout.read() # 獲取命令結果
print (str(result,encoding='utf-8'))
ssh.close() # 關閉連接SSHClient()里有個transport變量,是用于獲取連接，我們也可單獨的獲取到transport變量，然后執(zhí)行連接操作
import paramiko
transport = paramiko.Transport(('192.168.2.103', 22))
transport.connect(username='root', password='123456')
ssh = paramiko.SSHClient()
ssh._transport = transport
stdin, stdout, stderr = ssh.exec_command('df')
print (str(stdout.read(),encoding='utf-8'))
transport.close()用transport實現(xiàn)上傳下載以及命令的執(zhí)行：
#coding:utf-8
import paramiko
import uuid
class SSHConnection(object):
def __init__(self, host='192.168.2.103', port=22, username='root',pwd='123456'):
self.host = host
self.port = port
self.username = username
self.pwd = pwd
self.__k = None
def connect(self):
transport = paramiko.Transport((self.host,self.port))
transport.connect(username=self.username,password=self.pwd)
self.__transport = transport
def close(self):
self.__transport.close()
def upload(self,local_path,target_path):
# 連接，上傳
# file_name = self.create_file()
sftp = paramiko.SFTPClient.from_transport(self.__transport)
# 將location.py 上傳至服務器 /tmp/test.py
sftp.put(local_path, target_path)
def download(self,remote_path,local_path):
sftp = paramiko.SFTPClient.from_transport(self.__transport)
sftp.get(remote_path,local_path)
def cmd(self, command):
ssh = paramiko.SSHClient()
ssh._transport = self.__transport
# 執(zhí)行命令
stdin, stdout, stderr = ssh.exec_command(command)
# 獲取命令結果
result = stdout.read()
print (str(result,encoding='utf-8'))
return result
ssh = SSHConnection()
ssh.connect()
ssh.cmd("ls")
ssh.upload('s1.py','/tmp/ks77.py')
ssh.download('/tmp/test.py','kkkk',)
ssh.cmd("df")
ssh.close()看完上述內(nèi)容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝您對創(chuàng)新互聯(lián)網(wǎng)站建設公司，的支持。
分享標題：利用paramiko庫執(zhí)行命令時如何在超出給定的時間后強制退出-創(chuàng)新互聯(lián)
本文地址：http://www.dlmjj.cn/article/codiep.html
