判断远程主机是否存在某个文件

1.

# -*- coding:utf-8 -*-

import os,sys,paramiko,time
#*******判断所有测试环境是否有某个文件,***********
s7 = "10.10.123.96"
s3 = "10.10.39.70"
host_dic = {"10.10.154.77":"s1",
            "10.10.83.96":"s2",
            "10.10.39.70":"s3",
            "10.10.46.120":"s4",
            "10.10.15.128":"s5",
            "10.10.84.48":"s6",
            "10.10.123.96":"s7",
            "10.10.105.91":"qa1",
            "10.10.92.48":"qa2",
            "10.10.50.30":"qa3",
            "10.10.40.136":"qa4",
            "10.10.189.139":"qa5"
            }
exist ={}
not_exist = {}
port =22
user = "root"
passwd = "B^Dc%4LSBvhZZK3B"

def ssh_cmd(ip,port,cmd,user,passwd):
    result = ""
    try:
        ssh = paramiko.SSHClient()
        ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
        ssh.connect(ip,port,user,passwd)
        stdin, stdout, stderr = ssh.exec_command(cmd)
        result = stdout.read()
        print result
        ssh.close()
    except:
        print "ssh_cmd err."
    return result
while True:
    raw = raw_input("按a批量执行命令： 按b批量判断文件是否存在： 按q退出：")
    if raw =="a":
        cmd = raw_input("请输入要执行的命令：")
        for i in host_dic:
            print host_dic.get(i)
            ssh_cmd(i,port,cmd,    user,passwd)
    elif raw =="b":
        while True:
            print "33[32;1m****使用说明：该脚本可以判断文件，不能判断目录。****33[0m"
            choice = raw_input("请输入要查询远端服务器上文件的绝对路径： 按q退出")
            if choice =="q":
                print "感谢使用，再见"
                exit()
            v = "ls"
            c = v + " " +choice
            #print c
            for i in host_dic:
                ssh = paramiko.SSHClient()
                ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
                ssh.connect(i,port,user,passwd)
                stdin, stdout, stderr = ssh.exec_command(c)
                result = stdout.read()
                #print result
                if result != "":
                    print host_dic.get(i),"33[31;1m上存在该文件33[0m"
                    exist[i]=host_dic.get(i)
            #print host_dic.get(i),"33[33;1m上存在该文件33[0m"
            ssh.close()
            #print exist
            for i in host_dic:
                if i not in exist:
                    not_exist[i]=host_dic.get(i)
                    print host_dic.get(i),"33[33;1m上不存在该文件33[0m"
            exist = {}
            #print not_exist
            choice1 = raw_input("按任意键继续查询，按t拷贝本地一个文件到不存在该文件的机器上，按q退出：")
            if choice1 =="q":
                print "感谢使用，再见"
                print exit()
            elif choice1 == "t":
                local_file = raw_input("请输入本地文件的绝对路径：")
                remote_file = raw_input("请输入要复制到远端机器的绝对路径：")
                for j in not_exist:
                    scp = paramiko.SSHClient()
                    scp.set_missing_host_key_policy(paramiko.AutoAddPolicy())
                    scp.connect(j,port,user,passwd)
                    sftp = paramiko.SFTPClient.from_transport(scp.get_transport())
                    sftp = scp.open_sftp()
                    sftp.put(local_file,remote_file)
                    print "33[31;1m已复制到33[0m",host_dic.get(j)
                not_exist = {}
    else:
        print "感谢使用，再见"
        exit()