2016-12-20 15 views
0

MySQLデータベースからLogstashを使用してサーバにデータを簡単にインポートする方法を知りたかったのですが、LogstashでElasticsearchでMySQL-Entryをインポートする

私はSpring Boot Appを持っていて、そこで情報をインポートしたいと考えています。

+1

まだ試しましたか?正しい方向を教えてください:https://www.elastic.co/guide/en/logstash/current/plugins-inputs-jdbc.html – hurb

+0

あなたの助けていただきありがとうございます。ちょうど弾力性のある文書に覆されているように感じました。しかし数時間後にはもっと研究が進んでいます。 –

答えて

1

データをMySQLのデータをelasticsearchインデックスにインポートするには、上記の@hurbのようにjdbcプラグインを使用する必要があります。

あなた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" 
    } 
} 

、単なるサンプルです。それが役に立てば幸い!

+0

あなたのソリューションにjdbc-pluginをインストールしました。 .confファイルを実行するとエラーが発生します: NameError:クラス名が見つかりません( 'org.apache.logging.log4j.Level') –

+0

ESバージョンとは何ですか? – Kulasangar

+0

私はSpringブートとSpring Data Elasticsearchで作業しているので、彼らはES 2.4.0バージョン –

関連する問題