我jdbc在logstash输入的插件中有这样的MySQL语句。
statement => "SELECT * from TEST where id > :sql_last_value"
我的表没有任何date或datetime字段。因此,我尝试通过使用来检查scheduler每一分钟,以更新索引,是否在表中添加了任何新行。
我应该只能更新新记录,而不能更新现有记录中的现有值更改。为此,我需要进行以下logstash输入:
input {
jdbc {
jdbc_connection_string => "jdbc:mysql://myhostmachine:3306/mydb"
jdbc_user => "root"
jdbc_password => "root"
jdbc_validate_connection => true
jdbc_driver_library => "/mypath/mysql-connector-java-5.1.39-bin.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
jdbc_paging_enabled => "true"
jdbc_page_size => "50000"
schedule => "* * * * *"
statement => "SELECT * from mytable where id > :sql_last_value"
use_column_value => true
tracking_column => id
last_run_metadata_path => "/path/.logstash_jdbc_last_run"
clean_run => true
}
}
因此,每当我创建索引并运行该logstash文件以上传文档时,它就根本不会上传。文档数显示为零。我确保.logstash_jdbc_last_run在运行logstashconf文件之前删除了。
logstash控制台输出的一部分:
[2016-11-02T16:33:00,294] [INFO] [logstash.inputs.jdbc](0.002000s)SELECT
count(*)AS countFROM(SELECT * from TEST,其中id>‘2016-11-02 11:02: 00’)AS
t1LIMIT 1
并且通过逐分钟检查是正确的来继续进行,但是随后没有得到记录。它是如何工作的?
我想念什么吗?任何帮助,不胜感激。