国产成人精品久久免费动漫-国产成人精品天堂-国产成人精品区在线观看-国产成人精品日本-a级毛片无码免费真人-a级毛片毛片免费观看久潮喷

您的位置:首頁/技術文章
文章詳情頁

通過python 執行 nohup 不生效的解決

瀏覽:73日期:2022-07-29 17:09:07

通過paramiko模塊ssh登錄linux,然后用exec_command方法執行帶有nohup的shell命令不生效,python腳本如下:

import paramikoimport time ssh = paramiko.SSHClient()ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())ssh.connect(’192.168.1.2’, 22, ’root’, ’123456’)ssh.exec_command(’nohup ping localhost & n’)time.sleep(1)

腳本執行完之后ping進程并沒有繼續運行,這可能是因為exec_command執行完之后立刻關閉通道的原因,換用invoke_shell可以正常運行:

import paramikoimport time ssh = paramiko.SSHClient()ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())ssh.connect(’192.168.1.2’, 22, ’root’, ’123456’)chan = ssh.invoke_shell()chan.send(’nohup ping localhost & n’)time.sleep(1)

注意,命令最后的回車n和延時必不可少

補充知識:paramiko遠程服務器nohup阻塞問題

一、需求描述:

需要來回切換多臺服務器(腳本命令不太熟),就用了python的paramiko模塊進行遠程連接服務器,控制程序的停止和啟動。安裝:pip install paramiko

二、問題描述:

import paramiko # 創建SSH對象ssh = paramiko.SSHClient()# 允許連接不在know_hosts文件中的主機ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())# 連接服務器ssh.connect(hostname=’192.168.0.3’, port=22, username=’xxx’)# 執行命令stdin, stdout, stderr = ssh.exec_command(’cd ~/ ; nohup python3.6 run_test.py > nohup_test.log 2>&1 &’)# 獲取命令結果result = stdout.read()# 關閉連接ssh.close()

這樣連接服務器的時候確實可以執行,但是遇到會阻塞的任務時,就無法生效,找了很多方法,最后發現這個比較有效。

三、解決方法

import paramiko # 創建SSH對象ssh = paramiko.SSHClient()# 允許連接不在know_hosts文件中的主機ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())# 連接服務器ssh.connect(hostname=’192.168.0.3’, port=22, username=’xxx’, key=private_key)# 添加下面代碼transport = ssh.get_transport()channel = transport.open_session()# 執行命令 此方法沒有返回值channel.exec_command(’cd ~/ ; nohup python3.6 run_test.py > nohup_test.log 2>&1 &’) # 關閉連接ssh.close()

四、類的調用實現:

簡單測試,見下面代碼

# -*- coding: utf-8 -*-'''20190330''' import paramikoimport timefrom confs.log import logger # 自行導入logging模塊即可 class EasyConnectHandle(object): '''操作遠程服務器''' def __init__(self, connect_host_name:dict): '''初始化參數''' ''' 'test':{'ip':'192.168.0.189','user_name':'xxxx','pwd':'huhuhu' }, ''' self.connect_host = connect_host_name self.ssh = paramiko.SSHClient() self.ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) # 允許連接陌生服務器 self.ssh.connect(hostname=self.connect_host['ip'], port=22, username=self.connect_host['user_name'], password=self.connect_host['pwd'], timeout=10) # 初始化的時候連接到新的服務器 logger.info(f'登錄服務器---{self.connect_host[’ip’]}成功:') def __new__(cls, *args, **kwargs): '''單例模式''' if not hasattr(cls, ’_instance’): cls._instance = super(EasyConnectHandle, cls).__new__(cls) return cls._instance def exec(self, cmd=''): '''執行操作''' stdin, stdout, stderr = self.ssh.exec_command(cmd) return stdout.read().decode() def quit(self): '''斷開服務器''' self.ssh.close() logger.info(f'退出服務器---{self.connect_host[’ip’]}成功') if __name__ == ’__main__’: test_host = { 'test': {'ip': '192.168.0.111','user_name': 'xxxx','pwd': 'xxxx','jobs': [ { 'path': '/home/lemon', 'type': 'touch test_1.sh' }, { 'path': '/home/lemon', 'type': 'touch test_2.sh' }] } } for i in ['test']: easy_conn = EasyConnectHandle(test_host[i]) transport = easy_conn.ssh.get_transport() if len(test_host[i].get('jobs', [])) >= 1: for job in test_host[i]['jobs']:channel = transport.open_session()channel.exec_command(f'cd {job[’path’]};{job[’type’]}')logger.info(f'服務器---{easy_conn.connect_host[’ip’]}執行---cd {job[’path’]};{job[’type’]}---成功')time.sleep(2) else: logger.info(f'服務器---{easy_conn.connect_host[’ip’]}暫時沒有任務') easy_conn.quit()

以上這篇通過python 執行 nohup 不生效的解決就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持好吧啦網。

標簽: Python 編程
相關文章:
主站蜘蛛池模板: 国产成人精品三级在线 | 一区二区三区免费精品视频 | 亚洲国产精品91 | 美女把张开腿男生猛戳免费视频 | 久久精品国产大片免费观看 | 男人的天堂黄色 | 国产成人精品久久综合 | 黄男人和女人色一级 | 黄色三级免费网站 | 亚洲成a人片在线看 | 香港激情黄三级在线视频 | 久草在线观看视频 | 国产一级毛片免 | 亚洲精品一区二区三区第四页 | 女人张开腿让男人捅视频 | 欧美一级久久久久久久大片 | 网站三级| 国产三a级日本三级日产三级 | 乱淫网站| 2021国产成人精品久久 | 91四虎国自产在线播放线 | 韩国本免费一级毛片免费 | 九九精品成人免费国产片 | tom影院亚洲国产日本一区 | 欧美的高清视频在线观看 | 高清欧美一级在线观看 | 亚洲成a人不卡在线观看 | 成人高清在线观看 | 久久国产精品-国产精品 | 精品日本亚洲一区二区三区 | 久艹在线观看 | 国产日韩在线播放 | 国产自产21区 | 毛片免费在线观看网址 | 日本欧美不卡一区二区三区在线 | 日韩毛片欧美一级a网站 | 九九夜色| 一级视频网站 | 日韩免费一区二区三区 | 国内精品久久国产大陆 | 一区二区三区亚洲视频 |