Python如何实现网络自动化运维华为设备

int vlan 1
ip add 192.168.10.2 24    //配置VLANif 1的地址用来连接设备
user-interface vty 0 4
authentication-mode aaa    //将虚拟远程登录的模式设置为AAA认证
protocol inbound ssh        //使能SSH协议连接功能
user privilege level 15    //用户权限为15，这是最高权限
quit
stelnet server enable        //使能设备stelnet服务的功能
ssh user test                //配置SSH用户test
ssh user test service-type stelnet     //将用户的服务类型改为stelnet
ssh user test authentication-type password    //将SSH用户test的登录模式改为密码模式
aaa                                            //进入AAA视图
local-user test password cipher  Huawei@123    //配置test账户的密码
local-user test privilege level 15            //配置test账号的权限为15
local-user test service-type ssh             //配置SSH账户的权限为SSH
//以上是connect和command模块

sftp server enable                            //使能SFTP服务
ssh user test service-type  all                 //开启test全部的服务
ssh user test sftp-directory flash:            //将用户test的sftp下载目录指定为flash:下
//以上是download模块

int eth-tr 1
mode lacp
trunkport g0/0/1
trunkport g0/0/2
//配置聚合链路

int vlan 1
ip add 192.168.10.4 24
//使用该地址登录设备

ospf 
area 0
net 0.0.0.0 0.0.0.0
//与LSW4建立OSPF邻居关系

interface Eth-Trunk1
 mode lacp-static
#
interface GigabitEthernet0/0/2
 eth-trunk 1
#
interface GigabitEthernet0/0/3
 eth-trunk 1
//聚合链路

ospf 1
 area 0.0.0.0
  network 0.0.0.0 255.255.255.255
//配置OSPF协议

int vlan 1
ip add 192.168.10.3 24
//配置登录地址

int g1/0/0
undo shut
//开启接口

stelnet server enable    //使能stelnet服务

user-interface vty 0 4
authentication-mode aaa
protocol inbound ssh
//将远程登录模式设置为AAA模式，开启SSH登录功能

aaa
 local-user netconf password cipher Huawei@123
 local-user netconf service-type ssh
 local-user netconf level 3
//创建一个netconf账户，密码为Huawei@123，服务类型为SSH，权限为3
#
ssh user netconf
ssh user netconf authentication-type password
ssh user netconf service-type snetconf
//将用户netconf的认证类型改为密码类型，服务类型改为snetconf
将
#
netconf
protocol inbound ssh port 830
//netconf的端口号为830，允许netconf通过830号端口连接
q
#
snetconf server enable
//使能snetconf服务

import re,time,paramiko
from datetime import datetime
from config import parameter_dict,netconf1
from ncclient import manager
from ncclient.xml_ import to_ele
from threading import Thread

class SW:
    def __init__(self):    //初始化，建立起与设备的SSH连接。
        self.session = paramiko.SSHClient()
        self.session.set_missing_host_key_policy(paramiko.AutoAddPolicy())
        self.session.connect(hostname='192.168.10.2',password='Huawei@123',username='test',port=22,allow_agent=False,look_for_keys=False)
        self.vty = self.session.invoke_shell()
        self.command('sc 0 te')
        print('连接成功')
    def command(self,command):    //向网络设备终端输入变量并输出回显，回显字符上限为999999，类型为utf-8
        self.vty.send(command+'\n')
        time.sleep(1)
        return self.vty.recv(999999).decode('utf-8')
    def parameter_info(self):    //定义监控数据参数方法，每个5分钟输出一次设备参数
        parameter_list = []
        while True:
            for i in parameter_dict.keys():
                pat = self.command(parameter_dict[i]['command'])
                print(pat)
                res = re.compile(parameter_dict[i]['re']).findall(pat)
                print(res)
                if i == 'fan': res = res if res else "All are fans faulty"
                parameter_list.append(f'{i}:{res}')
            print('\n'.join(parameter_list))
            time.sleep(60 * 5)
    def download(self):        //通过SFTP功能下载flash:/vrpcfg.zip文件，并每隔一天保存在本地W:\\TestPython文件夹内
        while True:
            with paramiko.Transport(('192.168.10.2',22)) as t:
                t.connect(username='test',password='Huawei@123')
                sftp = paramiko.SFTPClient.from_transport(t)
                sftp.get('/vrpcfg.zip',f'W:\\TestPython\\{datetime.now().strftime("%Y_%m_%d_%H_%M_%S")}.zip')
            print('下载成功')
            time.sleep(60 * 60 * 24)
    def netconf(self,xml):        //最后配置日志文件地址为10.1.60.2
        manager.connect(host='192.168.10.3',port=22,username='netconf',password="Huawei@123",allow_agent=False,hostkey_verify=False,device_params={"name":"huawei"}).rpc(to_ele(xml))
        print("设置成功")
    def start(self):            //定义多进程模块
        Thread(target=self.download).start()
        Thread(target=self.parameter_info).start()
if __name__ == "__main__":        //满足条件则运行该文件
    for i in netconf1.values():
        SW().start()
        SW().netconf(i)

parameter_dict = {
"fan" : {"command":"display fan","re":"Normal"},
"power" : {"command":"display power","re":"Supply|NotSupply|Sleep|No"},
"cpu" : {"command":"display cpu-usage","re":"CPU Usage            : .+?%"},
"memory" : {"command":"display memory","re":"Memory Using Percentage Is: .+?%"},
"ospf" : {"command":"display ospf peer brief","re":"down|init|2-way|exstart|exchange|loading|Full"},
"lacp" : {"command":"display eth-trunk","re":"Up|Down"}
}

netconf1 = {
    'host_log': '''
            <edit-config>
    <target>
      <running/>
    </target>
    <default-operation>merge</default-operation>
    <error-option>rollback-on-error</error-option>
    <config>
      <syslog xmlns="http://www.huawei.com/netconf/vrp" content-version="1.0" format-version="1.0">
        <syslogServers>
          <syslogServer operation="merge">
            <ipType>ipv4</ipType>
            <serverIp>10.1.60.2</serverIp>
            <isDefaultVpn>false</isDefaultVpn>
            <vrfName>_public_</vrfName>
            <timestamp>UTC</timestamp>
            <transportMode>tcp</transportMode>
          </syslogServer>
        </syslogServers>
      </syslog>
    </config>
  </edit-config>  
'''}