我想知道如何使用Logstash
将数据从我的MySQL
数据库轻松导入到我的Elasticsearch
服务器。通过Logstash在Elasticsearch中导入MySQL-Entrys
我有一个Spring Boot App,想要导入那里的信息。
我想知道如何使用Logstash
将数据从我的MySQL
数据库轻松导入到我的Elasticsearch
服务器。通过Logstash在Elasticsearch中导入MySQL-Entrys
我有一个Spring Boot App,想要导入那里的信息。
为了让您将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"
}
}
以上只是一个样本,这样你就可以重现。希望能帮助到你!
刚刚为您的解决方案安装了jdbc插件。当我执行我的.conf文件时出现错误: NameError:缺少类名('org.apache.logging.log4j.Level') –
什么是ES版本? – Kulasangar
2.4.0因为我正在使用Spring Boot和Spring Data Elasticsearch,他们正在使用ES 2.4.0版本 –
你尝试过什么吗?让我指出您的正确方向:https://www.elastic.co/guide/en/logstash/current/plugins-inputs-jdbc.html – hurb
感谢您的帮助,刚刚从弹性文档中翻转过来。但是经过几个小时的研究,现在更清楚了! –