Logstash 从 MySQL 导入 Elasticsearch

Question

测试数据 将数据 u.item 导入 MySQL

Logstash 配置文件

logstash.conf

input {
  jdbc {
    jdbc_driver_library => "/Users/jasonwu/.m2/repository/mysql/mysql-connector-java/8.0.22/mysql-connector-java-8.0.22.jar"
    jdbc_driver_class => "com.mysql.jdbc.Driver"
    jdbc_connection_string => "jdbc:mysql://localhost:3306/my_test"
    jdbc_user => "root"
    jdbc_password => "root123"
    statement => "SELECT * FROM movies"
  }
}

output {
  stdout {
    codec => "json_lines"
  }

  elasticsearch {
    hosts => ["localhost:9200"]
    index => "movies-sql"
  }
}

执行 Logstash 导入 Elasticsearch

$ bin/logstash -f /Users/jasonwu/WorkSpace/learn/Elasticsearch/logstash.conf