一个python远程机群计算的垃圾代码

#!/usr/bin/python

import paramiko,os
import threading

def ssh(ip):
    client=paramiko.SSHClient()

    client.set_missing_host_key_policy(paramiko.AutoAddPolicy())

    client.connect(ip, 22,"root",'ysx',timeout=5)

    sftp=client.open_sftp()

    sftp.mkdir('/home/celue')
    sftp.mkdir('/home/celue/rb-tempdata')

    localdir='/home/celue/macd/rb-tempdata'

    remotedir='/home/celue/rb-tempdata'

    files=os.listdir(localdir)

    for f in files:
        print '###### begin ######'
        print 'uploading file',os.path.join(localdir,f)
        sftp.put(os.path.join(localdir,f),(os.path.join(remotedir,f)))
        print 'suceess'

    sftp.put('/home/celue/macd/Macd_trade.cpp','/home/celue/Macd_trade.cpp')

#cmd=['screen -x g++ /home/celue/Macd_trade.cpp']
#for m in cmd:
#   stdin,stdout,stderr=client.exec_command(m)
#   out=stdout.readlines()
#   for o in out:
#       print o,
#print 'finish'

    stdin,stdout,stderr=client.exec_command("cd /home/celue;screen -R you;work on you;g++ /home/celue/Macd_trade.cpp;/home/celue/a.out rb-tempdata")
#stdin,stdout,stderr=client.exec_command("g++ /home/celue/Macd_trade.cpp;/home/celue/a.out rb-tempdata")
    out=stdout.readlines()
    for o in out:
        print o,
    sftp.get('/home/celue/all.txt','/home/'+ip+'.txt')

    client.close()

if __name__=='__main__':
    ip="192.168.0.203"
    threads=[]
    a=threading.Thread(target=ssh,args=(ip,))
    a.start()
#   ssh(ip)