使用 paramiko 防止 SFTP/SSH 会话超时

问题描述 投票:0回答:2

我正在使用 paramiko 连接到 SFTP 服务器,我必须在该服务器上下载并处理一些文件。

服务器的超时设置为 5 分钟,但有时文件的处理时间可能会比超时长。因此,当我想更改服务器上的工作目录以处理其他一些文件时

sftp.chdir(target_dir))
我收到连接超时的异常:

文件 buildbdist.win32eggparamikosftp://ftp.py, 第 138 行,在 _write_all raise 中 EOFError()

为了解决这个问题,我认为激活保持活动将是最好的选择,因此我在传输上使用“set_keepalive”将其设置为 30 秒:

ssh = paramiko.SSHClient()
ssh.set_missing_hostkey_policy(paramiko.AutoAddPolicy())
ssh.connect(ssh_server, port=ssh_port, username=ssh_user, password=password)
transport = ssh.get_transport()
transport.set_keepalive(30)
sftp = transport.open_sftp_client()

但一切都没有改变。该更改完全没有影响。我不知道我是否误解了

set_keepalive
的概念,或者服务器(我无权访问)忽略了 keeplive 数据包。

这不是解决这个问题的正确方法吗?还是我应该尝试不同的方法?我不喜欢“手动”向服务器发送一些

ls
命令以保持会话活动的想法。

python ssh timeout sftp paramiko
2个回答
7
投票

如果服务器因不活动而超时,则客户端无能为力(除了时不时地发送一个简单的命令以防止会话超时)。

您是否考虑过分开下载和处理步骤,以便您可以下载开始所需的所有内容,然后异步处理或在所有下载完成后处理?


0
投票

这个解决方案对我有用 - 启动一个守护线程来保持连接处于活动状态。像这样的东西:

from threading import Thread
import time

# Function to keep the SFTP connection alive
def keep_sftp_alive(transport, interval=60):
    while True:
        time.sleep(interval)
        transport.send_ignore()

keep_alive_thread = Thread(target=keep_sftp_alive, args=(transport,))
keep_alive_thread.daemon = True
keep_alive_thread.start()

<rest of code here>

只有当主 Python 代码仍在运行时,守护线程才会继续工作。

© www.soinside.com 2019 - 2024. All rights reserved.