### 使用 Python 在服务器命令行中批量执行命令 在服务器环境中，Python 提供了多种方法来实现批量命令行操作。以下是通过 `paramiko` 库实现远程批量执行命令的详细说明和示例代码。 #### 1. 使用 Paramiko 实现远程批量命令执行 Paramiko 是一个用于 SSH 协议的 Python 实现库，支持远程连接、命令执行以及文件传输等功能。以下是一个基于 Paramiko 的批量命令执行脚本[^1]： ```python # -*- coding: utf-8 -*- #!/usr/bin/python import paramiko import threading def ssh2(ip, username, passwd, cmd): try: ssh = paramiko.SSHClient() ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) ssh.connect(ip, 22, username, passwd, timeout=5) for m in cmd: stdin, stdout, stderr = ssh.exec_command(m) out = stdout.readlines() for o in out: print(o, end="") print(f"{ip}\tOK") ssh.close() except Exception as e: print(f"{ip}\tError: {e}") if __name__ == '__main__': cmd = ['cal', 'echo hello!'] # 要执行的命令列表 username = "root" # 用户名 passwd = "password" # 密码 threads = [] print("Begin......") for i in range(1, 254): ip = f"192.168.1.{i}" a = threading.Thread(target=ssh2, args=(ip, username, passwd, cmd)) a.start() ``` 上述代码通过多线程机制实现了对多个 IP 地址的并发连接和命令执行。每个线程负责一个 IP 地址，并在连接成功后执行指定的命令列表。 #### 2. 配置文件驱动的批量命令执行 为了更灵活地管理服务器信息，可以使用配置文件来存储服务器的 IP 地址、用户名和密码。以下是一个基于配置文件的批量命令执行脚本[^3]： ```python # -*- coding: utf-8 -*- #!/usr/bin/python import paramiko import configparser def ssh_execute(ip, username, passwd, cmd): try: ssh = paramiko.SSHClient() ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) ssh.connect(ip, 22, username, passwd, timeout=5) for m in cmd: stdin, stdout, stderr = ssh.exec_command(m) out = stdout.readlines() for o in out: print(o, end="") print(f"{ip}\tOK") ssh.close() except Exception as e: print(f"{ip}\tError: {e}") if __name__ == '__main__': config = configparser.ConfigParser() config.read('servers.conf') cmd = ['cal', 'echo hello!'] for section in config.sections(): for item in config.items(section): ip, credentials = item username, passwd = credentials.split(":") ssh_execute(ip, username, passwd, cmd) ``` 配置文件 `servers.conf` 示例： ```ini [WEB] 192.168.56.102=root:liu123 192.168.56.103=root:liu123 [DB] 192.168.56.101=root:liu123 192.168.56.102=root:liu123 ``` #### 3. 多进程实现批量命令执行 除了多线程，还可以使用 `multiprocessing` 模块实现多进程并发执行命令。以下是一个基于多进程的批量命令执行脚本[^2]： ```python # -*- coding: utf-8 -*- #!/usr/bin/python import paramiko import multiprocessing import configparser def ssh_execute(ip, username, passwd, cmd): try: ssh = paramiko.SSHClient() ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) ssh.connect(ip, 22, username, passwd, timeout=5) for m in cmd: stdin, stdout, stderr = ssh.exec_command(m) out = stdout.readlines() for o in out: print(o, end="") print(f"{ip}\tOK") ssh.close() except Exception as e: print(f"{ip}\tError: {e}") if __name__ == '__main__': config = configparser.ConfigParser() config.read('servers.conf') cmd = ['cal', 'echo hello!'] processes = [] for section in config.sections(): for item in config.items(section): ip, credentials = item username, passwd = credentials.split(":") p = multiprocessing.Process(target=ssh_execute, args=(ip, username, passwd, cmd)) p.start() processes.append(p) for p in processes: p.join() ``` #### 注意事项 - 确保目标服务器已启用 SSH 服务并允许指定用户登录。 - 如果需要更高的安全性，建议使用密钥认证代替密码认证。 - 批量操作时需注意网络延迟和资源占用问题，适当调整并发数量。