Sqlite 输入插件
编辑Sqlite 输入插件编辑
- 插件版本：v3.0.4
- 发布时间：2018-04-06
- 更新日志
有关其他版本，请参阅版本化插件文档。
获取帮助编辑
有关插件的问题，请在论坛中打开一个主题。对于错误或功能请求，请在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"
}
通用选项编辑
以下配置选项受所有输入插件支持
详细信息编辑
codec编辑
- 值类型为编解码器
- 默认值为
"plain"
用于输入数据的编解码器。输入编解码器是一种方便的方法，可以在数据进入输入之前对其进行解码，而无需在 Logstash 管道中使用单独的过滤器。