перемещение данных из mysql вasticsearch с использованием конфигурации файла logstash - PullRequest
Новая
       1

перемещение данных из mysql вasticsearch с использованием конфигурации файла logstash

0 голосов
/ 17 апреля 2019

Я хочу перенести таблицу из базы данных MySQL вasticsearch, я использую logstash и пишу этот файл конфигурации, но он не работает, вы можете помочь мне исправить ошибку, заранее спасибо, это файл configuraton enterописание изображения здесь 

input {
  jdbc {
    jdbc_connection_string => "jdbc:mysql://localhost:3307/new_schema?useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC"
    jdbc_driver_library => "mysql-connector-java-5.1.47.jar"
    jdbc_driver_class => "com.mysql.jdbc.Driver"
    jdbc_user => "root"
    jdbc_password => "password"

    statement => "SELECT * FROM tweecoms"
  }
}

output {
#stdout { codec => json_lines }
  elasticsearch {
    hosts => ["localhost:9200"]
    index => "socialmed"
  }
}
...