Sqs 输入插件

此插件使用 AWS SDK 并支持以下几种获取凭证的方式，将按以下顺序尝试

用于参数化与 SQS 连接的设置和对应值的键值对。有关完整列表，请参阅 AWS SDK 文档。例如

    input {
      sqs {
        access_key_id => "1234"
        secret_access_key => "secret"
        queue => "logstash-test-queue"
        additional_settings => {
          force_path_style => true
          follow_redirects => false
        }
      }
    }

包含 AWS 凭证哈希的 YAML 文件的路径。仅当未设置 access_key_id 和 secret_access_key 时，才会加载此文件。文件内容应如下所示

    :access_key_id: "12345"
    :secret_access_key: "54321"

要连接的端点。默认情况下，它使用 region 的值构造。这在连接到与 S3 兼容的服务时很有用，但请注意，AWS SDK 不能保证这些服务能正常工作。

用于存储 SQS 消息 ID 的事件字段的名称

用于存储 SQS 消息 MD5 校验和的事件字段的名称

轮询频率，默认为 20 秒

如果需要，代理服务器的 URI

要从中拉取消息的 SQS 队列的名称。请注意，这只是队列的名称，而不是 URL 或 ARN。

如果您想使用带有嵌入式策略的 跨账户队列，则为拥有该队列的 AWS 账户的 ID。请注意，AWS SDK 仅支持数字账户 ID，不支持账户别名。

AWS 区域

要承担的 AWS IAM 角色（如果有）。这用于生成临时凭证，通常用于跨账户访问。有关更多信息，请参阅 AssumeRole API 文档。

承担 IAM 角色时使用的会话名称。

AWS 秘密访问密钥

用于存储 SQS 消息发送时间戳的事件字段的名称

临时凭证的 AWS 会话令牌

使用 AWS SDK 附带的捆绑 CA 证书来验证 SSL 对等证书。如果默认证书不可用（例如，Windows），则可以将其设置为 true。

向事件添加字段

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

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

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

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

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

这有助于以后的处理。

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

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

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

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