我有一个包含400多条记录的数据库表,但是每次使用logstash和jdbc时,它只得到126条记录。我尝试了很多次,每次都使用不同的索引,但仍然是唯一的索引。
以下是输出配置:
input {
jdbc {
-
-
jdbc_driver_class => "org.postgresql.Driver"
statement => "SELECT * from xfailure"
}
}
output {
elasticsearch {
hosts => ["localhost:9200"]
manage_template => false
index => "test_predictions"
document_id => "%{id}"
}
}
当我检查行数时,我发现它有400多条记录这里是select语句:
SELECT * FROM xfailure;
以下是记录列的示例:
id|modified|x_url|x_id|correlation_id|links|code|description|explanation|tr_id
当我在kibanna上创建一个索引时,我使用时间戳作为时间域,但是点击次数只有162次!
1条答案
按热度按时间sbdsn5lh1#
我找到了一个解决方案,通过在sql查询中更改
到
现在可以正常工作了。