当前位置：首页 > 文章列表 > Golang > Go教程 > DebianNode.js日志慢查询查找技巧

DebianNode.js日志慢查询查找技巧

2025-04-13 19:33:38 0浏览收藏

本文介绍在Debian系统下利用Node.js高效查找日志中慢查询的方法。通过Node.js的`fs`模块逐行读取日志文件，并根据指定时间范围和日志类型（例如：错误、警告）进行过滤和统计，最终定位性能瓶颈。文章提供改进后的Node.js代码示例，包含异步操作、错误处理及精确的日志匹配逻辑，有效提升代码可读性和处理大型日志文件的效率，帮助开发者快速查找并解决慢查询问题。关键词：Debian, Node.js, 日志查找, 慢查询, 性能优化

Debian Node.js 日志中如何查找慢查询

本文介绍如何在 Debian 系统中使用 Node.js 查找日志中的慢查询。我们将逐步讲解如何高效地读取、过滤和统计日志信息，最终定位性能瓶颈。

方法步骤：

日志读取: 利用 Node.js 的 fs 模块逐行读取日志文件。前端可以选择日志查找的时间范围和精度，实现精准定位。
日志过滤: 根据指定的时间范围和日志类型（例如：错误、警告等）筛选日志。例如，您可以设置只查找过去一小时内的错误日志。
日志统计: 统计符合条件的日志数量，并以结构化的方式输出结果，例如：显示找到的日志数量及具体内容。

Node.js 代码示例 (改进版):

以下代码示例演示了如何读取和过滤日志文件，并对代码进行了优化和改进，使其更易于理解和维护：

const fs = require('fs');
const readline = require('readline');

async function findSlowQueries(date, type, precision) {
  const logPath = `appDirName/log/ivsvr_${date}.log`;
  let slowQueries = [];

  try {
    const fileStats = await fs.promises.stat(logPath);
    if (!fileStats.isFile()) {
      console.log('日志文件不存在或不是文件。');
      return slowQueries;
    }

    const fileStream = fs.createReadStream(logPath);
    const rl = readline.createInterface({ input: fileStream });

    rl.on('line', (line) => {
      const parts = line.trim().split(' ');
      if (parts.length < 2) return; //忽略无效行

      const timestamp = parts[0];
      const message = parts.slice(1).join(' ');

      // 时间精度检查
      const timeRegex = /(\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2})/;
      const match = timestamp.match(timeRegex);
      if (!match) return; //忽略时间格式错误的行

      const logTime = match[1];
      let matched = true;

      switch (type) {
        case '0': // 所有日志
          break;
        case '1': // 按小时
          if (logTime.slice(0, 13) !== precision) matched = false;
          break;
        case '2': // 按分钟
          if (logTime.slice(0, 16) !== precision) matched = false;
          break;
        case '3': // 按秒
          if (logTime.slice(0, 19) !== precision) matched = false;
          break;
        default:
          console.error('未知日志类型。');
          matched = false;
      }

      if (matched && message.toLowerCase().includes('slow query')) {
        slowQueries.push({ timestamp: logTime, message });
      }
    });

    await new Promise((resolve) => rl.on('close', resolve)); // 等待读取完成

  } catch (error) {
    console.error('读取日志文件出错:', error);
  }

  return slowQueries;
}


// 示例用法: 查找2024-04-07当天所有包含 "slow query" 的日志
findSlowQueries('2024-04-07', '0', '').then(queries => {
  console.log(`找到 ${queries.length} 条慢查询日志:`);
  queries.forEach(query => console.log(query));
});

改进说明: