采用python3.12 +django5.1 结合 RabbitMQ 和发送邮件功能,实现一个简单的告警系统 前后端分离 vue-element

一、开发环境搭建和配置

#mac环境
brew install python@3.12
python3.12 --version
python3.12 -m pip install --upgrade pip
python3.12 -m pip install Django==5.1
python3.12 -m django --version
#用于检索系统信息和进程管理
python3.12 -m pip install psutil
#集成 pika 用于 RabbitMQ
python3.12 -m pip install pika#要在 Docker 中安装 RabbitMQ 并开启 WebSocket 端口 15674
docker run -d --name rabbitmq \
-p 5672:5672 \
-p 15672:15672 \
-p 15674:15674 \
rabbitmq:3-management#进入容器内部
docker exec -it rabbitmq bash#在容器内部,启用 WebSocket 插件:
rabbitmq-plugins enable rabbitmq_web_stomp

二、构建django应用

# 创建 monitor-plat 项目
django-admin startproject operation#项目结构
operation
├── __init__.py
├── __pycache__
│   ├── __init__.cpython-313.pyc
│   ├── settings.cpython-313.pyc
│   ├── urls.cpython-313.pyc
│   └── wsgi.cpython-313.pyc
├── asgi.py
├── common
│   ├── __init__.py
│   ├── __pycache__
│   │   └── __init__.cpython-313.pyc
│   ├── enum
│   │   ├── EventTypesEnum.py
│   │   ├── OperatorTypeEnum.py
│   │   ├── ResponeCodeEnum.py
│   │   ├── __init__.py
│   │   └── __pycache__
│   │       ├── EventTypesEnum.cpython-313.pyc
│   │       ├── OperatorTypeEnum.cpython-313.pyc
│   │       ├── ResponeCodeEnum.cpython-313.pyc
│   │       └── __init__.cpython-313.pyc
│   ├── exception
│   │   ├── BusinessException.py
│   │   ├── __init__.py
│   │   └── __pycache__
│   │       ├── BusinessException.cpython-313.pyc
│   │       └── __init__.cpython-313.pyc
│   └── utils
│       ├── CommonResult.py
│       ├── PageUtils.py
│       ├── Serializers.py
│       ├── __init__.py
│       └── __pycache__
│           ├── CommonResult.cpython-313.pyc
│           ├── PageUtils.cpython-313.pyc
│           ├── Serializers.cpython-313.pyc
│           └── __init__.cpython-313.pyc
├── settings.py
├── urls.py
└── wsgi.py
log
├── __init__.py
├── __pycache__
│   ├── __init__.cpython-313.pyc
│   ├── admin.cpython-313.pyc
│   ├── apps.cpython-313.pyc
│   ├── models.cpython-313.pyc
│   └── views.cpython-313.pyc
├── admin.py
├── apps.py
├── migrations
│   ├── 0001_initial.py
│   ├── __init__.py
│   └── __pycache__
│       ├── 0001_initial.cpython-313.pyc
│       └── __init__.cpython-313.pyc
├── models.py
├── tests.py
└── views.py
dbOperations
├── __init__.py
├── __pycache__
│   ├── __init__.cpython-313.pyc
│   ├── admin.cpython-313.pyc
│   ├── apps.cpython-313.pyc
│   ├── models.cpython-313.pyc
│   └── views.cpython-313.pyc
├── admin.py
├── apps.py
├── migrations
│   ├── __init__.py
│   └── __pycache__
│       └── __init__.cpython-313.pyc
├── models.py
├── tests.py
└── views.py
user
├── __init__.py
├── __pycache__
│   ├── __init__.cpython-313.pyc
│   ├── admin.cpython-313.pyc
│   ├── apps.cpython-313.pyc
│   ├── models.cpython-313.pyc
│   └── views.cpython-313.pyc
├── admin.py
├── apps.py
├── migrations
│   ├── 0001_initial.py
│   ├── __init__.py
│   └── __pycache__
│       ├── 0001_initial.cpython-313.pyc
│       └── __init__.cpython-313.pyc
├── models.py
├── tests.py
└── views.py
monitor
├── __init__.py
├── __pycache__
│   ├── __init__.cpython-313.pyc
│   ├── admin.cpython-313.pyc
│   ├── apps.cpython-313.pyc
│   ├── models.cpython-313.pyc
│   ├── signals.cpython-313.pyc
│   ├── tasks.cpython-313.pyc
│   └── views.cpython-313.pyc
├── admin.py
├── apps.py
├── migrations
│   ├── 0001_initial.py
│   ├── __init__.py
│   └── __pycache__
│       ├── 0001_initial.cpython-313.pyc
│       └── __init__.cpython-313.pyc
├── models.py
├── signals.py
├── tasks.py
├── tests.py
└── views.py

三、监控,告警相关代码 

monitor
├── __init__.py
├── __pycache__
│   ├── __init__.cpython-313.pyc
│   ├── admin.cpython-313.pyc
│   ├── apps.cpython-313.pyc
│   ├── models.cpython-313.pyc
│   ├── signals.cpython-313.pyc
│   ├── tasks.cpython-313.pyc
│   └── views.cpython-313.pyc
#=========================tasks.py=========================
import logging
import multiprocessingimport pika
import json
import psutil
import time
from monitor.models import ServerSecurityEventLog
from operation import settings
from operation.common.enum.EventTypesEnum import EventTypesEnum"""监控服务器 性能  """
def send_memory_data():connection = Nonechannel = None#获取 rabbitmq配置rabbitmq_config = settings.RABBITMQ_CONFIGtry:connection = pika.BlockingConnection(pika.ConnectionParameters(host=rabbitmq_config['host'],port=rabbitmq_config['port'],virtual_host=rabbitmq_config['virtual_host'],credentials=pika.PlainCredentials(rabbitmq_config['user'], rabbitmq_config['password'])))channel = connection.channel()channel.queue_declare(queue='virtual_queue',durable=True)print("连接成功")logging.info("连接成功")except pika.exceptions.AMQPConnectionError as e:logging.error(f"无法连接到AMQP服务器: {e}")return  # 如果连接失败,直接返回,避免后续代码执行try:while True:cpu_usage = psutil.cpu_percent(interval=1)cup_num = multiprocessing.cpu_count()memory_usage = psutil.virtual_memory()use_memory_usage = round(memory_usage.percent / (1024 * 1024 * 1024), 2)  # 获取已使用的内存memory_usage_total = round(memory_usage.total / (1024 * 1024 * 1024), 2)  # 获取总内存free_usage = round(memory_usage.active / (1024 * 1024 * 1024), 2)  # 获取 空闲内存disk_usage = psutil.disk_usage('/')  # 获取根目录的磁盘使用情况disk_usage_total = round(disk_usage.total / (1024 * 1024 * 1024), 2)  # 获取磁盘总容量free_disk_usage = round(disk_usage.free / (1024 * 1024 * 1024), 2)  # 获取磁盘剩余容量network_io = psutil.net_io_counters()#告警逻辑 保存event事件save_serverSecurity_event(cpu_usage, memory_usage.percent, disk_usage.percent, network_io)memory_usage_data = {'cpu_usage': cpu_usage,  # CPU的使用率。百分比'cup_num': cup_num,'use_memory_usage': use_memory_usage,  # 内存的使用情况。通以字节(bytes)或更常见的单位(如MB、GB)表示'memory_usage_total': memory_usage_total,'free_usage': free_usage,  # 空闲内存'disk_usage': disk_usage,  # 磁盘的使用情况。通常以字节(bytes)'disk_usage_total': disk_usage_total,  # 获取磁盘总容量'free_disk_usage': free_disk_usage,  # 获取磁盘剩余容量'network_io': network_io  # 表示网络输入/输出的情况 通常以字节(bytes)}# 发送rabbitmqchannel.basic_publish(exchange='',routing_key='virtual_queue',body=json.dumps(memory_usage_data))logging.info("数据发送成功")time.sleep(5)  # 每5秒发送一次except Exception as e:logging.error(f"数据发送失败: {e}")finally:if connection and connection.is_open:connection.close()"""保存告警逻辑 
"""
def save_serverSecurity_event(cpu_usage,memory_usage,disk_usage,network_io):logging.info("保存告警逻辑=====================================")# 告警逻辑if (cpu_usage > settings.CPU_THRESHOLD ormemory_usage > settings.MEMORY_THRESHOLD ordisk_usage > settings.DISK_THRESHOLD ornetwork_io.packets_recv == settings.PACKET_RECV_THRESHOLD ornetwork_io.packets_sent == settings.PACKETS_SENT_THRESHOLD):event_type = Noneevent_details = ""# 当cpu使用率大于90%时 记录cpuif cpu_usage > settings.CPU_THRESHOLD:logging.info(f'CPU使用率超过90%')event_type = EventTypesEnum.CPU_OVERLOAD.valueevent_details = f'CPU使用率超过90%: {cpu_usage}%'elif memory_usage > settings.MEMORY_THRESHOLD:logging.info(f'内存使用率超过80%')event_type = EventTypesEnum.MEMORY_OVERLOAD.valueevent_details = f'内存使用率超过80%: 1.15MB%'elif disk_usage > settings.DISK_THRESHOLD:logging.info(f'磁盘使用率超过90%')event_type = EventTypesEnum.DISK_OVERLOAD.valueevent_details = f'磁盘使用率超过90%: {disk_usage}%'elif network_io.packets_recv == settings.PACKET_RECV_THRESHOLD or network_io.packets_sent == settings.PACKETS_SENT_THRESHOLD:logging.info(f'网络异常,接收或发送的数据包为0')event_type = EventTypesEnum.NETWORK_ANOMALY.valueevent_details = '网络异常,接收或发送的数据包为0'# 保存告警信息到数据库ServerSecurityEventLog.objects.create(event_type=event_type,event_details=event_details)
#========================signals.py========================="""
处理告警逻辑:
"""
import logging
import time
from datetime import datetimefrom django.core.mail import send_mail
from django.db.models.signals import post_save
from django.dispatch import receiverfrom monitor.models import ServerSecurityEventLog
from operation import settings"""发送告警邮件 
"""# 设置告警邮件的发送频率,单位为秒
ALERT_EMAIL_INTERVAL = 60 * 5  # 5分钟# 上次发送告警邮件的时间
last_alert_email_time = 0@receiver(post_save, sender=ServerSecurityEventLog)
def send_alert_email(sender, instance, **kwargs):#global 关键字: 在函数内部使用 global 关键字声明变量时,表示该变量是全局变量,# 而不是函数内部的局部变量。这样可以在函数内部修改全局变量的值。global last_alert_email_time#获取当前时间current_time = time.time()if current_time - last_alert_email_time >= ALERT_EMAIL_INTERVAL:logging.info("发送告警邮件====================")subject = '服务器告警'# 格式化时间为目标格式formatted_time = instance.event_time.strftime("%Y-%m-%d %H:%M:%S")message = (f'服务器状态异常,请立即检查!\n'f'事件类型: {instance.event_type}\n'f'事件详情: {instance.event_details}\n'f'触发时间: {formatted_time}\n')from_email = settings.DEFAULT_FROM_EMAILrecipient_list = ['xxxxxxxx@qq.com']try:send_mail(subject, message, from_email, recipient_list)logging.info("邮件发送成功")last_alert_email_time = current_time  # 更新上次发送告警邮件的时间except Exception as e:logging.error(f"发送邮件失败 {e}")

    

#======================apps.py======================
from django.apps import AppConfigclass MonitorConfig(AppConfig):default_auto_field = 'django.db.models.BigAutoField'name = 'monitor'"""ready 方法: 这是 AppConfig 类中的一个特殊方法,在 Django 应用启动时会被调用。通常用于执行一些初始化操作"""def ready(self):# 注册信号  导入 monitor.signals 模块,用于注册 Django 信号。信号是 Django 中一种用于在特定事件发生时触发操作的机制。#@receiver(post_save, sender=ServerSecurityEventLog)  再做ServerSecurityEventLog 保存操作时 会 触发操作的机制。import monitor.signals# 导入任务函数: 从 tasks 模块中导入 send_memory_data 函数。from .tasks import send_memory_data#创建并启动线程: 使用 threading.Thread 创建一个新线程,#并将 send_memory_data 函数作为目标函数传递给线程。然后调用 thread.start() 启动线程。from threading import Threadthread = Thread(target=send_memory_data)thread.start()
#==========================models.py==========================from django.db import models# Create your models here.#告警 models
class ServerSecurityEventLog(models.Model):EVENT_TYPES = (('cpu_overload', 'CPU过载'),('memory_overload', '内存过载'),('disk_overload', '磁盘过载'),('network_anomaly', '网络异常'),)event_type = models.CharField(max_length=50, choices=EVENT_TYPES)event_time = models.DateTimeField(auto_now_add=True)event_details = models.TextField()is_resolved = models.BooleanField(default=False)def __str__(self):return f"{self.event_type} - {self.event_time}"class Meta:db_table = 'server_security_events_log'  # 指定表名def to_dict(self):return {'id': self.id,'event_type':self.event_type,'event_details':self.event_details,'event_time':self.event_time,'is_resolved':self.is_resolved}
#=========================views.py=========================#用于前端展示
import json
import multiprocessingimport psutil
from django.http import HttpResponse, JsonResponse
from django.views.decorators.csrf import csrf_exemptfrom monitor.models import ServerSecurityEventLog
from operation.common.enum.ResponeCodeEnum import ResponseCodeEnum
from operation.common.exception.BusinessException import BusinessException
from operation.common.utils.CommonResult import CommonResult
from operation.common.utils.PageUtils import paginate_querysetdef getSystemInfo(request):try:if request.method != "GET":raise BusinessException(ResponseCodeEnum.METHOD_ERROR.message,ResponseCodeEnum.METHOD_ERROR.code)cpu_usage = psutil.cpu_percent(interval=1)cup_count = multiprocessing.cpu_count()memory_usage = psutil.virtual_memory()use_memory_usage = round(memory_usage.percent/(1024 * 1024 * 1024),2) #获取已使用的内存memory_usage_total = round(memory_usage.total/(1024 * 1024 * 1024),2) #获取总内存free_usage = round(memory_usage.active/(1024 * 1024 * 1024),2)      #获取 空闲内存存disk_usage = psutil.disk_usage('/')     #获取根目录的磁盘使用情况disk_usage_total = round(disk_usage.total/(1024 * 1024 * 1024),2)     #获取磁盘总容量free_disk_usage = round(disk_usage.free /(1024 * 1024 * 1024),2)     #获取磁盘剩余容量network_io = psutil.net_io_counters()data = {'cpu_usage': cpu_usage,    #CPU的使用率。百分比'cup_count':cup_count,'use_memory_usage': use_memory_usage, #内存的使用情况。通以字节(bytes)或更常见的单位(如MB、GB)表示'memory_usage_total':memory_usage_total,'free_usage':free_usage,   #空闲内存'disk_usage': disk_usage,   #磁盘的使用情况。通常以字节(bytes)'disk_usage_total':disk_usage_total, #获取磁盘总容量'free_disk_usage':free_disk_usage,  #获取磁盘剩余容量'network_io': network_io    #表示网络输入/输出的情况 通常以字节(bytes)}return JsonResponse(CommonResult.success_data(data), json_dumps_params={'ensure_ascii': False})except BusinessException as e:return JsonResponse(CommonResult.error(e.code,e.message), json_dumps_params={'ensure_ascii': False})"""获取告警列表
"""
@csrf_exempt
def getAlarmList(request):if request.method == 'POST':json_data = request.bodydata = json.loads(json_data)page = data.get('page', 1)page_size = data.get('page_size', 10)serverSecurityEventLogs = ServerSecurityEventLog.objects.all().order_by('event_time')event_list, pagination_info = paginate_queryset(serverSecurityEventLogs, page, page_size)event_lists = [ServerSecurityEventLog.to_dict() for ServerSecurityEventLog in event_list]return JsonResponse(CommonResult.success_pagination(event_lists, pagination_info), json_dumps_params={'ensure_ascii': False})else:return JsonResponse(CommonResult.success_data(), json_dumps_params={'ensure_ascii': False})
#==============================EventTypesEnum工具类==============================##############################EventTypesEnum##############################"""('cpu_overload', 'CPU过载'),('memory_overload', '内存过载'),('disk_overload', '磁盘过载'),('network_anomaly', '网络异常'),
"""
from enum import Enumclass EventTypesEnum(Enum):CPU_OVERLOAD = ('cpu_overload', 'CPU过载')MEMORY_OVERLOAD = ('memory_overload', '内存过载')DISK_OVERLOAD = ('disk_overload', '磁盘过载')NETWORK_ANOMALY = ('network_anomaly', '网络异常')"""Enum 的成员值不能直接是元组可以使用 Enum 的 __new__ 方法来自定义枚举成员的创建过程。 __value: 私有变量__value__: 双下划线前后缀通常用于定义Python的特殊方法(也称为魔术方法)。这些方法有特定的用途,例如 __init__ 用于初始化对象,__str__ 用于定义对象的字符串表示等。_value_: 双下划线前后缀通常用于避免与Python的特殊方法或内置函数命名冲突。这种命名方式并不常见,通常是为了避免与Python的保留字或特殊方法名冲突。_value:单个下划线前缀通常用于表示一个变量是“内部使用”的。虽然Python没有真正的私有变量,但这种命名约定告诉其他开发者这个变量不应该被直接访问。"""def __new__(cls,code,message):obj = object.__new__(cls)obj._value_ = codeobj.message = messagereturn obj@propertydef get_message(self):return self.message##############################OperatorTypeEnum##############################
import logging
from enum import Enum"""
操作类别(0其它 1后台用户 2手机端用户) other,backend,mobile
"""
from enum import Enumclass OperatorTypeEnum(Enum):# 元组OPERATOR_TYPE_OTHER = (0, "其它")OPERATOR_TYPE_BACKEND = (1, "后台用户")OPERATOR_TYPE_MOBILE = (2, "手机端用户")# def __init__(self, code, value):#     self.code = code#     self.message = value#     logging.info("执行OperatorTypeEnum 初始化 code %s,value %s================"%(self.code,self.value))"""cls:表示类的本身(以便在类方法中访问枚举类的成员变量。)self:表示实例"""@classmethoddef get_value_by_id(cls,code):for operator in cls:if operator.value[0] == code:return operator.value[1]return None##############################ResponseCodeEnum##############################
from enum import Enumclass ResponseCodeEnum(Enum):SUCCESS = (200, "操作成功!")PARAMS_ERROR = (400, "参数解析失败,请核对参数!")UNAUTHORIZED = (401, "未认证(签名错误)")FORBIDDEN = (402, "请求错误")  # 返回失败业务公共codeMEDIA_TYPE_ERROR = (403, "不支持的媒体异常,请核对contentType!")URL_REQ_NULL = (404, "请求路径不存在")METHOD_ERROR = (405, "不支持当前请求方法,请核对请求方法!")INTERNAL_SERVER_ERROR = (500, "服务器内部错误!")  # 系统异常公共codeNULL_POINTER_ERROR = (600, "请核对必填字段是否为空!")NUMBER_FORMAT_ERROR = (601, "数据类型不一致!")PARAMS_TYPE_ERROR = (602, "参数类型错误!")TIMEOUT_ERROR = (603, "token失效连接超时!")TIMEOUT_EXPIRE_ERROR = (604, "token登录过期!")TOKEN_ILLEGAL = (605, "非法token!")USER_LOGIN_FAIL = (1001,"用户登录失败!")def __init__(self, code, message):self.code = codeself.message = message#@property 是 Python 中用于将类的方法转换为属性访问的装饰器。# 使用 @property 装饰器,你可以像访问属性一样访问方法,而不需要调用它@propertydef status_code(self):return self.code@propertydef error_message(self):return self.message#<class 'enum.EnumType'> 枚举类
# print(type(ResponseCodeEnum))
#<enum 'ResponseCodeEnum'> SUCCESS 是 ResponseCodeEnum 枚举类的一个实例。
# print(type(ResponseCodeEnum.SUCCESS))##############################BusinessException##############################class BusinessException(Exception):def __init__(self,message,code):self.message = messageself.code = code##############################CommonResult##############################
from typing import Any, Optionalfrom operation.common.enum.ResponeCodeEnum import ResponseCodeEnumclass CommonResult:"""res: ResponseCodeEnum 这个定义表示 res 参数的类型是 ResponseCodeEnum,即 res 必须是 ResponseCodeEnum 的枚举值之一。这种定义方式有助于提高代码的类型安全性和可读性。"""def __init__(self, res: ResponseCodeEnum, data: Any, pagination: Optional[dict] = None):self.ResponseCodeEnum = ResponseCodeEnumself.data = dataself.pagination = pagination"""表态方法定义 直接通过 CommonResult.success  类名.静态方法名@staticmethod 不能访问或修改类或实例的属性。"""@staticmethoddef success_pagination(data: Any, pagination: Optional[dict] = None):return {'code': ResponseCodeEnum.SUCCESS.status_code,'message': ResponseCodeEnum.SUCCESS.message,'data': data,  # 将 QuerySet 序列化为 JSON,'pagination': pagination}@staticmethoddef error(code,message):return {'code': code,'message': message,'data': None,  # 将 QuerySet 序列化为 JSON,'pagination': None}@staticmethoddef success_data(data: Any):return {'code': ResponseCodeEnum.SUCCESS.status_code,'message': ResponseCodeEnum.SUCCESS.message,'data': data,  # 将 QuerySet 序列化为 JSON,}##############################PageUtils##############################from django.core.paginator import Paginator, EmptyPage, PageNotAnIntegerdef paginate_queryset(queryset, page, page_size):"""分页封装函数:param queryset: 查询集:param page: 页码:param page_size: 每页记录数:return: 分页后的数据和分页信息"""paginator = Paginator(queryset, page_size)try:page_obj = paginator.page(page)except PageNotAnInteger:page_obj = paginator.page(1)except EmptyPage:page_obj = paginator.page(paginator.num_pages)pagination_info = {'total_pages': paginator.num_pages,'current_page': page_obj.number,'has_next': page_obj.has_next(),'has_previous': page_obj.has_previous(),'next_page_number': page_obj.next_page_number() if page_obj.has_next() else None,'previous_page_number': page_obj.previous_page_number() if page_obj.has_previous() else None,'total': paginator.count}return page_obj.object_list, pagination_info##############################Serializer############################### db_operations/serializers.py
from rest_framework import serializersclass SQLExecutionSerializer(serializers.Serializer):sql = serializers.CharField()

四、 settings.py配置

#数据库 连接配置 mysql
DATABASES = {'default': {# 数据库引擎'ENGINE': 'django.db.backends.mysql',# 'ENGINE': 'sqlalchemy.create_engine',# 数据库名字'NAME': 'xxx',# 数据库用户名'USER': 'xx',# 数据库密码'PASSWORD': 'xx',# 数据库主机地址'HOST': 'xxx.xxx.xxx.xxx',# 数据库端口号'PORT': 'xxx'}
}LOGGING = {'version': 1,'disable_existing_loggers': False,'handlers': {'console': {'class': 'logging.StreamHandler',},},'root': {'handlers': ['console'],'level': 'INFO',},'loggers': {'django': {'handlers': ['console'],'level': 'INFO','propagate': False,},},
}INSTALLED_APPS = ['django.contrib.admin','django.contrib.auth','django.contrib.contenttypes','django.contrib.sessions','django.contrib.messages','django.contrib.staticfiles','log','monitor','user','dbOperations'
]# 告警 邮箱配置  需要开通 smtp 权限 在qq邮箱中 配置
EMAIL_BACKEND = 'django.core.mail.backends.smtp.EmailBackend'
EMAIL_HOST = 'smtp.qq.com'  # QQ邮箱的SMTP服务器
EMAIL_PORT = 465  # QQ邮箱的SMTP端口
EMAIL_USE_SSL = True  # 使用SSL加密
EMAIL_HOST_USER = 'xx'  # 你的QQ邮箱
EMAIL_HOST_PASSWORD = 'xx'  # 你的QQ邮箱密码或授权码
DEFAULT_FROM_EMAIL = EMAIL_HOST_USER# RabbitMQ 配置
RABBITMQ_CONFIG = {'host': 'xx.xx.xx.xx','port': xx,'virtual_host': '/','user': 'xx','password': 'xx',
}

五、  创建和应用迁移


#创建数据库迁移文件并应用
python manage.py makemigrations
python manage.py migrate

六、  注册前端请求路由

from django.contrib import admin
from django.urls import pathfrom log import views as log_views
from monitor import views as monitor_views
from user import views as user_views
from dbOperations import views as db_views"""说明:这个路径将 /admin/ 开头的 URL 映射到 Django 自带的管理后台。admin.site.urls 是 Django 管理后台的 URL 配置,包含了管理后台的所有功能和页面。这个路径将 /log/ 开头的 URL 映射到 log 应用中的 getLogList 视图函数。name='log' 为这个 URL 路径定义了一个名称,可以在模板或其他地方通过这个名称来引用这个 URL。
"""
urlpatterns = [path('admin/', admin.site.urls),path('log/getLogList', log_views.getLogList, name='log_list'),path('log/getDebugLogList', log_views.getDebugLogList,name='debug_log_list'),path('monitor/getSystemInfo', monitor_views.getSystemInfo,name='system_info'),path('monitor/getAlarmList', monitor_views.getAlarmList, name='alarm_list'),path('user/login',user_views.login, name='login'),path('dbOperations/executeSQLView', db_views.executeSQLView,name='execute_sql_view')
]

七、  启动项目

#打开终端 cd 到根目录 
python manage.py runserver

八、  效果

#启动 前端 项目
npm run dev#==========================前端部分代码  alarmPage.vue==========================<template><div class="app-container"><el-card shadow="always"><el-form ref="searchForm" :inline="true" :model="searchMap" style="margin-top: 20px"><el-form-item><el-button type="primary" icon="el-icon-search" @click="searchLog('searchForm')">搜索</el-button><el-button type="primary" icon="el-icon-clear" @click="resetForm('searchForm')">重置</el-button></el-form-item></el-form></el-card><el-card shadow="always"><div><el-table ref="multipleTable" v-loading="listLoading" :data="alarmListDto" border fit highlight-current-row style="width: 100%;" class="tb-edit"><el-table-column label="操作ID" prop="id" width="180px" align="center" /><el-table-column label="事件类型" prop="event_type" width="380px" align="center" /><el-table-column label="事件详情" prop="event_details" width="380px" align="center" /><!-- <el-table-column label="是否已解决" prop="is_resolved" width="180px" align="center" /> --><el-table-column label="触发时间" prop="event_time" width="180px" align="center" /></el-table></div><div class="block"><el-pagination :current-page="currentPage" :page-sizes="[5, 10, 15, 20]" :page-size="5" layout="total, sizes, prev, pager, next, jumper" :total="total" @size-change="handleSizeChange" @current-change="handleCurrentChange" /></div></el-card></div>
</template><script>import {getAlarmList} from '@/api/monitors/monitors-request'export default {data() {return {total: 0,currentPage: 1,searchMap: {},listLoading: true,params: {page: 1, // 当前页码page_size: 5 // 每页显示数目},alarmListDto: [],error: ''}},mounted() {this.getAlarmList()},methods: {handleSizeChange(val) {console.log(`每页 ${val} 条`)this.params.page_size = valthis.getAlarmList()},handleCurrentChange(val) {console.log(`当前页: ${val}`)this.params.page = valthis.getAlarmList()},// 重置功能,element ui 提供的功能resetForm(formName) {console.log(this.$refs[formName].resetFields)this.$refs[formName].resetFields()this.getAlarmList()},searchLog(formName) {console.log(this.searchMap)this.getAlarmList()},getAlarmList() {this.dataLoading = trueconsole.log('请求参数:' + this.params)getAlarmList(this.params).then((res) => {console.log('响应:', res.data.data)alert(JSON.stringify(res.data.data))this.alarmListDto = res.data.datathis.total = res.data.pagination.totalsetTimeout(() => { // 超过指定超时时间  关闭查询的转圈的loading加载动画this.listLoading = false}, 1.5 * 1000)})}}}
</script><style>
</style>

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/886829.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

深入探讨 Puppeteer 如何使用 X 和 Y 坐标实现鼠标移动

背景介绍 现代爬虫技术中&#xff0c;模拟人类行为已成为绕过反爬虫系统的关键策略之一。无论是模拟用户点击、滚动&#xff0c;还是鼠标的轨迹移动&#xff0c;都可以为爬虫脚本带来更高的“伪装性”。在众多的自动化工具中&#xff0c;Puppeteer作为一个无头浏览器控制库&am…

【学术论文投稿】JavaScript 前端开发:从入门到精通的奇幻之旅

【中文核刊&普刊投稿通道】2024年体育科技与运动表现分析国际学术会议(ICSTPA 2024)_艾思科蓝_学术一站式服务平台 更多学术会议论文投稿请看&#xff1a;https://ais.cn/u/nuyAF3 目录 一、引言 二、JavaScript 基础 &#xff08;一&#xff09;变量与数据类型 &am…

Leetcode 最长回文子串

目录 解法1&#xff1a;递归算法 解法2&#xff1a;Map取同字母位置法 解法3&#xff1a;中心扩展法 解法4&#xff1a;动态规划法 解法5: Manacher算法 示例 1&#xff1a; 输入&#xff1a;s "babad" 输出&#xff1a;"bab" 解释&#xff1a;&quo…

SpringBoot(8)-任务

目录 一、异步任务 二、定时任务 三、邮件任务 一、异步任务 使用场景&#xff1a;后端发送邮件需要时间&#xff0c;前端若响应不动会导致体验感不佳&#xff0c;一般会采用多线程的方式去处理这些任务&#xff0c;但每次都需要自己去手动编写多线程来实现 1、编写servic…

WebStorm 2022.3.2/IntelliJ IDEA 2024.3出现elementUI提示未知 HTML 标记、组件引用爆红等问题处理

WebStorm 2022.3.2/IntelliJ IDEA 2024.3出现elementUI提示未知 HTML 标记、组件引用爆红等问题处理 1. 标题识别elementUI组件爆红 这个原因是&#xff1a; 在官网说明里&#xff0c;才版本2024.1开始&#xff0c;默认启用的 Vue Language Server&#xff0c;但是在 Vue 2 项…

Odoo :免费且开源的农牧行业ERP管理系统

文 / 开源智造Odoo亚太金牌服务 引言 提供农牧企业数字化、智能化、无人化产品服务及全产业链高度协同的一体化解决方案&#xff0c;提升企业智慧种养、成本领先、产业互联的核心竞争力。 行业典型痛点 一、成本管理粗放&#xff0c;效率低、管控弱 产品研发过程缺少体系化…

【Unity踩坑】出现d3d11问题导致编辑器崩溃

升级到Unity 6&#xff0c;有时出现下面这种D3D11的问题&#xff0c;会导致编辑器崩溃。 有人总结了这个问题的解决方法&#xff0c;可以做为参考&#xff1a; Failed to present D3D11 swapchain due to device reset/removed. List of Solutions - Unity Engine - Unity Dis…

数据库基础(MySQL)

1. 数据库基础 1.1 什么是数据库 存储数据用文件就可以了&#xff0c;为什么还要弄个数据库? 文件保存数据有以下几个缺点&#xff1a; 文件的安全性问题文件不利于数据查询和管理文件不利于存储海量数据文件在程序中控制不方便 数据库存储介质&#xff1a; 磁盘内存 为…

JMeter监听器与压测监控之Grafana

Grafana 是一个开源的度量分析和可视化套件&#xff0c;通常用于监控和观察系统和应用的性能。本文将指导你如何在 Kali Linux 上使用 Docker 来部署 Grafana 性能监控平台。 前提条件 Kali Linux&#xff1a;确保你已经安装了 Kali Linux。Docker&#xff1a;确保你的系统已…

集群聊天服务器(13)redis环境安装和发布订阅命令

目录 环境安装订阅redis发布-订阅的客户端编程环境配置客户端编程 功能测试 环境安装 sudo apt-get install redis-server 先启动redis服务 /etc/init.d/redis-server start默认在6379端口上 redis是存键值对的&#xff0c;还可以存链表、数组等等复杂数据结构 而且数据是在…

linux常用指令总结(附Vim编辑器学习总结)

本文是博主对Linux中经常用到的一些指令进行的总结&#xff0c;文章也附带了Linux中经常用到的Vim编辑器的一些基本知识和使用指令&#xff0c;觉得有帮助的朋友可以点赞收藏&#xff01; 本文会持续进行更新 linux常用指令总结 $ pwd # 查看当前终端所在…

w046基于web的古典舞在线交流平台的设计与实现

&#x1f64a;作者简介&#xff1a;多年一线开发工作经验&#xff0c;原创团队&#xff0c;分享技术代码帮助学生学习&#xff0c;独立完成自己的网站项目。 代码可以查看文章末尾⬇️联系方式获取&#xff0c;记得注明来意哦~&#x1f339;赠送计算机毕业设计600个选题excel文…

阿里云轻量应用服务器可以用在哪些场景呢

在数字化转型的浪潮中&#xff0c;中小企业面临着如何快速、高效地上云的挑战。阿里云轻量应用服务器&#xff08;SWAS&#xff09;作为一款专为中小企业设计的云服务产品&#xff0c;提供了简单易用、经济实惠的解决方案&#xff0c;助力企业轻松实现云端部署&#xff0c;赋能…

爬虫开发工具与环境搭建——使用Postman和浏览器开发者工具

第三节&#xff1a;使用Postman和浏览器开发者工具 在网络爬虫开发过程中&#xff0c;我们经常需要对HTTP请求进行测试、分析和调试。Postman和浏览器开发者工具&#xff08;特别是Network面板和Console面板&#xff09;是两种最常用的工具&#xff0c;能够帮助开发者有效地捕…

【操作系统】每日 3 题(二十九)

✍个人博客&#xff1a;https://blog.csdn.net/Newin2020?typeblog &#x1f4e3;专栏地址&#xff1a;https://blog.csdn.net/newin2020/category_12820365.html &#x1f4da;专栏简介&#xff1a;在这个专栏中&#xff0c;我将会分享操作系统面试中常见的面试题给大家~ ❤️…

JSON.stringify的应用说明

前言 JSON.stringify() 方法将 JavaScript 对象转换为字符串,在日常开发中较常用&#xff0c;但JSON.stringify其实有三个参数&#xff0c;后两个参数&#xff0c;使用较少&#xff0c;今天来介绍一下后两个参数的使用场景和示例。 语法及参数说明 JSON.stringify()&#xf…

Orcad 输出有链接属性的PDF

安装adobe pdf安装Ghostscript修改C:\Cadence\SPB_16.6\tools\capture\tclscripts\capUtils\capPdfUtil.tcl ​ 设置默认打印机为 Adobe PDF ​ 将Ghostscript的路径修改正确 打开cadence Orcad &#xff0c;accessories->candece Tcl/Tk Utilities-> Utilities->PD…

React(二)

文章目录 项目地址七、数据流7.1 子组件传递数据给父组件7.1.1 方式一:給父设置回调函数,传递给子7.1.2 方式二:直接将父的setState传递给子7.2 给props传递jsx7.2.1 方式一:直接传递组件给子类7.2.2 方式二:传递函数给子组件7.3 props类型验证7.4 props的多层传递7.5 cla…

Electron教程1-初学入门

玩转Electron Electron 是什么注意事项环境安装安装 vscode安装 git 第一个实例第二个实例第二个实例解读 总结问题解答 Electron 是什么 Electron是一个使用 JavaScript、HTML 和 CSS 构建桌面应用程序的框架。 嵌入 Chromium 和 Node.js 到 二进制的 Electron 允许您保持一个…

类和对象——拷贝构造函数,赋值运算符重载(C++)

1.拷⻉构造函数 如果⼀个构造函数的第⼀个参数是自身类类型的引用&#xff0c;且任何额外的参数都有默认值&#xff0c;则此构造函数也叫做拷贝构造函数&#xff0c;也就是说拷贝构造是⼀个特殊的构造函数。 // 拷贝构造函数//d2(d1) Date(const Date& d) {_year d._yea…