管理多行事件编辑

许多用例会生成跨越多行文本的事件。为了正确处理这些多行事件,Logstash 需要知道如何判断哪些行属于单个事件。

多行事件处理很复杂,依赖于正确的事件排序。保证有序日志处理的最佳方法是在管道中尽早实现处理。

multiline 编解码器是 Logstash 管道中处理多行事件的首选工具。multiline 编解码器使用一组简单的规则将来自单个输入的各行合并。

如果您使用的是支持多个主机的 Logstash 输入插件,例如 beats 输入插件,则不应使用 multiline 编解码器来处理多行事件。这样做可能会导致流混合和事件数据损坏。在这种情况下,您需要在将事件数据发送到 Logstash 之前处理多行事件。

配置 multiline 编解码器最重要的方面如下

  • pattern 选项指定一个正则表达式。匹配指定正则表达式的行被视为前一行的延续或新的多行事件的开始。您可以使用 grok 正则表达式模板来配置此选项。
  • what 选项接受两个值:previousnextprevious 值指定匹配 pattern 选项中值的行属于前一行。 next 值指定匹配 pattern 选项中值的行属于下一行。* negate 选项将 multiline 编解码器应用于 *不* 匹配 pattern 选项中指定的正则表达式的行。

有关配置选项的更多信息,请参阅 multiline 编解码器插件的完整文档。

Multiline 编解码器配置示例编辑

本节中的示例涵盖以下用例

  • 将 Java 堆栈跟踪合并到单个事件中
  • 将 C 样式的行延续合并到单个事件中
  • 将来自带时间戳事件的多行合并

Java 堆栈跟踪编辑

Java 堆栈跟踪由多行组成,初始行之后的每行都以空格开头,例如

Exception in thread "main" java.lang.NullPointerException
        at com.example.myproject.Book.getTitle(Book.java:16)
        at com.example.myproject.Author.getBookTitles(Author.java:25)
        at com.example.myproject.Bootstrap.main(Bootstrap.java:14)

要在 Logstash 中将这些行合并到单个事件中,请使用以下 multiline 编解码器配置

input {
  stdin {
    codec => multiline {
      pattern => "^\s"
      what => "previous"
    }
  }
}

此配置将任何以空格开头的行合并到前一行。

行延续编辑

许多编程语言在行尾使用 \ 字符来表示行延续,例如

printf ("%10.10ld  \t %10.10ld \t %s\
  %f", w, x, y, z );

要在 Logstash 中将这些行合并到单个事件中,请使用以下 multiline 编解码器配置

input {
  stdin {
    codec => multiline {
      pattern => "\\$"
      what => "next"
    }
  }
}

此配置将任何以 \ 字符结尾的行与下一行合并。

时间戳编辑

来自 Elasticsearch 等服务的活动日志通常以时间戳开头,后跟有关特定活动的的信息,例如

[2015-08-24 11:49:14,389][INFO ][env                      ] [Letha] using [1] data paths, mounts [[/
(/dev/disk1)]], net usable_space [34.5gb], net total_space [118.9gb], types [hfs]

要在 Logstash 中将这些行合并到单个事件中,请使用以下 multiline 编解码器配置

input {
  file {
    path => "/var/log/someapp.log"
    codec => multiline {
      pattern => "^%{TIMESTAMP_ISO8601} "
      negate => true
      what => previous
    }
  }
}

此配置使用 negate 选项指定任何不以时间戳开头的行都属于前一行。