通過Logstash在Elasticsearch中導入MySQL-Entrys

Question

我想知道如何使用Logstash將數據從我的MySQL數據庫輕鬆導入到我的Elasticsearch服務器。

我有一個Spring Boot App，想要導入那裏的信息。

Answer 1

爲了讓您將MySQL數據中的數據導入到您的elasticsearch索引，您應該使用jdbc插件作爲上面建議的@hurb。

你logstash jdbc輸入看起來是這樣的：

input { 
    jdbc { 
     jdbc_connection_string => "jdbc:mysql://yourhost:3306/yourdb" 
     jdbc_user => "root" 
     jdbc_password => "root" 
     jdbc_validate_connection => true 
     jdbc_driver_library => "/pathtojar/mysql-connector-java-5.1.39-bin.jar" 
     jdbc_driver_class => "com.mysql.jdbc.Driver" 
     schedule => "* * * * *" <-- if you need the query to be running continuously at a time span 
     statement => "SELECT * FROM yourtable" <-- change the query to your need   
     jdbc_paging_enabled => "true" 
     jdbc_page_size => "50000" 
    } 
} 

以上只是一個樣本，這樣你就可以重現。希望能幫助到你！