当前位置: 首页 > news >正文

采用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>

相关文章:

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

一、开发环境搭建和配置 #mac环境 brew install python3.12 python3.12 --version python3.12 -m pip install --upgrade pip python3.12 -m pip install Django5.1 python3.12 -m django --version #用于检索系统信息和进程管理 python3.12 -m pip install psutil #集成 pika…...

Qt 实现网络数据报文大小端数据的收发

1.大小端数据简介 大小端&#xff08;Endianness&#xff09;是计算机体系结构的一个术语&#xff0c;它描述了多字节数据在内存中的存储顺序。以下是大小端的定义和它们的特点&#xff1a; 大端&#xff08;Big-Endian&#xff09; 在大端模式中&#xff0c;一个字的最高有效…...

[译]Elasticsearch Sequence ID实现思路及用途

原文地址:https://www.elastic.co/blog/elasticsearch-sequence-ids-6-0 如果 几年前&#xff0c;在Elastic&#xff0c;我们问自己一个"如果"问题&#xff0c;我们知道这将带来有趣的见解&#xff1a; "如果我们在Elasticsearch中对索引操作进行全面排序会怎样…...

Java基于SpringBoot+Vue的藏区特产销售平台

博主介绍&#xff1a;✌程序员徐师兄、7年大厂程序员经历。全网粉丝12w、csdn博客专家、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ &#x1f345;文末获取源码联系&#x1f345; &#x1f447;&#x1f3fb; 精彩专栏推荐订阅&#x1f447;…...

12-表的约束

知识背景 表的约束&#xff0c;就是在表中的数据上加上约束&#xff0c;也被称为数据完整性约束。数据完整性约束的目的是为了不被规定的、不符合规范的数据进入数据库 在录入数据库或数据发生变化时&#xff0c;DBMS(数据库管理系统)会按照一定的约束条件对数据进行监测&…...

【人工智能】深度学习入门:用TensorFlow实现多层感知器(MLP)模型

《Python OpenCV从菜鸟到高手》带你进入图像处理与计算机视觉的大门! 多层感知器(MLP)是一种基础的神经网络结构,广泛应用于分类和回归任务。作为深度学习的重要组成部分,理解并实现MLP是学习更复杂神经网络模型的基础。本文将介绍多层感知器的核心概念、数学原理,并使用…...

【Go】-go中的锁机制

目录 一、锁的基础知识 1. 互斥量/互斥锁 2. CAS&#xff08;compare and swap&#xff09; 3. 自旋锁 4. 读写锁 5. 乐观锁 & 悲观锁 6. 死锁 二、go中锁机制 1. Mutex-互斥锁 2. RWMutex-读写锁 2.1 RWMutex流程概览 2.2 写锁饥饿问题 2.3. golang的读写锁源…...

c ++零基础可视化——vector

c 零基础可视化——vector 初始化 vector<int> v0(5); // 0 0 0 0 0 vector<int> v1(5, 1); // 1 1 1 1 1 vector<int> v2{1, 2, 3} // 1 2 3 vector<int> v3(v1); // 1 1 1 1 1 vector<vector<int>> v4(2, vect…...

Centos 7 安装 Docker 最新版本

文章目录 一、卸载旧版本二、安装最新版本docker三、问题解决3.1 启动docker报错3.2 启动容器报错 一、卸载旧版本 #如果之前安装过旧版本的Docker&#xff0c;可以使用下面命令卸载 yum remove docker \docker-client \docker-client-latest \docker-common \docker-latest …...

构建高效在线教育:SpringBoot课程管理系统

1系统概述 1.1 研究背景 随着计算机技术的发展以及计算机网络的逐渐普及&#xff0c;互联网成为人们查找信息的重要场所&#xff0c;二十一世纪是信息的时代&#xff0c;所以信息的管理显得特别重要。因此&#xff0c;使用计算机来管理在线课程管理系统的相关信息成为必然。开发…...

二进制与网络安全的关系

二进制与网络安全的关系 声明&#xff01; 学习视频来自B站up主 泷羽sec 有兴趣的师傅可以关注一下&#xff0c;如涉及侵权马上删除文章&#xff0c;笔记只是方便各位师傅的学习和探讨&#xff0c;文章所提到的网站以及内容&#xff0c;只做学习交流&#xff0c;其他均与本人以…...

【计算机网络】网段划分

一、为什么有网段划分 IP地址 网络号(目标网络) 主机号(目标主机) 网络号: 保证相互连接的两个网段具有不同的标识 主机号: 同一网段内&#xff0c;主机之间具有相同的网络号&#xff0c;但是必须有不同的主机号 互联网中的每一台主机&#xff0c;都要隶属于某一个子网 -&…...

VB、VBS、VBA的区别及作用

VB、VBS 和 VBA 是三种与微软 Visual Basic 相关的编程语言或环境&#xff0c;它们在功能和用途上有所不同&#xff1a; # Visual Basic (VB) Visual Basic 是一种面向对象的编程语言&#xff0c;最初由微软公司开发。它是一种高级编程语言&#xff0c;旨在简化开发过程&…...

深度学习中的循环神经网络(RNN)与时间序列预测

一、循环神经网络&#xff08;RNN&#xff09;简介 循环神经网络&#xff08;Recurrent Neural Networks&#xff0c;简称RNN&#xff09;是一种专门用于处理序列数据的神经网络架构。与传统神经网络不同&#xff0c;RNN具有内部记忆能力&#xff0c;能够捕捉数据中的时间依赖…...

Unity 设计模式-原型模式(Prototype Pattern)详解

原型模式 (Prototype Pattern) 原型模式 (Prototype Pattern) 是一种创建型设计模式&#xff0c;它允许通过复制现有的对象来创建新对象&#xff0c;而不是通过直接实例化类。这意味着你可以通过克隆原型对象来生成新的实例&#xff0c;而不必依赖类的构造函数。该模式的核心思…...

如何在 RK3568 Android 11 系统上排查以太网问题

1. 硬件连接检查 在进行软件诊断之前,首先确保所有硬件连接正常: 确认网线可靠插入设备的以太网端口。交换机、路由器中与设备连接的端口是否正常工作。若有可能,尝试更换网线或使用其他端口。2. 使用命令行工具进行基本检查 检查网络接口状态 连接设备并使用 ADB 或终端…...

如何在WPF中嵌入其它程序

在WPF中嵌入其它程序&#xff0c;这里提供两种方案 一、使用WindowsFormHost 使用步骤如下 1、添加WindowsFormsIntegration和System.Windows.Forms引用 2、在界面上放置WindowsFormHost和System.Windows.Forms.Panel 1 <Grid> 2 <WindowsFormsHost> 3…...

大模型呼入系统是什么?

大模型呼入系统是什么&#xff1f; 作者&#xff1a;开源呼叫中心系统 FreeIPCC&#xff0c;Github地址&#xff1a;https://github.com/lihaiya/freeipcc 在呼叫中心领域&#xff0c;大模型呼入是指利用大型语言模型&#xff08;如GPT等&#xff09;处理客户呼入的电话请求&a…...

Flutter:SlideTransition位移动画,Interval动画延迟

配置vsync&#xff0c;需要实现一下with SingleTickerProviderStateMixinclass _MyHomePageState extends State<MyHomePage> with SingleTickerProviderStateMixin{// 定义 AnimationControllerlate AnimationController _controller;overridevoid initState() {super.…...

【Elasticsearch入门到落地】2、正向索引和倒排索引

接上篇《1、初识Elasticsearch》 上一篇我们学习了什么是Elasticsearch&#xff0c;以及Elastic stack(ELK)技术栈介绍。本篇我们来什么是正向索引和倒排索引&#xff0c;这是了解Elasticsearch底层架构的核心。 上一篇我们学习到&#xff0c;Elasticsearch的底层是由Lucene实…...

网络安全概论

一、 网络安全是一个综合性的技术。在Internet这样的环境中&#xff0c;其本身的目的就是为了提供一种开放式的交互环境&#xff0c;但是为了保护一些秘密信息&#xff0c;网络安全成为了在开放网络环境中必要的技术之一。网络安全技术是随着网络技术的进步逐步发展的。 网络安…...

后端开发如何高效使用 Apifox?

对于后端开发者来说&#xff0c;日常工作中少不了接口的设计、调试和文档编写。你是否也曾因接口文档更新不及时、测试工具分散而头疼不已&#xff1f;Apifox&#xff0c;这款全能型工具&#xff0c;或许能成为你的效率神器&#xff01; Apifox究竟有哪些功能能帮助后端开发者…...

实现List接口的三类-ArrayList -Vector -LinkedList

一、ArrayList 数据结构与存储原理 ArrayList是基于动态数组实现的。它在内存中是一块连续的存储空间。当创建一个ArrayList时&#xff0c;会初始化一个默认大小&#xff08;通常为10&#xff09;的数组。随着元素的不断添加&#xff0c;如果数组容量不够&#xff0c;会进行扩…...

LeetCode 904.水果成篮

LeetCode 904.水果成篮 思路&#x1f9d0;&#xff1a; 求水果的最大数目&#xff0c;也就是求最大长度&#xff0c;我们是单调的向前求解&#xff0c;则能够想到使用滑动窗口进行解答&#xff0c;可以用hash表统计每个种类的个数&#xff0c;kinds变量统计当前种类&#xff0c…...

GitHub 开源项目 Puter :云端互联操作系统

每天面对着各种云盘和在线应用&#xff0c;我们常常会遇到这样的困扰。 文件分散在不同平台很难统一管理&#xff0c;付费订阅的软件越来越多&#xff0c;更不用说那些烦人的存储空间限制了。 最近在 GitHub 上发现的一个开源项目 Puter 彻底改变了我的在线办公方式。 让人惊…...

美创科技入选2024数字政府解决方案提供商TOP100!

11月19日&#xff0c;国内专业咨询机构DBC德本咨询发布“2024数字政府解决方案提供商TOP100”榜单。美创科技凭借在政府数据安全领域多年的项目经验、技术优势与创新能力&#xff0c;入选收录。 作为专业数据安全产品与服务提供商&#xff0c;美创科技一直致力于为政府、金融、…...

七天掌握SQL--->第五天:数据库安全与权限管理

1.1 用户权限管理 用户权限管理是指控制用户对数据库的访问和操作权限。在MySQL中&#xff0c;可以使用GRANT和REVOKE命令来管理用户权限。 GRANT命令用于授予用户权限。语法如下&#xff1a; GRANT privileges ON database.table TO userhost IDENTIFIED BY password;其中&…...

数学建模学习(138):基于 Python 的 AdaBoost 分类模型

1. AdaBoost算法简介 AdaBoost(Adaptive Boosting)是一种经典的集成学习算法,由Yoav Freund和Robert Schapire提出。它通过迭代训练一系列的弱分类器,并将这些弱分类器组合成一个强分类器。算法的核心思想是:对于被错误分类的样本,在下一轮训练中增加其权重;对于正确分类…...

丹摩|丹摩智算平台深度评测

1. 丹摩智算平台介绍 随着人工智能和大数据技术的快速发展&#xff0c;越来越多的智能计算平台涌现&#xff0c;为科研工作者和开发者提供高性能计算资源。丹摩智算平台作为其中的一员&#xff0c;定位于智能计算服务的提供者&#xff0c;支持从数据处理到模型训练的全流程操作…...

『VUE』34. 异步组件(详细图文注释)

目录 加载速度的优化示例代码总结 欢迎关注 『VUE』 专栏&#xff0c;持续更新中 欢迎关注 『VUE』 专栏&#xff0c;持续更新中 加载速度的优化 实际项目中你可能会有几十个组件,如果一开始就加载了全部组件(哪怕其中有些组件你暂时用不到)这无疑大大增加了响应时间,用户体验…...