parallel-ssh

import asyncio from pssh.clients import ParallelSSHClient import os async def run_remote_commands(): # Replace with your actual hostnames or IP addresses hosts = ['hostname1', 'hostname2'] # You can specify username, password, or private key path # client = ParallelSSHClient(hosts, user='myuser', password=os.environ.get('SSH_PASSWORD', '')) # client = ParallelSSHClient(hosts, user='myuser', pkey='/path/to/id_rsa') client = ParallelSSHClient(hosts, user=os.environ.get('SSH_USER', 'your_user')) print(f"Connecting to {hosts} and running 'ls -l /tmp'...") output = await client.run_command('ls -l /tmp') async for host_output in output: print(f"\n--- Host: {host_output.host} ---") print(f"Return Code: {host_output.return_code}") print("Stdout:") for line in host_output.stdout: print(f" {line}") print("Stderr:") for line in host_output.stderr: print(f" {line}") if __name__ == '__main__': # Ensure your SSH_USER env var is set or replace 'your_user' directly # Also, ensure SSH agents or known_hosts are configured for passwordless access # or provide password/pkey arguments to ParallelSSHClient. asyncio.run(run_remote_commands())