Python Paramiko执行nohup后台进程不生效的解决方案
本文分析了使用Python Paramiko库通过exec_command执行nohup命令时，因通道立即关闭导致后台进程无法持续运行的问题。通过对比exec_command与invoke_shell的区别，指出后者配合回车符和延时可有效解决阻塞问题，并提供了基于Transport通道的另一种实现方式及完整代码示例。
问题现象与原因分析
在使用Python的paramiko模块通过SSH登录Linux服务器时，若直接使用exec_command方法执行包含nohup的Shell命令，往往会出现命令看似执行成功但后台进程并未持续运行的情况。以下是导致该问题的典型Python脚本示例：
import paramiko
import 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方法，该方式能够保持会话活跃，从而确保nohup命令正常生效：
import paramiko
import 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时出现的阻塞问题，以下是详细的分析与解决方案。
一、需求描述：
由于需要频繁在多台服务器之间切换，且对Shell命令不够熟悉，因此选用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 paramiko
import time
from 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不生效的解决方法就是本文的全部内容，希望能为大家提供有效的参考，也希望大家能多多支持本站。
免责声明：本文内容仅供参考，不代表本站观点。转载或引用请注明出处。
