Спасибо !!!! это работает, но не должно очищать индекс, иначе logstash будет индексировать только документ, который был изменен.
троил logstash.conf для динамической вставки данных моей базы данных, но проблема заключается в следующем:
когда я изменяю строку в моей таблице, эта строка не обновляется в моем индексе, потому что я вставляю только новые значения после sql_last_value, я думаю о триггере, но не знаю, как это сделать.
input {
jdbc {
jdbc_connection_string =>"jdbc:mysql://localhost:3306/blog"
jdbc_user =>"root"
jdbc_password =>""
jdbc_driver_library =>"C:\Users\saidb\Downloads\mysql-connector-java-5.1.47\mysql-connector-java-5.1.47.jar"
jdbc_driver_class =>"com.mysql.jdbc.Driver"
schedule =>"* * * * *"
statement =>"SELECT * FROM blog_pro WHERE id >:sql_last_value"
use_column_value =>true
tracking_column =>id
}
}
output {
elasticsearch {
hosts =>"localhost:9200"
index =>"blog_pro"
document_type =>"data"
}
}