express(node ORM) 使用 Winston 记录日志 及数据库保存日志

news2025/2/27 4:42:23

一、安装

npm i winston
npm i winston-mysql

二、 配置 winston

2.1、封装

const config = require(__dirname + ‘/…/config/config.json’)[env];

  • 先判断当前是什么环境，如果.env中没有配置，就是开发环境。
  • 接着去config/config.json中读取对应的配置。
  • 取到值后，填充到options中
const {createLogger, format, transports} = require('winston');
const MySQLTransport = require('winston-mysql');

// 读取 config/config.json 数据库配置文件
// 根据环境变量 NODE_ENV 来选择对应数据库配置
const env = process.env.NODE_ENV || 'development';
const config = require(__dirname + '/../config/config.json')[env];
const options = {
  host: config.host,
  user: config.username,
  password: config.password,
  database: config.database,
  table: 'Logs'
};

const logger = createLogger({
  // 日志级别，只输出 info 及以上级别的日志
  level: 'info',
  // 日志格式为 JSON
  format: format.combine(
    format.errors({stack: true}),    // 添加错误堆栈信息
    format.json()
  ),
  // 添加元数据，这里添加了服务名称
  defaultMeta: {service: 'xw-api'},
  // 日志输出位置
  transports: [
    // 将 error 或更高级别的错误写入 error.log 文件
    new transports.File({filename: 'error.log', level: 'error'}),
    // 将 info 或更高级别的日志写入 combined.log 文件
    new transports.File({filename: 'combined.log'}),
    // 添加 MySQL 传输，将日志存储到数据库
    new MySQLTransport(options)
  ]
});

// 在非生产环境下，将日志输出到控制台
if (process.env.NODE_ENV !== 'production') {
  logger.add(new transports.Console({
    format: format.combine(
      format.colorize(), // 终端中输出彩色的日志信息
      format.simple()
    )
  }));
}

module.exports = logger;

config文件

在这里插入图片描述

2.2、测试
const logger = require('../utils/logger');

/**
 * 查询首页数据
 * GET /
 */
router.get('/', async function (req, res, next) {
  try {
    logger.info('这是一个 info 信息');
    logger.warn('这是一个 warn 信息');
    logger.error('这是一个 error 信息');

    // ...

  } catch (error) {
    failure(res, error);
  }
});

在这里插入图片描述

三、修改封装的responses.js

const createError = require('http-errors');
const multer = require('multer');
const logger = require("./logger");


/**
 * 请求成功
 * @param res
 * @param message
 * @param data
 * @param code
 */
function success(res, message, data = {}, code = 200) {
  res.status(code).json({
    status: true,
    message,
    data,
    code
  });
}


/**
 * 请求失败
 * @param res
 * @param error
 */
function failure(res, error) {
  // 初始化状态码和错误信息
  let statusCode;
  let errors;

  if (error.name === 'SequelizeValidationError') {      // Sequelize 验证错误
    statusCode = 400;
    errors = error.errors.map(e => e.message);
  } else if (error.name === 'JsonWebTokenError' || error.name === 'TokenExpiredError') {  // Token 验证错误
    statusCode = 401;
    errors = '您提交的 token 错误或已过期。';
  } else if (error instanceof createError.HttpError) {  // http-errors 库创建的错误
    statusCode = error.status;
    errors = error.message;
  } else if (error instanceof multer.MulterError) {     // multer 上传错误
    if (error.code === 'LIMIT_FILE_SIZE') {
      statusCode = 413;
      errors = '文件大小超出限制。';
    } else {
      statusCode = 400;
      errors = error.message;
    }
  } else {                                              // 其他未知错误
    statusCode = 500;
    errors = '服务器错误。';
    logger.error('服务器错误：', error);
  }

  res.status(statusCode).json({
    status: false,
    message: `请求失败: ${error.name}`,
    errors: Array.isArray(errors) ? errors : [errors]
  });
}

module.exports = {
  success,
  failure
}

四、封装日志接口

4.1、创建Log表
sequelize model:generate --name Log --attributes level:string,message:string,meta:string,timestamp:date
4.2、修改迁移
'use strict';
/** @type {import('sequelize-cli').Migration} */
module.exports = {
  async up(queryInterface, Sequelize) {
    await queryInterface.createTable('Logs', {
      id: {
        allowNull: false,
        autoIncrement: true,
        primaryKey: true,
        type: Sequelize.INTEGER.UNSIGNED
      },
      level: {
        allowNull: false,
        type: Sequelize.STRING(16)
      },
      message: {
        allowNull: false,
        type: Sequelize.STRING(2048)
      },
      meta: {
        allowNull: false,
        type: Sequelize.STRING(2048)
      },
      timestamp: {
        allowNull: false,
        type: Sequelize.DATE
      }
    });
  },
  async down(queryInterface, Sequelize) {
    await queryInterface.dropTable('Logs');
  }
};
4.3、运行迁移
sequelize db:migrate
4.4、修改模型
'use strict';
const {
  Model
} = require('sequelize');
module.exports = (sequelize, DataTypes) => {
  class Log extends Model {
    /**
     * Helper method for defining associations.
     * This method is not a part of Sequelize lifecycle.
     * The `models/index` file will call this method automatically.
     */
    static associate(models) {
      // define association here
    }
  }
  Log.init({
    level: DataTypes.STRING,
    message: DataTypes.STRING,
    meta: {
      type: DataTypes.STRING,
      get() {
        return JSON.parse(this.getDataValue("meta"));
      }
    },
    timestamp: DataTypes.DATE,
  }, {
    sequelize,
    modelName: 'Log',
    timestamps: false, // 没有 createdAt 与 updatedAt
  });
  return Log;
};
  • meta里存储的是详细的错误信息。在读取的时候，需要使用JSON.parse转回json格式。
  • 加上了timestamps: false。因为已经有专门的timestamp字段记录时间了，所以并不需要createdAt和updatedAt。
4.5、 接口封装
const express = require('express');
const router = express.Router();
const { Log } = require('../../models');
const { NotFound } = require('http-errors');
const { success, failure } = require('../../utils/responses');

/**
 * 查询日志列表
 * GET /admin/logs
 */
router.get('/', async function (req, res) {
  try {
    const logs = await Log.findAll({
      order: [['id', 'DESC']],
    });

    success(res, '查询日志列表成功。', { logs: logs });
  } catch (error) {
    failure(res, error);
  }
});

/**
 * 查询日志详情
 * GET /admin/logs/:id
 */
router.get('/:id', async function (req, res) {
  try {
    const log = await getLog(req);

    success(res, '查询日志成功。', { log });
  } catch (error) {
    failure(res, error);
  }
});

/**
 * 清空全部日志
 * DELETE /admin/logs/clear
 */
router.delete('/clear', async function (req, res) {
  try {
    await Log.destroy({ truncate: true });

    success(res, '清空日志成功。');
  } catch (error) {
    failure(res, error);
  }
});

/**
 * 删除日志
 * DELETE /admin/logs/:id
 */
router.delete('/:id', async function (req, res) {
  try {
    const log = await getLog(req);
    await log.destroy();

    success(res, '删除日志成功。');
  } catch (error) {
    failure(res, error);
  }
});

/**
 * 公共方法：查询当前日志
 */
async function getLog(req) {
  const { id } = req.params;

  const log = await Log.findByPk(id);
  if (!log) {
    throw new NotFound(`ID: ${id}的日志未找到。`)
  }

  return log;
}

module.exports = router;
  • 在清空日志里，我用了truncate: true，它的意思是截断表。作用是将表中的数据清空后，自增的id恢复从1开始。
  • 还有要注意，清空全部日志路由，必须在删除日志路由的上面。不然就会先匹配到/:id，导致无法匹配到/clear的
4.6、app.js引入 参考自己的项目
const adminLogsRouter = require('./routes/admin/logs');

app.use('/admin/logs', adminAuth, adminLogsRouter);

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

是德科技keysight N5173B信号发生器，是一款经济高效的仪器

是德科技keysight N5173B信号发生器，是一款经济高效的仪器

是德科技keysight N5173B信号发生器安捷伦N5173B信号源 是德N5173B微波模拟信号发生器，拥有 9 kHz 至 40 GHz 的频率覆盖范围，N5173B为宽带滤波器、放大器、接收机等器件的参数测试提供了必要的信号，是一款经济高效的仪器。 N5173B特点&…
阅读更多...
从零到一：如何用阿里云百炼和火山引擎搭建专属 AI 助手（DeepSeek）？

从零到一：如何用阿里云百炼和火山引擎搭建专属 AI 助手（DeepSeek）？

本文首发：从零到一：如何用阿里云百炼和火山引擎搭建专属 AI 助手（DeepSeek）？ 阿里云百炼和火山引擎都推出了免费的 DeepSeek 模型体验额度，今天我和大家一起搭建一个本地的专属 AI 助手。　 阿里云百炼为 …
阅读更多...
FFmpeg视频处理入门级教程

FFmpeg视频处理入门级教程

一、FFmpeg常规处理流程 #mermaid-svg-W8X1llNEyuYptV3I {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-W8X1llNEyuYptV3I .error-icon{fill:#552222;}#mermaid-svg-W8X1llNEyuYptV3I .error-text{fill:#552222;str…
阅读更多...
C/C++ | 每日一练 (4)

C/C++ | 每日一练 (4)

💢欢迎来到张胤尘的技术站 💥技术如江河，汇聚众志成。代码似星辰，照亮行征程。开源精神长，传承永不忘。携手共前行，未来更辉煌💥 文章目录 C/C | 每日一练 (4)题目参考答案基础容器序列容器std:…
阅读更多...
蓝桥杯备考：贪心算法之矩阵消除游戏

蓝桥杯备考：贪心算法之矩阵消除游戏

这道题是牛客上的一道题，它呢和我们之前的排座位游戏非常之相似，但是，排座位问题选择行和列是不会改变元素的值的，这道题呢每每选一行都会把这行或者这列清零，所以我们的策略就是先用二进制把选择所有行的情况全部枚举…
阅读更多...
基于 CFD 预测的机器学习第 2 部分：在 Benchmark 应用程序上使用 Stochos 预测流场

基于 CFD 预测的机器学习第 2 部分：在 Benchmark 应用程序上使用 Stochos 预测流场

了解机器学习和 Stochos 如何彻底改变制造业的 CFD 预测。 挑战 预测复杂流体动力学场景中的流场一直是工程师和科学家面临的重大挑战。传统的计算流体动力学 （CFD） 方法需要大量的计算资源和时间，因此难以处理实时预测和大规模模拟。 此外…
阅读更多...
批量导出数据库表到Excel

批量导出数据库表到Excel

这篇文章将介绍如何批量的将多个甚至成千上万的数据库表导出为Excel文件。 准备数据 如下图是数据库里的表，我们需要将它们全部导出为excel文件，这里以SQL Server数据库为例 新增导出 打开的卢导表工具，新建数据库连接，这里以S…
阅读更多...
力扣提升第一天

力扣提升第一天

力扣提升第一天 题目链接：https://leetcode.cn/problems/design-memory-allocator/?envTypedaily-question&envId2025-02-25 一开始解题思路 暴力解决法 我奔着先从简单的写法做起，之后再想办法进行改进，心里已经预料到会出现超出时间…
阅读更多...
uni-app 开发 App 、 H5 横屏签名（基于lime-signature）

uni-app 开发 App 、 H5 横屏签名（基于lime-signature）

所用插件&#xff1a;lime-signature 使用到 CSS 特性 绝对定位transform 旋转transform-origin transform 原点 复习一下定位元素&#xff08;相对定位、绝对定位、粘性定位&#xff09; 代码# <template><view class"signature-page"><view clas…
阅读更多...
【Python】Python顺序语句经典题（四）

【Python】Python顺序语句经典题（四）

Python顺序语句经典练习题例题&#xff08;四&#xff09;。题目来源&#xff1a;Acwing 前三期合集&#xff1a;【Python】Python顺序语句经典题合集-CSDN博客 目录 1.最大值 题目描述 解题思路 AC代码 2.距离 题目描述 AC代码 3.燃料消耗 题目描述 AC代码 4.钞票…
阅读更多...
03_pyqt5 + vlc 实现视频播放器

03_pyqt5 + vlc 实现视频播放器

1.功能需求如图 按钮: 播放/暂停, 前进/后退, 视频上一个/下一个, 打开视频进度条: 视频进度条显示, 进度条拖拽, 音量控制按键控制: 1,2,3,4缩放画面大小, 2.方案选择 开发语言: python UI界面: pyqt5 qt_designed 设计ui布局 视频编码: python-vlc 方案说明: 视频解码可…
阅读更多...
prometheus+node_exporter+grafana监控K8S信息

prometheus+node_exporter+grafana监控K8S信息

prometheusnode_exportergrafana监控K8S 1.prometheus部署2.node_exporter部署3.修改prometheus配置文件4.grafana部署 1.prometheus部署 包下载地址&#xff1a;https://prometheus.io/download/ 将包传至/opt 解压 tar xf prometheus-2.53.3.linux-amd64.tar.gz 移动到…
阅读更多...
IDEA关闭SpringBoot程序后仍然占用端口的排查与解决

IDEA关闭SpringBoot程序后仍然占用端口的排查与解决

IDEA关闭SpringBoot程序后仍然占用端口的排查与解决 问题描述 在使用 IntelliJ IDEA 开发 Spring Boot 应用时&#xff0c;有时即使关闭了应用&#xff0c;程序仍然占用端口&#xff08;例如&#xff1a;4001 端口&#xff09;。这会导致重新启动应用时出现端口被占用的错误&a…
阅读更多...
山东大学软件学院nosql实验三

山东大学软件学院nosql实验三

实验题目&#xff1a; 用Java做简单查询(2学时) 实验内容 用API方式&#xff0c;做简单查询。 实验要求 在以下要求中选择至少2个&#xff0c;使用Java语言实现数据查询&#xff0c;最终把数据输出到前端界面。 &#xff08;1&#xff09;找出年龄小于20岁的所有学生 &…
阅读更多...
零样本学习 zero-shot

零样本学习 zero-shot

1 是什么 2 如何利用零样本学习进行跨模态迁移&#xff1f; demo代码 安装clip pip install ftfy regex tqdm pip install githttps://github.com/openai/CLIP.git import torch import clip from PIL import Image# 加载 CLIP 模型 device "cuda" if torch.cuda.i…
阅读更多...
《深度学习实战》第3集：循环神经网络（RNN）与序列建模

《深度学习实战》第3集：循环神经网络（RNN）与序列建模

第3集&#xff1a;循环神经网络&#xff08;RNN&#xff09;与序列建模 引言 在深度学习领域&#xff0c;处理序列数据&#xff08;如文本、语音、时间序列等&#xff09;是一个重要的研究方向。传统的全连接网络和卷积神经网络&#xff08;CNN&#xff09;难以直接捕捉序列中…
阅读更多...
mac下载MAMP6.8.1

mac下载MAMP6.8.1

因为mac的小皮面板没有php7.4了 链接&#xff1a;c9cc270e6961c17c.dmg官方版下载丨最新版下载丨绿色版下载丨APP下载-123云盘 鹅选一 附上大佬写的教程&#xff1a;MAMP PRO教程 - 牛奔 - 博客园
阅读更多...
BUU41 [GYCTF2020]FlaskApp1【SSTI】

BUU41 [GYCTF2020]FlaskApp1【SSTI】

题目&#xff1a; 加密处没啥事&#xff0c;但是解密的地方提交{{7*7}}就会返回报错界面&#xff0c;顺便把代码也爆出来了 text_decode base64.b64decode(text.encode()) 先将字符串 text编码为字节对象&#xff0c;然后使用 base64.b64decode 函数对这个字节对象进行 Base…
阅读更多...
今日运维之-Mac笔记本python环境问题

今日运维之-Mac笔记本python环境问题

1. 问题&#xff1a;MAC升级系统后git报错&#xff1f; Error: Cant create update lock in /usr/local/var/homebrew/locks! Fix permissions by running:sudo chown -R $(whoami) /usr/local/var/homebrew Traceback (most recent call last):11: from /usr/local/Homebrew/…
阅读更多...
易基因：RNA甲基化修饰和R-loop的交叉调控：从分子机制到临床意义｜深度综述

易基因：RNA甲基化修饰和R-loop的交叉调控：从分子机制到临床意义｜深度综述

大家好&#xff0c;这里是专注表观组学十余年&#xff0c;领跑多组学科研服务的易基因。 R-loop&#xff08;RNA-DNA杂合结构&#xff09;是转录调控、DNA复制和修复等关键细胞过程的重要组成部分。但R-loop异常积累可能会破坏基因组完整性&#xff0c;从而导致多种疾病的发生…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023