如何在节点js中同步读取文本文件并将行组合在一起

Question

我需要同步读取node js中的snort日志文件，并将它们解析成JSON数据，以便我可以将它们存储在数据库中。问题是，snort 日志文件不仅仅是一行。 snort 中的一个警报由 5 行组成，我希望能够将这 5 行作为一个警报存储在数据库中。

我试过使用

     const rl = readline.createInterface({
            input: fs.createReadStream(LOG_FILE),
         });

         rl.on('line', (line) => {
         console.log(`Line from file: ${line}`);
         });

逐行读取文件并打印出来，但它只是逐行打印出来，我不知道如何将它们组合在一起。

这是一个 snort 日志文件的示例：

[**] [1:1000001:1] ICMP test [**]
[Classification: Generic ICMP event] [Priority: 3] 
06/09-14:18:58.102020 192.168.137.91 -> 192.168.137.89
ICMP TTL:64 TOS:0x0 ID:20610 IpLen:20 DgmLen:84 DF
Type:8  Code:0  ID:1664   Seq:5  ECHO

所以在我的数据库中，我会有一个叫做 alert 的东西，这 5 行将用 id: 1 等来提醒。任何帮助将不胜感激。

Answer 1

将行收集在一个变量中，然后在获得完整条目后做一些事情。像这样：

let lines = [];
rl.on('line', (line) => {
  lines.push(line);
  if (lines.length>=5) {
    let log = lines.splice(0,5).join('\n');
    console.log(log);
  }
});

这是以 5 行为一组进行计数。如果需要，您还可以使用其他条件，例如模式匹配或其他条件。

注意： 如果您在条目的第一行使用模式匹配，您将必须做一些事情来检查文件中的最后一个（不会有另一个跟随它），比如监听流的 end 事件，并从那里写下最后一个 logPart 。（但是因为这个例子只是等待第 5 行，所以我们不需要做任何特殊的事情来处理最后一组。）

如何在节点js中同步读取文本文件并将行组合在一起

How to read a text file and group lines together in node js synchronously

javascript

node.js

file-io

synchronous