Rabbitmq 输入插件

启用消息确认。通过确认，Logstash 获取但尚未发送到 Logstash 管道的消息将在 Logstash 关闭时由服务器重新排队。但是，确认会影响消息吞吐量。

这将仅每 prefetch_count 条消息发送一次确认。批量工作可在此处提高性能。

可选的队列参数作为数组。

相关的 RabbitMQ 文档指南

当最后一个消费者断开连接时，是否应在代理上删除队列？如果要使队列保留在代理上，排队消息直到有消费者来消费它们，请将此选项设置为 false。

将其设置为从断开的连接中自动恢复。您几乎肯定不想覆盖此设置！

重试连接前等待的时间（以秒为单位）

默认连接超时（以毫秒为单位）。如果未指定，则超时为无限期。

此队列是否持久？（又名；它是否应在代理重新启动后保留？）如果直接从队列中消费，则必须将此值设置为与现有队列设置匹配，否则连接将因不相等的 arg 错误而失败。

要将队列绑定到的交换机的名称。指定 exchange_type 以便在交换机不存在时声明它

要绑定到的交换机的类型。指定此值将导致此插件在交换机不存在时声明它。

队列是否是独占的？独占队列只能由声明它们的连接使用，并在关闭时（例如，由于 Logstash 重新启动）删除。

以秒为单位的心跳超时。如果未指定，则将使用 60 秒的心跳超时。

rabbitmq 输入/输出 RabbitMQ 服务器地址的常用功能，主机可以是单个主机，也可以是主机列表，例如 host ⇒ "localhost" 或 host ⇒ ["host01", "host02"]

如果初始连接上提供了多个主机，并且任何后续恢复尝试的主机都是随机选择并连接的。请注意，一次只有一个主机连接处于活动状态。

将队列绑定到交换机时使用的路由密钥。这仅与 direct 或 topic 交换机相关。

启用关于 RabbitMQ 主题的元数据，以添加到事件的 @metadata 字段，以便在管道处理期间可用。一般来说，大多数输出插件和编解码器不包括 @metadata 字段。这可能会影响内存使用和性能。

如果为 true，则将被动声明队列，这意味着它必须已存在于服务器上。要让 Logstash 在必要时创建队列，请将此选项保留为 false。如果主动声明已存在的队列，则此插件的队列选项（durable 等）必须与现有队列的选项匹配。

RabbitMQ 密码

RabbitMQ 连接端口

预取计数。如果通过 ack 选项启用了确认，则指定允许的最大未确认消息数。

要从每条消息中提取并存储在 @metadata 字段中的属性。

从技术上讲，交换机、重新传递和路由密钥属性属于信封而不是消息，但我们在此忽略了这种区别。但是，我们通过 get_headers 单独提取标头，即使标头表在技术上是消息属性。

冻结所有字符串，以便修改事件 @metadata 字段的代码无法触及它们。

如果更新此列表，请记住也更新上面的文档。此插件的默认编解码器是 JSON。您可以根据您的特定需求覆盖此设置。Logstash 将从中消费事件的队列的名称。如果留空，将创建一个具有随机选择名称的瞬态队列。

启用或禁用 SSL。请注意，默认情况下，远程证书验证是关闭的。如果需要证书验证，请指定 ssl_certificate_path 和 ssl_certificate_password。

在 ssl_certificate_path 中指定的加密 PKCS12 (.p12) 证书文件的密码

用于验证远程主机的 PKCS12 (.p12) 格式的 SSL 证书的路径

要使用的 SSL 协议版本。

在订阅请求失败后，重试之前等待的时间（以秒为单位）。如果服务器关闭然后又重新启动，订阅可能会失败。

RabbitMQ 用户名

要使用的 vhost（虚拟主机）。如果您不知道这是什么，请保留默认值。除了默认的 vhost (“/”)，vhost 的名称不应以正斜杠开头。

向事件添加一个字段

用于输入数据的编解码器。输入编解码器是一种方便的方法，可以在数据进入输入之前解码数据，而无需在 Logstash 管道中使用单独的过滤器。

禁用或启用此特定插件实例的指标日志记录，默认情况下，我们记录所有可以记录的指标，但是您可以禁用特定插件的指标收集。

向插件配置添加唯一的 ID。如果未指定 ID，Logstash 将生成一个。强烈建议在配置中设置此 ID。当您有两个或多个相同类型的插件时，这尤其有用，例如，如果您有 2 个 rabbitmq 输入。在这种情况下添加命名的 ID 将在使用监控 API 时有助于监控 Logstash。

input {
  rabbitmq {
    id => "my_plugin_id"
  }
}

向您的事件添加任意数量的标签。

这有助于以后的处理。

向此输入处理的所有事件添加一个 type 字段。

类型主要用于过滤器激活。

该类型作为事件本身的一部分存储，因此您也可以使用该类型在 Kibana 中搜索它。

如果您尝试在已经具有类型的事件上设置类型（例如，当您将事件从托运人发送到索引器时），则新的输入将不会覆盖现有类型。在托运人处设置的类型会一直保留在该事件中，即使发送到另一个 Logstash 服务器也是如此。