Logstash 内部如何处理消息/事件?

Logstash 内部如何处理消息/事件?

我是 Logstash 新手,我正在尝试了解输入、过滤器和输出如何协同工作。我知道有各种各样的输入、过滤器和输出,但我不明白 Logstash 内部如何处理消息。

假设我配置了一个 syslog 输入,并且我希望将 syslog 事件作为 GELF 发送到日志索引。我可以使用 syslog 输入,也可以使用 GELF 输出。但是,我是否有责任(使用过滤器)根据 syslog 事件的值填充正确的 GELF 字段?

我是否应该将事件(来自输入过滤器)视为具有命名字段(类似于键:值数组)的实体,然后使用过滤器来确保输出可以获得正确的数据?

答案1

正如 Jordan Sissel 所说,把它想象成一个强化版的管道,在输入和输出之间,你可以用事件做你想做的事情,你可以使用以下方法将消息的各个部分与字段名称进行匹配格罗克或者你可以使用变异删除字段正则表达式样式的文本替换添加或者消除标签。一旦您将数据格式化为您想要的格式,您就可以将其发送到输出。

相关内容