由于脚本执行时间，Paramiko 块中的命令

Question

大家好，我有三台服务器，我从 SSH 管理它，所以我制作了这个脚本来运行我的注册脚本“Register.py”，所以我每天都打开注册模式，所以问题是我如何在不关闭的情况下登录到多个 SSH 连接另一个

import paramiko
import os
ZI1={"ip":"192.168.1.2","pass":"Administrator"}
ZI2={"ip":"192.168.1.3","pass":"AdminTeachers"}
ZI3={"ip":"192.168.1.4","pass":"AdminStudents"}
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
for F1 in ZI1:
    ssh.connect(ZI1["ip"],username='root', password=ZI1["pass"])
    ssh.exec_command('./register.py -time 6') #6 hour so the script still working for 6 hours
    ssh.close()
for F2 in ZI2:
    ssh.connect(ZI2["ip"],username='root', password=ZI2["pass"])
    ssh.exec_command('./register.py -time 6')
    ssh.close()
for F3 in ZI3:
    ssh.connect(ZI2["ip"],username='root', password=ZI2["pass"])
    ssh.exec_command('./register.py -time 6')
    ssh.close()

所以我必须做什么才能在不停止脚本的情况下打开 3 个会话！

Answer 1

我建议查看Fabric。它可以帮助您处理 SSH 连接。

Answer 2

您当前的操作方式会阻塞，因为您有六个小时没有退出主机。

多处理：

如果您需要查看脚本的返回码，您应该使用python's multiprocessing module 打开与每个主机的连接。

nohup:

另一种方法（不允许您通过paramiko 查看脚本的返回值）是使用nohup 解除脚本与shell 的关联。这会将其置于后台并允许您注销。为此，请使用...

    ssh.exec_command('nohup ./register.py -time 6 &') 

错别字：

顺便说一句，您在最后一个循环中有拼写错误...ZI2 在最后一个循环中应该是ZI3...此外，for-循环是不必要的...我修复了您的最后一次迭代。 .. 感谢@johnsyweb 发现了比我更多的 OP 错别字...

ssh.connect(ZI3["ip"],username='root', password=ZI3["pass"])
ssh.exec_command('./register.py -time 6')   # <------------- missing s in ssh
ssh.close()

Answer 3

如果您需要根据 Register.py 的返回执行一些操作，另一种方法是使用 Thread

查看示例：

import paramiko
import os
import sys
from threading import Thread

SERVER_LIST = [{"ip":"192.168.1.2","pass":"Administrator"},{"ip":"192.168.1.4","pass":"AdminStudents"},{"ip":"192.168.1.3","pass":"AdminTeachers"}]



class ExecuteRegister(Thread):
    def __init__ (self,options):
        Thread.__init__(self)
        self.options = options       
        self.ssh = paramiko.SSHClient()
        self.ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())



    def run(self):
        try:
           self.ssh.connect(self.options['ip'],username='root', password=self.options["pass"])
           self.ssh.exec_command('./register.py -time 6') #6 hour so the script still working for 6 hours
           self.ssh.close()
        except:
           print sys.exc_info()



for server in SERVER_LIST:
    Register = ExecuteRegister(server)
    Register.start()