input{
jdbc{
jdbc_driver_library => "/etc/mysql-connector/mysql-connector-java-5.1.46/mysql-connector-java-5.1.46-bin.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
jdbc_connection_string => "jdbc:mysql://.......amazonaws.com:..../..."
jdbc_user => "api_......."
jdbc_password => "........"
schedule => "*/10 * * * * *"
statement => "SELECT * from view_product_autosuggest
clean_run => true
}
}
filter {
mutate {
convert =>
"price" => "integer"
}
}
output {
elasticsearch {
hosts => ["https://s........amazonaws.com:..."]
index => "search_suggestion_dev"
document_id => "%{id}"
}
}
i have problem in configuration logstash, my statement in config select and then in elastic i get data in database to elastic then logstash updated my databse :sql_mode=NO_ENGINE..... in the same time
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.