通过python 执行 nohup 不生效的解决
通过paramiko模块ssh登录linux,然后用exec_command方法执行带有nohup的shell命令不生效,python脚本如下:
importparamiko importtime ssh=paramiko.SSHClient() ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) ssh.connect('192.168.1.2',22,'root','123456') ssh.exec_command('nohuppinglocalhost&\n') time.sleep(1)
脚本执行完之后ping进程并没有继续运行,这可能是因为exec_command执行完之后立刻关闭通道的原因,换用invoke_shell可以正常运行:
importparamiko importtime 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('nohuppinglocalhost&\n') time.sleep(1)
注意,命令最后的回车\n和延时必不可少
补充知识:paramiko远程服务器nohup阻塞问题
一、需求描述:
需要来回切换多台服务器(脚本命令不太熟),就用了python的paramiko模块进行远程连接服务器,控制程序的停止和启动。安装:pipinstallparamiko
二、问题描述:
importparamiko #创建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~/;nohuppython3.6run_test.py>nohup_test.log2>&1&') #获取命令结果 result=stdout.read() #关闭连接 ssh.close()
这样连接服务器的时候确实可以执行,但是遇到会阻塞的任务时,就无法生效,找了很多方法,最后发现这个比较有效。
三、解决方法
importparamiko #创建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~/;nohuppython3.6run_test.py>nohup_test.log2>&1&') #关闭连接 ssh.close()
四、类的调用实现:
简单测试,见下面代码
#-*-coding:utf-8-*- """ 20190330 """ importparamiko importtime fromconfs.logimportlogger#自行导入logging模块即可 classEasyConnectHandle(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): """单例模式""" ifnothasattr(cls,'_instance'): cls._instance=super(EasyConnectHandle,cls).__new__(cls) returncls._instance defexec(self,cmd=""): """执行操作""" stdin,stdout,stderr=self.ssh.exec_command(cmd) returnstdout.read().decode() defquit(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":"touchtest_1.sh" }, { "path":"/home/lemon", "type":"touchtest_2.sh" } ] } } foriin["test"]: easy_conn=EasyConnectHandle(test_host[i]) transport=easy_conn.ssh.get_transport() iflen(test_host[i].get("jobs",[]))>=1: forjobintest_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不生效的解决就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持毛票票。