logstashのインストール使用、バージョン6.2.4
1.logstashダウンロードをインストールする:https://artifacts.elastic.co/downloads/logstash/logstash-6.2.4.zip 2.logstashフォルダの下にあるGemfileファイルを変更する
ソースを次のように変更します.https://gems.ruby-china.org
3.cmd binディレクトリに入りlogstash-plugin install logstash-input-jdbcを実行
Validating logstash-input-jdbc Installing logstash-input-jdbc Installation successfulはインストールに成功したことを示します
4.binにmysql-connector-java-5.1を入れる31.jarパッケージ5.binフォルダ新規logstash.confファイルの構成への追加
7.構成後cmdはbinディレクトリに入り、以下のコマンドlogstashを実行する.bat -f logstash.conf
小さな黒い画面にsql出力があるのを見たら、成功しました.データはリアルタイムで同期しています.headに行ってデータの参考があるかどうかを調べてみてください.https://blog.csdn.net/a863922230/article/details/80293931このリンクを参考にして成功しなかったので、sqlをinputに入れればいいです.
ソースを次のように変更します.https://gems.ruby-china.org
3.cmd binディレクトリに入りlogstash-plugin install logstash-input-jdbcを実行
Validating logstash-input-jdbc Installing logstash-input-jdbc Installation successfulはインストールに成功したことを示します
4.binにmysql-connector-java-5.1を入れる31.jarパッケージ5.binフォルダ新規logstash.confファイルの構成への追加
input {
jdbc {
# mysql jdbc
jdbc_connection_string => "jdbc:mysql://127.0.0.1:3306/vtest?useUnicode=true&characterEncoding=utf-8&useSSL=false"
jdbc_user => "root"
jdbc_password => "123456"
# jdbc mysql , :https://dev.mysql.com/downloads/connector/j/
jdbc_driver_library => "mysql-connector-java-5.1.31.jar"
# the name of the driver class for mysql
jdbc_driver_class => "com.mysql.jdbc.Driver"
jdbc_paging_enabled => true
jdbc_page_size => "50000"
jdbc_default_timezone =>"Asia/Shanghai"
# mysql , SQL , :
statement => "select * from t_owner"
# statement_filepath => "jdbc.sql"
# crontab, , ( )
schedule => "* * * * *"
#type => "jdbc"
}
}
output {
elasticsearch {
hosts => "127.0.0.1:9200"
#
index => "owner"
# , ,
document_id => "%{ownerid}"
template_overwrite => true
}
# ,
stdout {
codec => json_lines
}
}
7.構成後cmdはbinディレクトリに入り、以下のコマンドlogstashを実行する.bat -f logstash.conf
小さな黒い画面にsql出力があるのを見たら、成功しました.データはリアルタイムで同期しています.headに行ってデータの参考があるかどうかを調べてみてください.https://blog.csdn.net/a863922230/article/details/80293931このリンクを参考にして成功しなかったので、sqlをinputに入れればいいです.