配置 Logstash 输出编辑

Logstash 输出使用 lumberjack 协议(通过 TCP 运行)将事件直接发送到 Logstash。Logstash 允许对生成的事件进行额外的处理和路由。

先决条件

要将事件发送到 Logstash,您还需要创建一个 Logstash 配置管道,该管道侦听传入的 Beats 连接并将接收到的事件索引到 Elasticsearch 中。有关更多信息,请参阅Logstash 入门。另请参阅 Beats 输入Elasticsearch 输出 插件的文档。

如果要使用 Logstash 对 Winlogbeat 收集的数据执行其他处理,则需要配置 Winlogbeat 以使用 Logstash。

为此,请编辑 Winlogbeat 配置文件以通过注释禁用 Elasticsearch 输出,并通过取消注释 Logstash 部分来启用 Logstash 输出。

output.logstash:
  hosts: ["127.0.0.1:5044"]

hosts 选项指定 Logstash 服务器和端口 (5044),Logstash 在该端口配置为侦听传入的 Beats 连接。

对于此配置,您必须手动将索引模板加载到 Elasticsearch 中,因为自动加载模板的选项仅适用于 Elasticsearch 输出。

访问元数据字段编辑

发送到 Logstash 的每个事件都包含以下元数据字段,您可以在 Logstash 中使用这些字段进行索引和过滤。

{
    ...
    "@metadata": { 
      "beat": "winlogbeat", 
      "version": "8.14.3" 
    }
}

Winlogbeat 使用 @metadata 字段将元数据发送到 Logstash。有关 @metadata 字段的更多信息,请参阅Logstash 文档

默认值为 winlogbeat。要更改此值,请在 Winlogbeat 配置文件中设置 index 选项。

Winlogbeat 的当前版本。

您可以从 Logstash 配置文件内部访问此元数据,以根据元数据的内容动态设置值。

例如,以下 Logstash 配置文件告诉 Logstash 使用 Winlogbeat 报告的索引将事件索引到 Elasticsearch 中

input {
  beats {
    port => 5044
  }
}

output {
  elasticsearch {
    hosts => ["https://127.0.0.1:9200"]
    index => "%{[@metadata][beat]}-%{[@metadata][version]}" 
    action => "create"
  }
}

%{[@metadata][beat]} 将索引名称的第一部分设置为 beat 元数据字段的值,%{[@metadata][version]} 将第二部分设置为 Beat 的版本。例如:winlogbeat-8.14.3

使用此处显示的 Logstash 配置索引到 Elasticsearch 的事件将类似于 Winlogbeat 直接索引到 Elasticsearch 的事件。

如果未使用 ILM,请将 index 设置为 %{[@metadata][beat]}-%{[@metadata][version]}-%{+YYYY.MM.dd},以便 Logstash 根据来自 Beats 的事件的 @timestamp 值每天创建一个索引。

兼容性编辑

此输出适用于所有兼容版本的 Logstash。请参阅Elastic 支持矩阵

配置选项编辑

您可以在 winlogbeat.yml 配置文件的 logstash 部分中指定以下选项

enabled编辑

enabled 配置是一个布尔设置,用于启用或禁用输出。如果设置为 false,则输出被禁用。

默认值为 true

hosts编辑

要连接到的已知 Logstash 服务器列表。如果负载平衡被禁用,但配置了多个主机,则会随机选择一个主机(没有优先级)。如果一个主机变得不可访问,则会随机选择另一个主机。

此列表中的所有条目都可以包含端口号。如果没有给出数字,则将使用默认端口号 5044。

compression_level编辑

gzip 压缩级别。将此值设置为 0 将禁用压缩。压缩级别必须在 1(最佳速度)到 9(最佳压缩)之间。

提高压缩级别将减少网络使用量,但会增加 CPU 使用量。

默认值为 3。

escape_html编辑

配置对字符串中 HTML 的转义。设置为 true 以启用转义。

默认值为 false

workerworkers编辑

每个配置的主机发布事件到 Logstash 的工作进程数量。这最适合在启用负载平衡模式的情况下使用。例如:如果您有 2 个主机和 3 个工作进程,那么总共会启动 6 个工作进程(每个主机 3 个)。

loadbalance编辑

当设置了 loadbalance: true 时,Winlogbeat 会连接到所有配置的主机并通过所有连接并行发送数据。如果连接失败,数据将发送到剩余的主机,直到可以重新建立连接为止。只要 Winlogbeat 可以连接到至少一个配置的主机,数据就会继续发送。

当设置了 loadbalance: false 时,Winlogbeat 会一次发送数据到单个主机。目标主机是随机从配置的主机列表中选择的,所有数据都发送到该目标,直到连接失败,才会选择新的目标。只要 Winlogbeat 可以连接到至少一个配置的主机,数据就会继续发送。要随着时间的推移轮换配置的主机列表,请将此选项与 ttl 设置一起使用,以在配置的间隔时间内关闭连接并选择新的目标主机。

默认值为 false

output.logstash:
  hosts: ["localhost:5044", "localhost:5045"]
  loadbalance: true
  index: winlogbeat

ttl编辑

与 Logstash 的连接的生存时间,在此之后将重新建立连接。在 Logstash 主机代表负载均衡器时很有用。由于与 Logstash 主机的连接是粘性的,因此在负载均衡器后面操作会导致实例之间负载分布不均。在连接上指定 TTL 允许在实例之间实现均匀的连接分布。指定 TTL 为 0 将禁用此功能。

默认值为 0。此设置接受持续时间 数据类型值。

"ttl" 选项在异步 Logstash 客户端(使用 "pipelining" 选项设置的客户端)上尚不支持。

pipelining编辑

配置异步发送到 Logstash 的批次数量,同时等待来自 Logstash 的 ACK。一旦已写入 pipelining 批次数量,输出才会变为阻塞。如果配置的值为 0,则禁用管道。默认值为 2。

proxy_url编辑

连接到 Logstash 服务器时使用的 SOCKS5 代理的 URL。该值必须是方案为 socks5:// 的 URL。与 Logstash 通信的协议不是基于 HTTP 的,因此无法使用 Web 代理。

如果 SOCKS5 代理服务器需要客户端身份验证,则可以在 URL 中嵌入用户名和密码,如示例所示。

使用代理时,主机名将在代理服务器上解析,而不是在客户端上解析。您可以通过设置 proxy_use_local_resolver 选项更改此行为。

output.logstash:
  hosts: ["remote-host:5044"]
  proxy_url: socks5://user:password@socks5-proxy:2233

proxy_use_local_resolver编辑

proxy_use_local_resolver 选项决定在使用代理时是否在本地解析 Logstash 主机名。默认值为 false,这意味着使用代理时名称解析在代理服务器上发生。

index编辑

要写入事件的索引根名称。默认值为 Beat 名称。例如,"winlogbeat" 生成 "[winlogbeat-]8.14.3-YYYY.MM.DD" 索引(例如,"winlogbeat-8.14.3-2017.04.26")。

此参数的值将分配给 metadata.beat 字段。然后可以在 Logstash 的输出部分中将其访问为 %{[@metadata][beat]}

ssl编辑

SSL 参数的配置选项,例如 Logstash 连接的根 CA。有关更多信息,请参阅SSL。要使用 SSL,您还必须配置Logstash 的 Beats 输入插件 以使用 SSL/TLS。

timeout编辑

在超时之前等待来自 Logstash 服务器的响应的秒数。默认值为 30(秒)。

max_retries编辑

Winlogbeat 忽略 max_retries 设置并无限期重试。

bulk_max_size编辑

在一个 Logstash 请求中批量发送的事件的最大数量。默认值为 2048。

事件可以收集到批次中。Winlogbeat 会将从队列读取的比 bulk_max_size 大的批次拆分成多个批次。

指定更大的批次大小可以通过降低发送事件的开销来提高性能。但是,大型批次大小也会增加处理时间,这可能会导致 API 错误、连接终止、发布请求超时,并最终导致吞吐量降低。

bulk_max_size 设置为小于或等于 0 的值将禁用批次的拆分。当禁用拆分时,队列决定批次中包含的事件数量。

slow_startedit

如果启用,每次事务仅传输一批事件中的部分事件。如果未遇到错误,将发送的事件数会增加到 bulk_max_size。如果遇到错误,每次事务的事件数将再次减少。

默认值为 false

backoff.initedit

在网络错误后尝试重新连接到 Logstash 之前等待的秒数。等待 backoff.init 秒后,Winlogbeat 会尝试重新连接。如果尝试失败,则回退计时器将指数增加到 backoff.max。连接成功后,回退计时器将重置。默认值为 1 秒。

backoff.maxedit

在网络错误后尝试连接到 Logstash 之前等待的最大秒数。默认值为 60 秒。