Sqlite 输入插件
编辑Sqlite 输入插件
编辑- 插件版本:v3.0.4
- 发布日期:2018-04-06
- 更新日志
有关其他版本,请参阅版本化插件文档。
获取帮助
编辑有关插件的问题,请在Discuss论坛中打开一个主题。对于错误或功能请求,请在Github中打开一个 issue。有关 Elastic 支持的插件列表,请查阅Elastic 支持矩阵。
描述
编辑从 sqlite 数据库读取行。
这在直接记录到表中的情况下最有用。任何被监视的表都必须有一个单调递增的 id
列。
默认情况下,读取所有表,除了
- 匹配
sqlite_%
的表 - 这些是 sqlite 的内部/管理表 -
since_table
- 此插件使用此表来跟踪状态。
示例
% sqlite /tmp/example.db sqlite> CREATE TABLE weblogs ( id INTEGER PRIMARY KEY AUTOINCREMENT, ip STRING, request STRING, response INTEGER); sqlite> INSERT INTO weblogs (ip, request, response) VALUES ("1.2.3.4", "/index.html", 200);
然后使用此 logstash 配置
input { sqlite { path => "/tmp/example.db" type => weblogs } } output { stdout { debug => true } }
示例输出
{ "@source" => "sqlite://sadness/tmp/x.db", "@tags" => [], "@fields" => { "ip" => "1.2.3.4", "request" => "/index.html", "response" => 200 }, "@timestamp" => "2013-05-29T06:16:30.850Z", "@source_host" => "sadness", "@source_path" => "/tmp/x.db", "@message" => "", "@type" => "foo" }
通用选项
编辑所有输入插件都支持这些配置选项
codec
编辑- 值类型为编解码器
- 默认值为
"plain"
用于输入数据的编解码器。输入编解码器是一种方便的方法,可以在数据进入输入之前对其进行解码,而无需在 Logstash 管道中使用单独的过滤器。