73 lines
3.0 KiB
Python
73 lines
3.0 KiB
Python
#报错提示
|
|
import paramiko
|
|
import time
|
|
import threading
|
|
|
|
# 执行命令的函数
|
|
def execute_commands_on_server(hostname, username, password, host):
|
|
try:
|
|
# 连接到服务器
|
|
client = paramiko.SSHClient()
|
|
client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
|
|
client.connect(hostname=hostname, username=username, password=password)
|
|
|
|
# 执行命令
|
|
shell = client.invoke_shell()
|
|
#启动docker
|
|
shell.send("cd /root/pdf_parser/zzb_data_prod\n")
|
|
time.sleep(1)
|
|
shell.send("conda activate py310\n")
|
|
time.sleep(1)
|
|
shell.send("ps -ef | grep app_word.py | grep -v grep | awk '{print $2}' | xargs -r kill -9\n")
|
|
time.sleep(1)
|
|
shell.send("nohup python app_word.py > app.log 2>&1 &\n")
|
|
time.sleep(1)
|
|
# 读取输出
|
|
output = shell.recv(2048).decode()
|
|
print(f"Output from {hostname}:\n{output}")
|
|
|
|
except paramiko.SSHException as e:
|
|
print(f"SSH connection error with {hostname}: {e}")
|
|
|
|
finally:
|
|
client.close()
|
|
|
|
# 创建线程函数
|
|
def thread_function(server):
|
|
execute_commands_on_server(server['hostname'], server['username'], server['password'], server['host'])
|
|
|
|
servers = [
|
|
{'hostname': '124.71.149.225', 'username': 'root', 'password': 's6fQeVQmxxNv', 'host': '企业服务器1'},
|
|
{'hostname': '1.94.143.23', 'username': 'root', 'password': 's6fQeVQmxxNv', 'host': '企业服务器2'},
|
|
{'hostname': '1.94.60.103', 'username': 'root', 'password': 's6fQeVQmxxNv', 'host': '企业服务器3'},
|
|
{'hostname': '124.71.157.162', 'username': 'root', 'password': 's6fQeVQmxxNv', 'host': '企业服务器4'},
|
|
{'hostname': '123.60.16.225', 'username': 'root', 'password': 's6fQeVQmxxNv', 'host': '企业服务器5'},
|
|
{'hostname': '1.94.101.237', 'username': 'root', 'password': 's6fQeVQmxxNv', 'host': '企业服务器6'},
|
|
|
|
{'hostname': '113.44.72.157', 'username': 'root', 'password': 's6fQeVQmxxNv', 'host': '监管服务器1'},
|
|
{'hostname': '113.44.52.221', 'username': 'root', 'password': 's6fQeVQmxxNv', 'host': '监管服务器2'},
|
|
{'hostname': '121.37.137.13', 'username': 'root', 'password': 's6fQeVQmxxNv', 'host': '监管服务器3'},
|
|
|
|
{'hostname': '1.94.106.10', 'username': 'root', 'password': 's6fQeVQmxxNv', 'host': '新增服务器1'},
|
|
{'hostname': '1.94.182.142', 'username': 'root', 'password': 's6fQeVQmxxNv', 'host': '新增服务器2'},
|
|
{'hostname': '119.3.153.192', 'username': 'root', 'password': 's6fQeVQmxxNv', 'host': '新增服务器3'},
|
|
|
|
# {'hostname': '192.168.0.13', 'username': 'root', 'password': 's6fQeVQmxxNv','host':'测试服务器2'},
|
|
# {'hostname': '192.168.0.103', 'username': 'root', 'password': 's6fQeVQmxxNv','host':'测试服务器3'},
|
|
#
|
|
]
|
|
|
|
# 创建并启动线程
|
|
threads = []
|
|
for server in servers:
|
|
thread = threading.Thread(target=thread_function, args=(server,))
|
|
threads.append(thread)
|
|
thread.start()
|
|
|
|
# 等待所有线程完成
|
|
for thread in threads:
|
|
thread.join()
|
|
|
|
print("All commands executed.")
|
|
|