简介这是一套面向计算机专业毕业设计场景的自动化运维平台源码基于Python与Django构建适合正在准备毕设或希望系统学习Web开发与运维自动化的学生与开发者。平台围绕服务器监控、日志分析、任务调度、配置管理、权限控制与RESTful API等模块展开将Python的paramiko、psutil等运维能力与Django的MVT架构、认证权限体系结合形成一套可运行、可扩展的完整项目。压缩包共1132个文件约13.78MB其中191个py文件承载核心业务逻辑223个html与144个css、184个js构成前端界面另有png、gif等静态资源及txt、md、yml、conf等配置与说明文档目录结构清晰便于按模块阅读与二次开发。目前已有312人学习下载。对于毕设选题、答辩演示或运维自动化入门而言这份源码提供了从需求拆解到功能落地的参考路径读者可借此理解监控指标采集、定时任务编排与权限分层的实现思路并在此基础上完成个性化改造。1. 从一份 Django 自动化运维平台源码说起它能替你省掉哪些重复劳动如果你手头正压着一个运维相关的毕业设计或者想找一个能跑起来的 Django 全栈项目练手这份「基于 pythonDjango 的自动化运维平台」源码包值得先看一眼。它解决的不是什么高深算法问题而是一线运维里最磨人的那类活批量执行命令、定时巡检、资产信息集中管理、任务结果回看。这些事用脚本也能干但脚本散落在各台机器上换个人接手就得重新翻一遍时间一长连自己都记不清哪个脚本对应哪台机器。这个平台把这些零散操作收进一个 Web 界面用 Django 做后端和页面渲染Python 负责实际的任务调度与远程执行。适合两类人一类是毕设需要完整可演示系统的同学另一类是想拿一个真实项目熟悉 Django 视图、模型、模板三层怎么串起来的新手。它不追求大而全但把「提交任务 → 执行 → 存结果 → 页面展示」这条链路走通了这一点比很多只画界面的 demo 实在。2. 拆开源码包先看什么目录结构、依赖与启动链路拿到一个 Django 项目压缩包别急着runserver。先花十分钟把目录和依赖理清楚后面能少踩一半的坑。这个包的结构是标准 Django 布局但运维平台会多出任务执行和资产采集相关的模块需要重点确认。2.1 目录骨架与各目录职责解压后典型结构如下不同版本可能略有出入但核心目录不会变opsplatform/ ├── manage.py ├── requirements.txt ├── opsplatform/ │ ├── settings.py │ ├── urls.py │ └── wsgi.py ├── apps/ │ ├── assets/ # 资产管理 │ ├── tasks/ # 任务调度与执行 │ └── accounts/ # 登录与权限 ├── templates/ ├── static/ └── scripts/ # 实际执行的运维脚本apps/下按功能拆 app 是 Django 的常规做法好处是资产、任务、账号三块互不干扰。scripts/目录要特别留意运维平台真正干活的逻辑往往在这里而不是在视图里。先打开requirements.txt看依赖清单常见的是 Django、paramikoSSH 远程执行、celery异步任务、redis消息队列这几样。2.2 依赖安装与数据库初始化确认 Python 版本后建虚拟环境别直接往系统环境里装。Django 2.x 和 3.x 在路由写法上有差异装错版本会出现url() got an unexpected keyword argument这类报错。# 建虚拟环境python3.8 是这类老项目比较稳的选择 python3.8 -m venv venv source venv/bin/activate # Windows 用 venv\Scripts\activate # 按清单装依赖建议加国内镜像源加速 pip install -r requirements.txt -i https://pypi.tuna.tsinghua.edu.cn/simple # 生成数据库表sqlite 默认无需额外配置 python manage.py makemigrations python manage.py migrate # 建管理员账号用于登录后台 python manage.py createsuperusermakemigrations负责把模型变更翻译成迁移文件migrate才真正写库两步不能省。如果migrate报外键约束错误多半是 app 注册顺序问题检查settings.py里的INSTALLED_APPS把自定义 app 放在 Django 内置 app 之后。2.3 启动前必须改的三个配置settings.py里有三处不改就跑不顺配置项默认值改成什么原因ALLOWED_HOSTS空列表[*]或本机 IP空列表只允许 localhost局域网访问会被拒DEBUGTrue调试期保持 True生产才关关了静态文件不自动服务DATABASESsqlite3按需换 MySQL并发任务多时 sqlite 会锁表改完执行python manage.py runserver 0.0.0.0:8000浏览器打开对应地址能看到登录页说明主链路通了。看不到页面先看终端报错Django 的报错信息给得比较直白缺表、缺模块都会点名。3. 核心功能怎么跑通资产采集、任务下发与结果回显平台的价值全在这三块。资产采集解决「我有哪些机器」任务下发解决「让机器干什么」结果回显解决「干成没有」。这三块串起来才是一个能用的运维平台缺一块就退化成玩具。3.1 资产模型设计与数据录入资产 app 的模型通常长这样字段设计直接决定后面能查什么# apps/assets/models.py from django.db import models class Host(models.Model): hostname models.CharField(max_length64, uniqueTrue) ip models.GenericIPAddressField(uniqueTrue) port models.IntegerField(default22) username models.CharField(max_length32) # 密码实际项目应加密存储这里演示用明文 password models.CharField(max_length128, blankTrue) group models.CharField(max_length32, defaultdefault) created models.DateTimeField(auto_now_addTrue) def __str__(self): return f{self.hostname}({self.ip})ip用GenericIPAddressField而不是普通字符字段Django 会自动做格式校验录入时填错会直接报错省得后面连接时才炸。uniqueTrue防止同一台机器重复录入。密码字段在真实环境一定要走加密常见做法是用cryptography库做对称加密密钥放环境变量里别硬编码进代码。录入方式有两种后台 admin 逐条加或者写个批量导入脚本读 CSV。机器多的时候后者省事# 批量导入示例放在 manage.py shell 里执行 import csv from apps.assets.models import Host with open(hosts.csv) as f: for row in csv.DictReader(f): Host.objects.get_or_create( iprow[ip], defaults{ hostname: row[hostname], username: row[username], password: row[password], } )get_or_create保证重复执行不会产生脏数据defaults里的字段只在新建时写入已存在的记录不会被覆盖。这个习惯在运维脚本里很关键因为导入操作经常要重跑。3.2 用 paramiko 实现远程命令执行任务执行的核心是 SSH。paramiko 是 Python 里最常用的 SSH 库封装好连接、执行、取回显三步# apps/tasks/executor.py import paramiko def run_command(host, command, timeout30): client paramiko.SSHClient() # 首次连接自动接受主机密钥生产环境应预置 known_hosts client.set_missing_host_key_policy(paramiko.AutoAddPolicy()) try: client.connect( hostnamehost.ip, porthost.port, usernamehost.username, passwordhost.password, timeouttimeout ) stdin, stdout, stderr client.exec_command(command, timeouttimeout) out stdout.read().decode(utf-8, errorsignore) err stderr.read().decode(utf-8, errorsignore) return {ok: True, stdout: out, stderr: err} except Exception as e: return {ok: False, error: str(e)} finally: client.close()AutoAddPolicy图省事但会跳过主机密钥校验内网测试无所谓跨网段用要换成预置known_hosts否则中间人攻击防不住。timeout参数必须设不设的话某台机器网络卡住整个任务线程就挂在那页面一直转圈。errorsignore是防止某些命令输出含非 UTF-8 字符时解码直接抛异常。3.3 任务结果落库与页面回显执行完的结果要存下来否则刷新页面就没了。建个任务记录模型# apps/tasks/models.py class TaskRecord(models.Model): host models.ForeignKey(assets.Host, on_deletemodels.CASCADE) command models.TextField() stdout models.TextField(blankTrue) stderr models.TextField(blankTrue) status models.CharField(max_length16, defaultpending) created models.DateTimeField(auto_now_addTrue)on_deletemodels.CASCADE表示主机删了它的任务记录一起删。如果希望保留历史记录改成SET_NULL并把nullTrue加上。视图里拿到执行结果后写库模板里循环渲染即可。任务多的时候同步执行会阻塞页面常见做法是接 Celery 把执行丢到后台页面先返回「任务已提交」用户刷新看状态。这一步是这类平台从「能用」到「好用」的分水岭。4. 避坑与排查这份源码最容易翻车的五个地方源码包能跑起来不代表能改明白下面这几条是我拆类似项目时反复遇到的按「现象 → 原因 → 解决」记下来能省不少调试时间。现象runserver启动报No module named xxx。原因依赖没装全或者虚拟环境没激活pip 装到了系统环境。 解决确认命令行前缀有(venv)再pip list核对requirements.txt里的包是否都在。缺哪个补哪个别一次装一堆。现象页面能打开但样式全丢CSS 不生效。原因DEBUGFalse时 Django 不再自动服务静态文件而项目没配 Nginx 或static路由。 解决调试期把DEBUG设回True要长期关掉就在urls.py里加static(settings.STATIC_URL, document_rootsettings.STATIC_ROOT)的调试路由。现象远程执行一直超时但手动 SSH 能连上。原因目标机防火墙只放行了特定来源 IP或者 paramiko 用的端口和实际 SSH 端口不一致。 解决先在服务器上telnet 目标IP 22确认端口通再核对Host模型里的port字段。防火墙策略要找运维确认别自己乱改。现象任务执行成功但页面显示空白。原因命令输出走了 stderr 而不是 stdout代码只取了 stdout。 解决把stderr也存库并在页面展示。很多命令的正常提示信息是往 stderr 写的只取 stdout 会漏掉关键信息。现象并发提交多个任务后数据库报database is locked。原因sqlite 不支持高并发写多个任务同时写记录就锁表。 解决换 MySQL 或 PostgreSQL。改settings.py的DATABASES配置装对应驱动mysqlclient 或 psycopg2重新migrate。提示改数据库前先备份 sqlite 文件迁移过程中出问题还能退回去。5. 从能跑到好用任务异步化与执行日志的进阶处理同步执行在机器少的时候够用一旦资产上到几十台页面提交后要等所有机器跑完才返回体验直接崩。把执行逻辑丢给 Celery 是这类平台的标准升级路径也是这份源码最值得动手改的地方。先装 Celery 和 Redis在项目里加celery.py# opsplatform/celery.py import os from celery import Celery os.environ.setdefault(DJANGO_SETTINGS_MODULE, opsplatform.settings) app Celery(opsplatform) # 从 Django settings 里读以 CELERY_ 开头的配置 app.config_from_object(django.conf:settings, namespaceCELERY) app.autodiscover_tasks()namespaceCELERY意味着settings.py里写CELERY_BROKER_URL redis://127.0.0.1:6379/0就能被识别。autodiscover_tasks()会自动去每个 app 下找tasks.py所以执行函数要挪到apps/tasks/tasks.py里并加上装饰器from celery import shared_task from .executor import run_command from .models import TaskRecord shared_task def async_run(host_id, command): from apps.assets.models import Host host Host.objects.get(idhost_id) result run_command(host, command) TaskRecord.objects.create( hosthost, commandcommand, stdoutresult.get(stdout, ), stderrresult.get(stderr, result.get(error, )), statussuccess if result[ok] else failed ) return result[ok]视图里改成async_run.delay(host.id, command)页面立刻返回用户刷新看状态。启动 worker 用celery -A opsplatform worker -l infoWindows 上要加-P solo参数否则会报进程池相关的错。日志这块别只存 stdout 和 stderr 就完事。加一个执行耗时字段用time.time()前后差值算存进模型。时间一长你会发现排查性能问题靠的就是这个字段——哪台机器执行同一条命令突然变慢一眼就能看出来。我一般还会在TaskRecord上加个operator字段记录是谁提交的多人共用平台时这个信息不能少。验证异步链路是否通最简单的办法是提交一条sleep 10 echo done页面应该秒回「已提交」十秒后刷新状态变成成功。如果一直停在 pending先看 worker 终端有没有收到任务再看 Redis 是否正常。从那以后我每次改完任务执行逻辑都强制走一遍「提交 → 看 worker 日志 → 查数据库记录 → 刷新页面」这四步少一步都可能漏掉状态不同步的问题。希望帮到你。本文还有配套的精品资源点击获取
