扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
这篇文章主要为大家展示了“python中如何通过脚本进行双线路切换”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“python中如何通过脚本进行双线路切换”这篇文章吧。
在平房等地区,都构建了全面的区域性战略布局,加强发展的系统性、市场前瞻性、产品创新能力,以专注、极致的服务理念,为客户提供网站设计、成都做网站 网站设计制作定制网站建设,公司网站建设,企业网站建设,成都品牌网站建设,网络营销推广,外贸网站制作,平房网站建设费用合理。
这两天写了一个脚本,用于线路切换,目前还有些小bug,还没有想好逻辑结构如何改,反正想着想着头发就没有了。
要求:1.所有用户连接ISP是通过Core01的G0/1出局,Core02的G0/1是Shutdown状态
2. 当Core01的G0/1光线线路出问题时,通过脚本去把Core02的G0/1 UP
***更新代码,增加微信提醒功能
拓扑如下图:
脚本如下:
#!/usr/bin/env python3 # -*- coding: utf-8 -*- import time import re import sys import subprocess from sendwxInfo import * from netmiko import ConnectHandler from netmiko.ssh_exception import NetMikoTimeoutException,NetMikoAuthenticationException def auth(Conn): def wrapper(ip,username,password): device = { 'device_type': 'cisco_ios', 'ip': ip, 'username': username, 'password': password, } try: connect = ConnectHandler(**device) connect.enable() except (EOFError, NetMikoTimeoutException): print(u" 网络设备%s: 无法连接!请确认该设备IPAddress是否可达!"%ip) return except (EOFError, NetMikoAuthenticationException): print(u" 网络设备%s: 用户名与密码错误!请确认账号与密码!" %ip) return res = Conn(ip,username,password,connect) return res return wrapper @auth def upInterface(ip,username,password,connect): cmd = ['interface g0/1','no shutdown'] connect.send_config_set(cmd) res = connect.send_command('show ip int brief') connect.disconnect() @auth def downInterface(ip,username,password,connect): cmd = ['interface g0/1','shutdown'] connect.send_config_set(cmd) connect.disconnect() def sendInfo(): weixinInfo = WeChat('https://qyapi.weixin.qq.com/cgi-bin') return weixinInfo def masterLogs(): filename = '/var/log/syslog-ng/172.16.200.21/messages' file = subprocess.Popen('tail -n 1 ' +filename , shell=True, stdout=subprocess.PIPE,stderr=subprocess.PIPE) masterData = str(file.stdout.readline(),encoding='utf-8') if re.match('.*sla 1 state Up -> Down.*',masterData): res01 ="设备Core01连接互联网的端口G0/1已经断开,请管理员确认业务。" downInterface('172.16.200.21','admin','Password.123') upInterface('172.16.200.22','admin','Password.123') res02 = 'Intetnet线路已经从Core01的G0/1切换至Core02的G0/1端口,请管理员确认业务。' res03 = '重要信息!' message = "{0}\n{1}\n\n{2}".format(res03,res01,res02) info = sendInfo() info.sendMessage(message) def slaveLogs(): filename = '/var/log/syslog-ng/172.16.200.22/messages' file = subprocess.Popen('tail -n 1 ' +filename , shell=True, stdout=subprocess.PIPE,stderr=subprocess.PIPE) slaveData = str(file.stdout.readline(),encoding='utf-8') if re.match('.*sla 1 state Up -> Down.*',slaveData): res01= "设备Core02连接互联网的端口G0/1已经断开,请管理员确认业务。" downInterface('172.16.200.22','admin','Password.123') upInterface('172.16.200.21','admin','Password.123') res02='Internet线路已经从Core02的G0/1切换至Core01的G0/1端口,请管理员确认业务。' res03 = '重要信息!' message = "{0}\n{1}\n\n{2}".format(res03,res01,res02) info = sendInfo() info.sendMessage(message) if __name__ == "__main__": while True: masterLogs() time.sleep(5) slaveLogs() time.sleep(5)
微信提醒功能代码
#!/usr/bin/env python3 # -*- coding: utf-8 -*- import urllib,json import urllib.parse import urllib.request import sys class WeChat(object): __token_id = '' def __init__(self,url): self.__url = url.rstrip('/') #自行更改 self.__corpid = 'XXXXXXXXXX' self.__secret = 'XXXXXXXXXXXXXX' def authID(self): params = {'corpid':self.__corpid, 'corpsecret':self.__secret} data = urllib.parse.urlencode(params) content = self.getToken(data) try: self.__token_id = content['access_token'] except KeyError: raise KeyError def getToken(self,data,url_prefix='/'): url = self.__url + url_prefix + 'gettoken?' try: response = urllib.request.Request(url + data) except KeyError: raise KeyError result = urllib.request.urlopen(response) content = json.loads(result.read()) return content def postData(self,data,url_prefix='/'): url = self.__url + url_prefix + 'message/send?access_token=%s' % self.__token_id request = urllib.request.Request(url,data) try: result = urllib.request.urlopen(request) except urllib.request.HTTPError as e: if hasattr(e,'reason'): print ('reason',e.reason) elif hasattr(e,'code'): print ('code',e.code) return 0 else: content = json.loads(result.read()) result.close() return content def sendMessage(self,message): self.authID() data = json.dumps({ 'touser':"", #自行更改 'toparty':"XXX", 'msgtype':"text", #自行更改 'agentid':"XXXXXX", 'text':{ 'content':message }, 'safe':"0" },ensure_ascii=False) response = self.postData(data.encode('utf-8'))
主备设备的目前状态如下:所有流量从Core01的G0/1出局
备用路由器Core02的G0/1口是关闭状态,(注意一点: Core01与Core02各自的G0/1配置相同)
从互联网ISP去Ping 企业的IP: 169.254.100.1状态是OK的。
以下是测试抓取日志以及线路切换后互联网ISP去ping 企业的IP: 169.100.1状态
Core01连接互联网的端口已经断开
Core02通过脚本自动切换
从ISP的路由器去ping企业的IP: 169.254.100.1的状态:
监控脚本运行的结果:
---------------------------------------------------------------------------------------------------------------------------
下面再从Core02自动切换回Core01
Core01日志状态
ISP去Ping 企业的IP: 169.254.100.1的状态:
脚本运行的状态:
****添加的微信提醒功能
以上是“python中如何通过脚本进行双线路切换”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注创新互联行业资讯频道!
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流