From ccb4876d88896141e2d695f0a1e10b5bbd1e7716 Mon Sep 17 00:00:00 2001 From: halcyon <864072399@qq.com> Date: Sun, 4 Jan 2015 11:12:38 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- connect.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/connect.py b/connect.py index 37a88f84c..61bace914 100755 --- a/connect.py +++ b/connect.py @@ -341,14 +341,14 @@ def connect(username, password, host, port, login_name): def remote_exec_cmd(ip, port, username, password, cmd): try: - time.sleep(3) + time.sleep(5) ssh = paramiko.SSHClient() ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) ssh.connect(ip, port, username, password, key_filename=USER_KEY_FILE, timeout=5) stdin, stdout, stderr = ssh.exec_command("bash -l -c '%s'" % cmd) out = stdout.readlines() err = stderr.readlines() - color_print('%s:', 'blue') + color_print('%s:' %ip, 'blue') for i in out: color_print(" " * 4 + i.strip(), 'green') for j in err: @@ -360,7 +360,7 @@ def remote_exec_cmd(ip, port, username, password, cmd): def multi_remote_exec_cmd(hosts, username, cmd): - pool = Pool(processes=3) + pool = Pool(processes=5) for host in hosts: username, password, ip, port = get_connect_item(username, host) pool.apply_async(remote_exec_cmd, (ip, port, username, password, cmd))