前言：
目前你们对“mysql表数据导入”大约比较关切，兄弟们都想要剖析一些“mysql表数据导入”的相关资讯。那么小编也在网摘上收集了一些关于“mysql表数据导入””的相关资讯，希望看官们能喜欢，咱们快快来了解一下吧！因为elk(Elasticsearch,logstash,Kibana是一家的),所以使用 logstash做为作为导入工具是最好的选择。
1))下载logstash
2)解压后进入logstash目录
3)新版本（2020/3/12，7.6.1）无需执行bin/logstash-plugin install logstash-input-jdbc,包内自带
4)新建导入的配置文件
vi cat config/mysql-to-elasticsearch.conf
input { jdbc { jdbc_connection_string => "jdbc:mysql://127.0.0.1:3786/datacapture?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8&allowMultiQueries=true" jdbc_user => "root" jdbc_password => "123456" jdbc_driver_library => "/Users/hongyanma/repo/mysql/mysql-connector-java/5.1.46/mysql-connector-java-5.1.46.jar" jdbc_driver_class => "com.mysql.jdbc.Driver" jdbc_paging_enabled => "true" jdbc_page_size => "50000" jdbc_default_timezone => "Asia/Shanghai" statement_filepath => "/Users/hongyanma/gitspace/java/logstash-7.6.1/config/layer_video.sql" schedule => "* * * * *" type => "jdbc" }} output { elasticsearch { hosts => "127.0.0.1:9200" # protocol => "http" index => "datacapture" document_type => "video" document_id => "%{id}" } }vi /Users/hongyanma/gitspace/java/logstash-7.6.1/config/person_info.sql
select * from person_info
注意sql结尾不要加分号
4）运行logstash
bin/logstash -f config/mysql-to-elasticsearch.conf
启动需要一点时间，然后就会输出执行的sql
版权声明：
本站文章均来自互联网搜集，如有侵犯您的权益，请联系我们删除，谢谢。
标签： #mysql表数据导入
