弾性検索を使用してmysqlレコードをインデックスする

Question

私はmysql dbから結果セットを取得してからjsonに変換し、弾性検索apiを使用してインデックスを作成しようとしています。

Googleは、logstashを使用してデータを直接弾性検索にインデックス付けし、多くの検索を行ったが、どのようなサンプルコードでもJavaコードでこれを行う方法を見つけることができます。

（logstashを使用してインデックスを作成するか、結果セットをjsonに変換してからelasticsearchを使用してインデックスを作成する）最適な方法がわかりません。

サンプルコード/リンクは非常に役に立ちます。あなたがlogstashを使用して、それを行うために喜んでいる場合

Answer 1

は、あなたができるあなたのelasticsearchインスタンスにごMySQLデータベースとインデックスからデータを描画することが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" 
    } 
} 

上記は単なるサンプルであり、必要に応じて再現できます。私はそれがより良い方法は、jsonに変換するか、それともlogstashを使用して明示的にインデックスを作成するかどうか、かなり分かりません。このthreadをご覧になりたいかもしれません。それが役に立てば幸い！