使用多线程通过跳跃发送多个命令

Question

我创建了一个脚本，在其中将15000个命令发送到70个开关，因此每个交换机约为200个命令。 对于每个交换机，我通过Jumpssh（通过跳转服务器）创建一个SSH连接：建立

from jumpssh import SSHSession

# establish ssh connection between your local machine and the jump server
gateway_session = SSHSession('gateway.example.com',
                             'my_user', password='my_password').open()

# from jump server, establish connection with a remote server
remote_session = gateway_session.get_remote_session('remote.example.com',
                                                    password='my_password2')

连接后，我将使用MultineReading发送200个命令：

def main_loop():
    for switch in result.keys():
        gateway_session = SSHSession('gateway.example.com',
                             'my_user', password='my_password').open()
        remote_session = gateway_session.get_remote_session(switch["ip"],
                                                    password='my_password2')
        with ThreadPoolExecutor(max_workers=8) as executor:
            for command in result[switch]["commands"]:
                executor.submit(launch_command, command, remote_session)

def launch_command(command, remote_session):
    process = remote_session.get_cmd_output(command)                

问题是，如果我使用7或8个工人，则是无法正常工作（我丢失了一些信息），而且我会遇到此错误：

secsh channel 10 open FAILED: open failed: Connect failed
secsh channel 123 open FAILED: open failed: Connect failed
secsh channel 42 open FAILED: open failed: Connect failed
secsh channel 76 open FAILED: open failed: Connect failed
secsh channel 12 open FAILED: open failed: Connect failed
secsh channel 55 open FAILED: open failed: Connect failed
...

如果我使用的6名工人或更少，我没有任何错误，一切正常。

我的印象是它每叶创建多个SSH连接，因此这就是为什么存在错误的原因，因为也许我达到了交换机中允许的最大会话数，但是根据我的代码，每个交换机只有一个连接是设置。

也许有人遇到了同样的问题？

谢谢你，