图文详解python之简单主机批量管理工具

"""批量主机管理接口"""import coreif name == "main":    core.run()

"""核心代码"""import settingsimport paramikoimport threadingimport osclass REMOTE_HOST(object):    #远程操作主机    def init(self, host, port ,username, password, cmd):        self.host = host        self.port = port        self.username = username        self.password = password        self.cmd = cmd    def run(self):        """起线程连接远程主机后调用"""        cmd_str = self.cmd.split()[0]        if hasattr(self, cmd_str):      #反射 eg:调用put方法            getattr(self, cmd_str)()        else:            #setattr(x,'y',v)is  equivalent  to   ``x.y=v''            setattr(self, cmd_str, self.command)            getattr(self, cmd_str)()  #调用command方法，执行批量命令处理    def command(self):        """批量命令处理"""        ssh = paramiko.SSHClient()  #创建ssh对象        #允许连接不在know_hosts文件中的主机        ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())        ssh.connect(hostname=self.host,port=self.port,username=self.username,password=self.password)        stdin,stdout,stderr = ssh.exec_command(self.cmd)        result = stdout.read()        print("%s".center(50, "-") % self.host)        print(result.decode())        ssh.close()    def put(self):        """上传文件"""        filename = self.cmd.split()[1]  #要上传的文件        transport = paramiko.Transport((self.host, self.port))        transport.connect(username=self.username, password=self.password)        sftp = paramiko.SFTPClient.from_transport(transport)        sftp.put(filename, filename)        print("put sucesss")        transport.close()def show_host_list():    """通过选择分组显示主机名与IP"""    for index, key in enumerate(settings.msg_dic):        print(index + 1, key, len(settings.msg_dic[key]))    while True:        choose_host_list = input(">>>(eg:group1)").strip()        host_dic = settings.msg_dic.get(choose_host_list)        if host_dic:            #print(host_dic)            for key in host_dic:                print(key, host_dic[key]["IP"])            return host_dic        else:            print("NO exit this group!")def interactive(choose_host_list):    """根据选择的分组主机起多个线程进行批量交互"""    thread_list = []    while True:        cmd = input(">>>").strip()        if cmd:            for key in choose_host_list:                host, port, username, password = choose_host_list[key]["IP"], choose_host_list[key]["port"],                                                  choose_host_list[key]["username"], choose_host_list[key]["password"]                func = REMOTE_HOST(host, port, username, password, cmd)  # 实例化类                t = threading.Thread(target=func.run)  # 起线程                t.start()                thread_list.append(t)            for t in thread_list:                t.join()  # 主线程等待子线程执行完毕        else:            continuedef run():    choose_host_list = show_host_list()    interactive(choose_host_list)

"""配置文件"""msg_dic = {    "group1":{    #分组1        "h1":{"IP":"192.168.1.1", "username":"11", "password":"aa", "port":22},        "h2":{"IP":"192.168.1.2", "username":"22", "password":"bb", "port":22},        "h3":{"IP":"192.168.1.3", "username":"33", "password":"cc", "port":22},        "h4":{"IP":"192.168.1.4", "username":"44", "password":"dd", "port":22},        "h5":{"IP":"192.168.1.5", "username":"55", "password":"ee", "port":22},        "h6":{"IP":"192.168.1.6", "username":"66", "password":"ff", "port":22},    },    "group2":{    #分组2        "h1":{"IP":"192.168.2.1", "username":"111", "password":"aaa", "port":22},        "h2":{"IP":"192.168.2.2", "username":"222", "password":"bbb", "port":22},        "h3":{"IP":"192.168.2.3", "username":"333", "password":"ccc", "port":22},        "h4":{"IP":"192.168.2.4", "username":"444", "password":"ddd", "port":22},        "h5":{"IP":"192.168.2.5", "username":"555", "password":"eee", "port":22},        "h6":{"IP":"192.168.2.6", "username":"666", "password":"fff", "port":22},        "h7":{"IP":"192.168.2.7", "username":"777", "password":"ggg", "port":22},        "h8":{"IP":"192.168.2.8", "username":"888", "password":"hhh", "port":22},    },    "group3":{        "h1":{"IP":"192.168.179.133", "username":"root", "password":"zcl", "port":22},    }}

C:Python34python3.exe C:/Users/Administrator/PycharmProjects/laonanhai/host_manage/main.py1 group1 62 group3 13 group2 8>>>(eg:group1)group3h1 192.168.179.133>>>put from_windows.pyput sucesss>>>>>>ls------------------------192.168.179.133------------------------anaconda-ks.cfgdatabase_testfrom_windows.pyinstall.loginstall.log.syslogmootoottmprom_windows.py>>>