Paramiko写入stdin后如何实时逐行读取SSH通道stdout输出

云上老周

2026-8-30

问题根因

接口选型错误：exec_command() 面向单次非交互式命令执行场景设计，通道逻辑会等待命令执行结束、返回退出状态后才标记会话完成。绝大多数网络交换机（本次场景为网件M4300）不支持独立exec通道，其CLI为常驻交互式shell，运行过程中不会主动返回退出状态，是程序卡住、无法打印finished的核心原因。
循环退出逻辑错误：自定义的line_buffered函数以f.channel.exit_status_ready()作为循环终止判定条件，交换机输出完命令返回结果后会立刻回到命令提示符等待新输入，永远不会主动上报退出状态，循环会永久阻塞等待不存在的“会话结束”信号。
隐性逻辑bug：client.set_missing_host_key_policy(paramiko.AutoAddPolicy) 传入的是类本身，未加括号完成实例化，会导致主机密钥校验逻辑异常。
缓冲处理缺失：写入stdin后未主动调用flush()，部分场景下数据会滞留在本地缓冲区，无法立即发送到对端设备。

修复方案

放弃exec_command，改用invoke_shell()唤起交互式终端会话；读取输出时不要等待通道退出，通过匹配设备命令提示符作为单条命令执行完成的判定条件；写入命令后主动刷新缓冲区，避免数据滞留。

修正后的可运行代码：

import paramiko
import time

def realtime_read(channel, prompt, timeout=2):
    """实时逐行读取输出，匹配到提示符即停止，避免永久阻塞"""
    output = ""
    last_recv_time = time.time()
    while True:
        # 仅当通道有可读数据时读取，避免空读阻塞
        if channel.recv_ready():
            chunk = channel.recv(1024).decode(errors="ignore")
            output += chunk
            # 逐行实时打印输出
            for line in chunk.splitlines(True):
                print(line, end="")
            last_recv_time = time.time()
            # 匹配到命令提示符，判定当前命令执行完成
            if prompt in output:
                break
        # 超时兜底，无新输出时自动退出，避免死循环
        if time.time() - last_recv_time > timeout:
            break
        time.sleep(0.05)
    return output

client = paramiko.SSHClient()
# 修复：实例化主机密钥策略
client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
client.connect(
    "192.168.18.96",
    username="admin",
    password="password",
    look_for_keys=False,
    allow_agent=False
)
print("SSH Connection completed.")

# 唤起交互式shell，替代不适用的exec_command
channel = client.invoke_shell()
# 等待登录初始化完成，读取登录banner和初始提示符
time.sleep(1)
realtime_read(channel, prompt=">", timeout=3)
print("Start executing...")

# 发送命令，写完主动刷新通道
channel.send("something\n")
# 实时读取命令输出，直到返回提示符
realtime_read(channel, prompt=">")

print("-----------------")
print("finished")

channel.close()
client.close()

注意事项

代码中的prompt参数需要和设备实际提示符匹配，当前用户模式提示符为(M4300-52G) >，如果后续进入特权模式、配置模式导致提示符变化，需要对应调整匹配规则，也可以用正则实现更灵活的匹配。
不要随意调用stdin.channel.shutdown_write()，关闭写通道后无法再向设备发送后续命令，做多命令配置、备份操作时需要保持通道可写。
需要执行多条命令时，循环调用send+realtime_read即可，每次等设备返回提示符后再发送下一条命令，不会出现输出读取不全或进程卡住的问题。

内容的提问来源于stack exchange，提问作者LiiVion