导入必要的模块

from ncclient import manager # 用于与网络设备建立NETCONF连接 import paramiko # 用于通过SSH与网络设备建立连接 import time # 用于等待命令执行完成 import datetime # 用于生成文件名

定义设备IP地址、用户名和密码

DEVICE_IP = '10.1.0.6' USERNAME = 'python' PASSWORD = 'Huawei@123'

class Device(): def init(self, ip, usr, pwd): self.hostname = ip # 设备IP地址 self.username = usr # 登录设备的用户名 self.password = pwd # 登录设备的密码 self.client = self._get_connect() # 通过SSH与设备建立连接 self.cli = self.client.invoke_shell() # 打开交互式Shell self.cli.send('n\n') # 发送回车键 self.cli.send('screen-length 0 temporary\n') # 发送命令，设置输出为不分页

def _get_connect(self):
    ssh_con = paramiko.SSHClient()  # 创建SSHClient实例
    ssh_con.set_missing_host_key_policy(paramiko.AutoAddPolicy())  # 设置自动添加主机密钥
    ssh_con.connect(hostname=self.hostname, username=self.username, password=self.password, timeout=10)  # 通过SSH连接到设备
    return ssh_con  # 返回SSH连接对象

def check_fan_status(self, output):
    lines = output.split('\n')  # 将命令输出按行分割成列表
    fan_status = {}  # 初始化字典，用于保存风扇状态
    for line in lines:
        if 'Fan' in line:  # 如果该行包含'Fan'字符串
            fan_name = line.split(':')[0]  # 获取风扇名称
            fan_state = line.split(':')[1].strip()  # 获取风扇状态
            if 'Normal' not in fan_state:  # 如果风扇状态不是'Normal'
                fan_status[fan_name] = fan_state  # 将风扇名称和状态保存到字典中
    if not fan_status:  # 如果所有风扇状态都正常
        print('All fans are working normally!')  # 打印提示信息
    else:  # 如果有风扇状态异常
        print('Fan status:')  # 打印提示信息
        for fan_name, fan_state in fan_status.items():  # 遍历所有异常风扇的名称和状态
            print(f'{fan_name}: {fan_state}')  # 打印风扇名称和状态

def open(self):
    with open('command.txt', 'r') as f:  # 打开文件，读取命令列表
        cmd_list = f.readlines()  # 将命令列表读取到列表中
        for cmd in cmd_list:  # 遍历所有命令
            self.cli.send(cmd)  # 发送命令
    time.sleep(1)  # 等待命令执行完成
    COMMAND = self.cli.recv(65535).decode('utf-8')  # 获取命令输出，转换为字符串

    print(COMMAND)

    self.check_fan_status(COMMAND)

    timestamp = datetime.datetime.now().strftime('%Y-%m-%d_%H-%M-%S')  # 根据当前时间生成时间戳
    filename = f'{timestamp}_T1_ACC2.zip'  # 根据时间戳生成文件名
    with manager.connect(host=DEVICE_IP, port=830, username=USERNAME, password=PASSWORD, hostkey_verify=False) as m:  # 建立NETCONF连接
        # 发送<get-config> RPC消息，获取当前正在运行的配置，并保存到设备中
        get_config = """
        <get-config>
            <source>
                <running/>
            </source>
        </get-config>
        """
        config = m.dispatch(get_config).data_xml  # 获取配置信息
        with open(filename, 'w') as f:  # 创建ZIP文件，写入配置信息
            f.write(config)

    with manager.connect(host=DEVICE_IP, port=830, username=USERNAME, password=PASSWORD, hostkey_verify=False) as m:  # 建立NETCONF连接
        # 发送<get-config> RPC消息，获取设备中保存的配置，并下载到本地
        get_config = """
        <get-config>
            <source>
                <startup/>
            </source>
        </get-config>
        """
        config = m.dispatch(get_config).data_xml  # 获取配置信息
        with open('startup-config.xml', 'w') as f:  # 创建XML文件，写入配置信息
            f.write(config)

def close(self):
    self.client.close()

if name == 'main': while True: device = Device(DEVICE_IP, USERNAME, PASSWORD) # 创建Device对象，传入设备IP、用户名和密码 device.open() # 打开Shell，执行命令，检查风扇状态，保存正在运行的配置到设备，下载保存在设备的配置到本地 device.close() # 关闭SSH连