logstash:如何设置logstash来获取所有查询的数据,而不仅仅是其中的一部分?

e0bqpujr  于 2021-06-14  发布在  ElasticSearch
关注(0)|答案(1)|浏览(377)

我有一个包含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次!

sbdsn5lh

sbdsn5lh1#

我找到了一个解决方案,通过在sql查询中更改

SELECT * FROM xfailure;

SELECT field_1 as field_1, field_2 as field_2 FROM xfailure;

现在可以正常工作了。

相关问题