通过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不生效的解决就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持毛票票。