配置 Logstash 输出
编辑配置 Logstash 输出编辑
Logstash 输出使用 lumberjack 协议(通过 TCP 运行)将事件直接发送到 Logstash。Logstash 允许对生成的事件进行额外的处理和路由。
先决条件
要将事件发送到 Logstash,您还需要创建一个 Logstash 配置管道,该管道侦听传入的 Beats 连接并将接收到的事件索引到 Elasticsearch 中。有关更多信息,请参阅 Logstash 入门。另请参阅 Beats 输入 和 Elasticsearch 输出 插件的文档。
如果要使用 Logstash 对 Auditbeat 收集的数据执行其他处理,则需要将 Auditbeat 配置为使用 Logstash。
为此,请编辑 Auditbeat 配置文件,通过注释掉 Elasticsearch 输出将其禁用,并通过取消注释 Logstash 部分来启用 Logstash 输出
output.logstash: hosts: ["127.0.0.1:5044"]
hosts
选项指定 Logstash 服务器和端口 (5044
),Logstash 在该端口上配置为侦听传入的 Beats 连接。
对于此配置,您必须 将索引模板手动加载到 Elasticsearch 中,因为自动加载模板的选项仅适用于 Elasticsearch 输出。
访问元数据字段编辑
发送到 Logstash 的每个事件都包含以下元数据字段,您可以在 Logstash 中使用这些字段进行索引和过滤
Auditbeat 使用 |
|
默认值为 auditbeat。要更改此值,请在 Auditbeat 配置文件中设置 |
|
Auditbeat 的当前版本。 |
您可以从 Logstash 配置文件中访问此元数据,以根据元数据的内容动态设置值。
例如,以下 Logstash 配置文件告诉 Logstash 使用 Auditbeat 报告的索引将事件索引到 Elasticsearch 中
input { beats { port => 5044 } } output { elasticsearch { hosts => ["https://127.0.0.1:9200"] index => "%{[@metadata][beat]}-%{[@metadata][version]}" action => "create" } }
|
使用此处显示的 Logstash 配置索引到 Elasticsearch 中的事件将类似于 Auditbeat 直接索引到 Elasticsearch 中的事件。
如果未使用 ILM,请将 index
设置为 %{[@metadata][beat]}-%{[@metadata][version]}-%{+YYYY.MM.dd}
,以便 Logstash 根据来自 Beats 的事件的 @timestamp
值每天创建一个索引。
兼容性编辑
此输出适用于所有兼容版本的 Logstash。请参阅 Elastic 支持矩阵。
配置选项编辑
您可以在 auditbeat.yml
配置文件的 logstash
部分中指定以下选项
hosts
编辑
要连接到的已知 Logstash 服务器列表。如果禁用负载均衡,但配置了多个主机,则会随机选择一个主机(没有优先级)。如果一个主机变得不可达,则会随机选择另一个主机。
此列表中的所有条目都可以包含端口号。如果没有给出数字,则将使用默认端口号 5044。
compression_level
编辑
gzip 压缩级别。将此值设置为 0 将禁用压缩。压缩级别必须在 1(速度最快)到 9(压缩率最高)的范围内。
提高压缩级别将减少网络使用量,但会增加 CPU 使用量。
默认值为 3。
worker
或 workers
编辑
每个配置的主机将事件发布到 Logstash 的工作线程数。这最适合在启用负载均衡模式的情况下使用。示例:如果您有 2 个主机和 3 个工作线程,则总共会启动 6 个工作线程(每个主机 3 个)。
loadbalance
编辑
当设置 loadbalance: true
时,Auditbeat 连接到所有配置的主机并通过所有连接并行发送数据。如果连接失败,数据将发送到剩余的主机,直到重新建立连接。只要 Auditbeat 可以连接到其至少一个配置的主机,数据就会继续发送。
当设置 loadbalance: false
时,Auditbeat 一次将数据发送到一个主机。目标主机是从配置的主机列表中随机选择的,所有数据都发送到该目标,直到连接失败,然后选择一个新的目标。只要 Auditbeat 可以连接到其至少一个配置的主机,数据就会继续发送。要随时间轮换配置的主机列表,请将此选项与 ttl
设置结合使用,以按配置的间隔关闭连接并选择新的目标主机。
默认值为 false
。
output.logstash: hosts: ["localhost:5044", "localhost:5045"] loadbalance: true index: auditbeat
ttl
编辑
与 Logstash 的连接的生存时间,在此时间之后将重新建立连接。当 Logstash 主机代表负载均衡器时很有用。由于与 Logstash 主机的连接是粘性的,因此在负载均衡器后面运行会导致实例之间的负载分配不均匀。在连接上指定 TTL 允许在实例之间实现相等的连接分配。指定 TTL 为 0 将禁用此功能。
默认值为 0。此设置接受 持续时间 数据类型值。
异步 Logstash 客户端(设置了“pipelining”选项的客户端)尚不支持“ttl”选项。
pipelining
编辑
配置在等待来自 Logstash 的 ACK 时异步发送到 Logstash 的批次数。仅当已写入 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 名称。例如,“auditbeat”
生成 “[auditbeat-]8.14.3-YYYY.MM.DD”
索引(例如,“auditbeat-8.14.3-2017.04.26”
)。
此参数的值将分配给 metadata.beat
字段。然后可以在 Logstash 的输出部分中以 %{[@metadata][beat]}
的形式访问它。
ssl
编辑
用于 SSL 参数的配置选项,例如 Logstash 连接的根 CA。有关详细信息,请参阅SSL。要使用 SSL,您还必须配置Logstash 的 Beats 输入插件以使用 SSL/TLS。
timeout
编辑
在超时前等待 Logstash 服务器响应的秒数。默认值为 30(秒)。
bulk_max_size
编辑
在单个 Logstash 请求中批量处理的最大事件数。默认值为 2048。
事件可以收集到批次中。Auditbeat 会将从队列中读取的、大于 bulk_max_size
的批次拆分为多个批次。
指定较大的批次大小可以通过降低发送事件的开销来提高性能。但是,大的批次大小也会增加处理时间,这可能会导致 API 错误、连接被终止、发布请求超时,最终导致吞吐量降低。
将 bulk_max_size
设置为小于或等于 0 的值将禁用批次拆分。禁用拆分后,队列将决定批次中包含的事件数量。
slow_start
编辑
如果启用,则每次事务仅传输一批事件中的部分事件。如果没有遇到错误,则要发送的事件数量会增加到 bulk_max_size
。如果出现错误,则每次事务的事件数量将再次减少。
默认值为 false
。
backoff.init
编辑
网络错误后,在尝试重新连接到 Logstash 之前等待的秒数。在等待 backoff.init
秒后,Auditbeat 尝试重新连接。如果尝试失败,则退避计时器会呈指数级增加,直至达到 backoff.max
。成功连接后,退避计时器将重置。默认值为 1 秒。
backoff.max
编辑
网络错误后,在尝试连接到 Logstash 之前等待的最长时间(以秒为单位)。默认值为 60 秒。