MySQL
データベースからLogstash
を使用してサーバにデータを簡単にインポートする方法を知りたかったのですが、LogstashでElasticsearchでMySQL-Entryをインポートする
私はSpring Boot Appを持っていて、そこで情報をインポートしたいと考えています。
MySQL
データベースからLogstash
を使用してサーバにデータを簡単にインポートする方法を知りたかったのですが、LogstashでElasticsearchでMySQL-Entryをインポートする
私はSpring Boot Appを持っていて、そこで情報をインポートしたいと考えています。
データを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"
}
}
、単なるサンプルです。それが役に立てば幸い!
あなたのソリューションにjdbc-pluginをインストールしました。 .confファイルを実行するとエラーが発生します: NameError:クラス名が見つかりません( 'org.apache.logging.log4j.Level') –
ESバージョンとは何ですか? – Kulasangar
私はSpringブートとSpring Data Elasticsearchで作業しているので、彼らはES 2.4.0バージョン –
まだ試しましたか?正しい方向を教えてください:https://www.elastic.co/guide/en/logstash/current/plugins-inputs-jdbc.html – hurb
あなたの助けていただきありがとうございます。ちょうど弾力性のある文書に覆されているように感じました。しかし数時間後にはもっと研究が進んでいます。 –