¿Cómo podría actualizar mis datos dinámicamente desde MySQL con logstash (sin duplicado)?
He configurado logstash.conf para insertar dinámicamente los datos de mi base de datos, pero el problema es:
cuando cambio una línea de mi tabla, esa línea no se actualiza en mi índice porque solo inserto nuevos valores después de sql_last_value, pensé en nosotros como un disparador pero no estoy seguro de cómo puedo hacerlo.
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"
}
}