首页 / MYSQL / LogStash如何通过jdbc 从mysql导入elasticsearch

LogStash如何通过jdbc 从mysql导入elasticsearch

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了LogStash如何通过jdbc 从mysql导入elasticsearch，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1317字，纯文字阅读大概需要2分钟。

内容图文

# mysql jdbc connection string to our backup databse jdbc_connection_string => "jdbc:mysql://localhost:3306/userdb?useUnicode=true&characterEncoding=utf-8&useSSL=false" # the user we wish to excute our statement as jdbc_user => "user" jdbc_password => "pass" # the path to our downloaded jdbc driver jdbc_driver_library => "mysql-connector-java-5.1.40-bin.jar" # the name of the driver class for mysql jdbc_driver_class => "com.mysql.jdbc.Driver" jdbc_paging_enabled => "true" jdbc_page_size => "50000" statement_filepath => "mysqltestsql.sql" schedule => "* * * * *" type => "jdbc" use_column_value => true tracking_column => id last_run_metadata_path => "C:\logstash-5.2.0\bin\last_run_metadata_path\last_run_metadata_path" } } filter { json { source => "message" remove_field => ["message","_id"] } } output { elasticsearch { action => "index" hosts => ["http://localhost:9200"] index => "mysqltestdb2" #index => "user" workers => 1 } #stdout { #codec => rubydebug #codec => json_lines #} }

 

 mysqltestsql.sql

select id, name from userinfo WHERE id > :sql_last_value

 

LogStash如何通过jdbc 从mysql导入elasticsearch

标签：cte   nload   .sql   odi   line   sql   ade   jdbc   remove   

本文系统来源：http://www.cnblogs.com/haoliansheng/p/6497870.html

内容总结

以上是互联网集市为您收集整理的LogStash如何通过jdbc 从mysql导入elasticsearch全部内容，希望文章能够帮你解决LogStash如何通过jdbc 从mysql导入elasticsearch所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/475808.html

来源：【匿名】