›

创建 Logstash Pipeline

您可以通过将插件串联起来创建 Pipeline——输入、输出、过滤器，有时还有编解码器——以便处理数据。要构建 Logstash Pipeline，请创建一个配置文件以指定要使用的插件以及每个插件的设置。

一个非常基本的 Pipeline 可能只包含输入和输出。大多数 Pipeline 至少包含一个过滤器插件，因为这是 ETL（提取、转换、加载）魔力中“转换”部分发生的地方。您可以在 Pipeline 中引用事件字段，并使用条件语句在事件满足特定条件时处理事件。

让我们逐步了解如何在本地机器上创建一个简单的 Pipeline 配置文件，然后使用它来运行 Logstash。创建一个名为“logstash-simple.conf”的文件，并将其保存在与 Logstash 相同的目录中。

input { stdin { } }
output {
  elasticsearch { cloud_id => "<cloud id>" api_key => "<api key>" }
  stdout { codec => rubydebug }
}

然后，运行 Logstash 并使用 -f 标志指定配置文件。

bin/logstash -f logstash-simple.conf

瞧！Logstash 读取指定的配置文件并输出到 Elasticsearch 和标准输出。在我们继续学习更复杂的示例之前，让我们看一下 Pipeline 配置文件的内容。