Sqlite 输入插件
编辑Sqlite 输入插件
编辑- 插件版本:v3.0.4
- 发布日期:2018-04-06
- 更改日志
对于其他版本,请参阅 版本化插件文档。
获取帮助
编辑如有关于插件的问题,请在 Discuss 论坛中发起主题。对于错误或功能请求,请在 Github 中提交问题。有关 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" }