Не удается импортировать данные MySQL в эластичный поиск - PullRequest
Новая
       31

Не удается импортировать данные MySQL в эластичный поиск

0 голосов
/ 15 октября 2018

Я пытаюсь следовать примеру курса, который не получил никакой помощи в часто задаваемых вопросах, перепробовал все, что я мог найти в Google и здесь.

Я не использую docker, просто запускаю эту демонстрацию на моей локальной машине (Ubunutu 18.04), работают и упругий поиск, и mysql.

Когда я запускаю "sudo bin / logstash -f /etc / logstash / conf.d / mysql.conf --path.settings / etc / logstash "Я получаю следующую ошибку: com.mysql.jdbc.Driver не загружен.Вы уверены, что включили правильный драйвер jdbc в: jdbc_driver_library?Драйвер существует, и путь указан правильно.

, когда я использую sudo bin / logstash --config.test_and_exit -f /etc/logstash/conf.d/mysql.conf Возвращается с настройкой ok.

Я использую mysql-connector-java-5.1.47 openjdk version "1.8.0_181" Среда выполнения OpenJDK (сборка 1.8.0_181-8u181-b13-0ubuntu0.18.04.1-b13) Виртуальная 64-разрядная серверная виртуальная машина OpenJDK(сборка 25.181-b13, смешанный режим)

Elasticsearch-6.4.2 Logstash-6.4.2

Мой mysql.conf 

input {
    jdbc {
        jdbc_connection_string => "jdbc:mysql://localhost:3306/movielens"
        jdbc_user => "grunt"
        jdbc_password => "password"
        jdbc_driver_library => "/home/alarik/mysql-connecter-java-5.1.47/mysql-connector-java-5.1.47-bin.jar"
        jdbc_driver_class => "com.mysql.jdbc.Driver"
        statement => "SELECT * FROM movies"
    }
}

output {
    stdout { codec => json_lines }
    elasticsearch {
        "hosts" => "localhost:9200"
        "index" => "movielens-sql"
        "document_type" => "data"
    }
}

1 Ответ

0 голосов
/ 12 ноября 2018

Я решил проблему:

Сначала проверьте вашу версию Java: 

root@xxxxxx:/# java -version
openjdk version "1.8.0_181"

Если вы используете 1.8, то вам следует использовать версию JDBC42.

Если вы1.7, тогда вы должны использовать версию JDBC41.

Если вы используете 1.6, тогда вам следует использовать версию JDBC43.

mysql setup:

mysql-connector-java-5.1.46.jar 

jdbc_driver_library => "//path_to_jar/mysql-connector-java-5.1.46.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
...