Jdbc_streaming 过滤器插件

任何条目应保留在缓存中的最小秒数。默认为 5 秒。

数值。您可以使用小数，例如：cache_expiration => 0.25。如果存在瞬态 jdbc 错误，缓存将为给定的参数集存储空结果并绕过 jbdc 查找。这会将 default_hash 合并到事件中，直到缓存条目过期。然后，将再次尝试使用相同的参数进行 jdbc 查找。相反，当缓存包含有效结果时，在 cache_expiration 期间，不会注意到任何会导致 jdbc 错误的外部问题。

将存储的最大缓存条目数。默认为 500 个条目。将删除最近最少使用的条目。

定义在查找未能返回匹配行时使用的默认对象。确保此对象的键名与语句中的列匹配。

JDBC 连接字符串

要加载的 JDBC 驱动程序类，例如“oracle.jdbc.OracleDriver”或“org.apache.derby.jdbc.ClientDriver”

第三方驱动程序库的 JDBC 驱动程序库路径。

JDBC 密码

JDBC 用户

连接池配置。在使用前验证连接。

连接池配置。验证连接的频率（以秒为单位）。

查询参数的哈希，例如 { "id" => "id_field" }。

预处理语句的绑定值数组。使用字段引用和常量。有关更多信息，请参阅预处理语句部分。

赋予预处理语句的名称。它在您的配置和数据库中必须是唯一的。如果 use_prepared_statements 为 true，则需要提供此名称。

一个标志，用于控制当在 prepared_statement_bind_values 中检测到可能是作为字段引用的字符串常量时，是否记录警告。

通用/特定于供应商的 Sequel 配置选项

可选连接池配置 max_connections 的一个示例 - 连接池的最大连接数

可以在此文档页面中找到特定于供应商的选项示例：https://github.com/jeremyevans/sequel/blob/master/doc/opening_databases.rdoc

要执行的语句。要使用参数，请使用命名参数语法，例如“SELECT * FROM MYTABLE WHERE ID = :id”。

如果没有找到记录并且使用了默认值，则将值追加到 tags 字段。

如果发生 sql 错误，则将值追加到 tags 字段。

定义用于存储提取结果的目标字段。如果存在，则覆盖该字段。

启用或禁用缓存，布尔值 true 或 false。默认为 true。

设置为 true 时，启用预处理语句的使用

如果此过滤器成功，请将任何任意字段添加到此事件。字段名称可以是动态的，并且可以使用 %{field} 包含事件的一部分。

示例

    filter {
      jdbc_streaming {
        add_field => { "foo_%{somefield}" => "Hello world, from %{host}" }
      }
    }

    # You can also add multiple fields at once:
    filter {
      jdbc_streaming {
        add_field => {
          "foo_%{somefield}" => "Hello world, from %{host}"
          "new_field" => "new_static_value"
        }
      }
    }

如果事件具有字段 "somefield" == "hello"，则此过滤器在成功时会添加字段 foo_hello （如果存在），其值为上述值，并且 %{host} 部分会被事件中的相应值替换。第二个示例还会添加一个硬编码字段。

如果此过滤器成功，则会向事件添加任意标签。标签可以是动态的，并且可以使用 %{field} 语法包含事件的部分内容。

示例

    filter {
      jdbc_streaming {
        add_tag => [ "foo_%{somefield}" ]
      }
    }

    # You can also add multiple tags at once:
    filter {
      jdbc_streaming {
        add_tag => [ "foo_%{somefield}", "taggedy_tag"]
      }
    }

如果事件具有字段 "somefield" == "hello"，则此过滤器在成功时会添加标签 foo_hello （第二个示例当然会添加一个 taggedy_tag 标签）。

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

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

    filter {
      jdbc_streaming {
        id => "ABC"
      }
    }

定期调用过滤器刷新方法。可选。

如果此过滤器成功，则会从此事件中删除任意字段。字段名称可以是动态的，并且可以使用 %{field} 包含事件的部分内容。示例

    filter {
      jdbc_streaming {
        remove_field => [ "foo_%{somefield}" ]
      }
    }

    # You can also remove multiple fields at once:
    filter {
      jdbc_streaming {
        remove_field => [ "foo_%{somefield}", "my_extraneous_field" ]
      }
    }

如果事件具有字段 "somefield" == "hello"，则此过滤器在成功时会删除名为 foo_hello 的字段（如果存在）。第二个示例会删除一个额外的非动态字段。

如果此过滤器成功，则会从事件中删除任意标签。标签可以是动态的，并且可以使用 %{field} 语法包含事件的部分内容。

示例

    filter {
      jdbc_streaming {
        remove_tag => [ "foo_%{somefield}" ]
      }
    }

    # You can also remove multiple tags at once:
    filter {
      jdbc_streaming {
        remove_tag => [ "foo_%{somefield}", "sad_unwanted_tag"]
      }
    }

如果事件具有字段 "somefield" == "hello"，则此过滤器在成功时会删除标签 foo_hello（如果存在）。第二个示例还会删除一个令人难过的、不需要的标签。