美文网首页
ElasticSearch_Logstash_mysql

ElasticSearch_Logstash_mysql

作者: bboymonk | 来源:发表于2017-06-08 11:34 被阅读0次

WIN10,64位:

先安装logstash-input-jdbc插件



查看可用插件列表命令用:

 logstash-plugin list

需要两个文件:1)jdbc.conf,2)jdbc.sql。

jdbc.conf:
这个文件放在bin下面。

input {
    stdin {
    }
    jdbc {
      jdbc_connection_string => "jdbc:mysql://127.0.0.1:3306/testdb"
      jdbc_user => "root"
      jdbc_password => "wjb"
      jdbc_driver_library => "F:\Repositories\Maven\mysql\mysql-connector-java\5.1.39\mysql-connector-java-5.1.39.jar"
      jdbc_driver_class => "com.mysql.jdbc.Driver"
      jdbc_paging_enabled => "true"
      jdbc_page_size => "100000"
      statement_filepath => "F:\ElasticSearch\logstash-5.4.1\dataSql\jdbc.sql"
      schedule => "* * * * *"
      type => "jdbc"
    }
}
output {
    stdout {
        codec => json_lines
    }
    elasticsearch {
        hosts  => "localhost:9200"
        index => "bboy" 
        document_type => "form" 
        document_id => "%{id}" 
} }

jdbc.sql:
这个文件位置随意指定。

select * from user
启动logstash
logstash.bat -f wjbMysql.conf
成功导入数据到elasticsearch,索引为bboy。用kibana查看:

相关文章

  • ElasticSearch_Logstash_mysql

    WIN10,64位: 先安装logstash-input-jdbc插件 查看可用插件列表命令用: 需要两个文件:1...

网友评论

      本文标题:ElasticSearch_Logstash_mysql

      本文链接:https://www.haomeiwen.com/subject/cqvzfxtx.html