netmiko模块

#!/bin/python
# -*- coding:UTF-8 -*-
# pip install netmiko
from netmiko import ConnectHandler, SSHDetect
from netmiko.exceptions import NetMikoAuthenticationException, NetMikoTimeoutException
import threading
import datetime
import queue
import re, os
import logging

logging.basicConfig(filename='test.log', level=logging.DEBUG)
logger = logging.getLogger("netmiko")


def conn_info(ip):
    dev = {
        # 'device_type': 'huawei_serial',  # 指定设备类型，串口方式登陆，默认连接COM1，波特率9600
        # 'device_type': 'huawei_telnet',  # 指定设备类型，该类型适用于huawei设备，telnet方式
        'device_type': 'huawei',  # 该类型适用于huawei设备，ssh方式
        'host': ip,
        'port': 1022,  # ssh默认使用22，telnet默认使用23
        'username': 'admin',  # 设备管理员用户
        'password': 'TJuOO8Uz',  # 管理员用户密码
    }
    return dev


def conn_dev(dev_q):
    while not dev_q.empty():
        dev_ip = dev_q.get()
        try:
            dev_dict = conn_info(dev_ip)
            # guesser = SSHDetect(**dev_dict)
            # best_match = guesser.autodetect()
            # print('best_match is:{}'.format(best_match))
            # print('all guessers  is:{}'.format(guesser.potential_matches))
            # dev_dict['device_type'] = best_match
            dev_conn = ConnectHandler(**dev_dict)
            print("[%s] Connected." % dev_ip)
            output = dev_conn.send_config_from_file('cmds.txt')
            print(output)
            output = dev_conn.save_config()
            print(output)
            dev_conn.disconnect()
            print('[%s] done.\n' % dev_ip)
        except NetMikoAuthenticationException:
            print("[%s] Error! Please check username or password ..." % dev_ip)
        except NetMikoTimeoutException:
            print("[%s] Error! Connect time out ..." % dev_ip)
        except Exception as e:
            print('[%s] Error:%s' % (dev_ip, e))


if __name__ == "__main__":
    devs_ip = ['192.168.12.34', '192.168.12.35', '192.168.13.19']  # 需进行配置的交换机ip地址列表

    devs_q = queue.Queue()
    for dev in devs_ip:
        devs_q.put(dev)

    max_conn = 15  # 同时操作交换机数量（可增加或减少）

    ts = []  # 线程集合
    for i in range(max_conn):
        t = threading.Thread(target=conn_dev, args=(devs_q,))
        t.start()
        ts.append(t)
    for t in ts:
        t.join()

    print("Done.")