Python脚本实现网络设备自动化管理

先放个链接，万一有人关注呢

优质文章推荐

↓ ↓ ↓ ↓ ↓

随着企业网络规模的不断扩大和复杂性的增加，运维工程师面临着日益繁重的任务和挑战。为了有效管理和维护网络设备，他们需要频繁地连接到各种网络设备，并执行一系列配置和故障排除操作。然而，手动操作的方式既耗时又容易出错，不仅增加了工作负担，还可能导致配置不一致和故障延误。

为解决这一问题，网络设备自动化管理脚本应运而生。这个脚本基于Python编程语言，旨在提供一种高效、可靠的自动化解决方案，帮助运维工程师简化日常任务，提高工作效率和网络可靠性。

应用场景

1. 批量设备配置更新 

在网络环境中，定期对设备进行配置更新是必要的。网络设备自动化管理脚本可以批量连接到多个设备，并执行预定义的配置命令，例如添加新的访问控制列表、更新路由表、配置端口和VLAN等。通过自动化执行这些操作，运维工程师能够节省大量时间和精力，并确保配置的一致性和准确性。

2. 设备状态检查与监控 

保持网络设备的正常运行状态对于网络的稳定性至关重要。脚本可以定期连接到设备并执行命令来检查设备的状态，例如检查接口状态、CPU和内存利用率、链路质量等。在检测到异常情况时，脚本可以发送警报通知运维团队，使他们能够及时采取措施解决问题，从而提高网络的可靠性和可用性。

3. 故障排除和日志分析 

当网络设备出现故障时，快速而准确地定位问题是至关重要的。脚本可以连接到故障设备并收集相关的日志信息，例如系统日志、事件日志和接口错误计数等。通过自动化地收集和分析这些日志，运维工程师可以更迅速地定位问题的根本原因，并采取适当的措施进行故障修复。

4. 定时任务和计划性维护 

网络设备的定期维护和任务调度对于网络的稳定性和性能至关重要。脚本可以按计划自动执行维护任务，例如备份设备配置、定期清理日志、更新设备固件等。通过自动化管理这些定期任务，运维工程师可以减少人工干预和遗漏，确保维护活动的及时性和一致性。

脚本示例

import paramiko
import json
from concurrent.futures import ThreadPoolExecutor
import logging

# 配置文件路径
CONFIG_FILE = 'devices.json'

# 日志配置
LOG_FILE = 'automation.log'
LOG_LEVEL = logging.INFO

# 并发线程数
CONCURRENT_THREADS = 5

# 连接超时时间（秒）
CONNECT_TIMEOUT = 10

# 配置日志
logging.basicConfig(filename=LOG_FILE, level=LOG_LEVEL)

# 读取设备信息配置文件
def read_config():
    try:
        with open(CONFIG_FILE, 'r') as file:
            config = json.load(file)
            return config
    except FileNotFoundError:
        logging.error(f'配置文件 {CONFIG_FILE} 未找到')
    except json.JSONDecodeError:
        logging.error(f'配置文件 {CONFIG_FILE} 解析错误')

    return None

# 连接设备
def connect_device(device):
    client = paramiko.SSHClient()
    client.set_missing_host_key_policy(paramiko.AutoAddPolicy())

    try:
        client.connect(
            hostname=device['host'],
            username=device['username'],
            key_filename=device['key_filename'],
            timeout=CONNECT_TIMEOUT
        )
        return client
    except paramiko.AuthenticationException:
        logging.error(f"无法连接设备 {device['host']}: 身份验证失败")
    except paramiko.SSHException as e:
        logging.error(f"无法连接设备 {device['host']}: {str(e)}")
    except Exception as e:
        logging.error(f"无法连接设备 {device['host']}: {str(e)}")

    return None

# 执行命令
def execute_command(client, command):
    try:
        stdin, stdout, stderr = client.exec_command(command, timeout=CONNECT_TIMEOUT)
        output = stdout.read().decode('utf-8')
        error = stderr.read().decode('utf-8')
        client.close()

        if error:
            logging.error(f"命令执行出错: {error}")
            return None

        return output.strip()
    except Exception as e:
        logging.error(f"命令执行出错: {str(e)}")
        return None

# 检查设备状态
def check_device_status(device):
    client = connect_device(device)

    if client:
        output = execute_command(client, 'show interfaces')
        if output:
            logging.info(f"设备 {device['host']} 状态正常")
            logging.info(output)

# 配置设备
def configure_device(device):
    client = connect_device(device)

    if client:
        config_commands = [
            'interface eth0',
            'ip address 192.168.1.1 255.255.255.0',
            'no shutdown'
        ]

        for command in config_commands:
            execute_command(client, command)

        logging.info(f"设备 {device['host']} 配置已更新")

# 故障排除
def troubleshoot_device(device):
    client = connect_device(device)

    if client:
        output = execute_command(client, 'show logs')
        if output:
            logging.info(f"设备 {device['host']} 故障排除日志:")
            logging.info(output)

# 主函数
def main():
    config = read_config()

    if config:
        with ThreadPoolExecutor(max_workers=CONCURRENT_THREADS) as executor:
            futures = []

            for device in config['devices']:
                logging.info(f"正在检查设备 {device['host']} 的状态...")
                futures.append(executor.submit(check_device_status, device))

                logging.info(f"正在配置设备 {device['host']}...")
                futures.append(executor.submit(configure_device, device))

                logging.info(f"正在对设备 {device['host']} 进行故障排除...")
                futures.append(executor.submit(troubleshoot_device, device))

            # 等待所有任务完成
            for future in futures:
                future.result()

# 执行主函数
if __name__ == '__main__':
    main()

网络设备自动化管理脚本是现代运维工程师的得力助手。它在提升运维效率、减少错误和提高网络可靠性方面发挥着重要作用。通过自动化执行设备配置、状态检查、故障排除和定期维护等任务，运维团队可以更好地管理和维护企业网络，确保网络的稳定运行，满足业务需求的不断增长。

结束!如有不足之处，欢迎指正！

来不及解释了，快上车！（加我微信拉你进群）：

欢迎新的小伙伴加入！在这里，我们鼓励大家积极参与群内讨论和交流，分享自己的见解和经验，一起学习和成长。同时，也欢迎大家提出问题和建议，让我们不断改进和完善这个平台。