Подключитесь к mongodb с помощью плагина фильтра logstash Jdbc_streaming

Я пытаюсь получить данные из mongodb, используя плагин фильтра Jdbc_streaming в logstash в Windows. Я использую mongo-java-driver-3.4.2.jar для подключения к базе данных, но получаю такую ​​ошибку.

JavaSql::SQLException: No suitable driver found for jdbc:mongo://localhost:27017/EmployeeDB

Не повезло с существующими ссылками. Я использую версию logstash 7.8.0. Это моя конфигурация logstash:

jdbc_streaming {
        jdbc_driver_library => "C:/Users/iTelaSoft-User/Downloads/logstash-7.8.0/mongo-java-driver-3.4.2.jar"
        jdbc_driver_class => "com.mongodb.MongoClient"
        jdbc_connection_string => "jdbc:mongo://localhost:27017/EmployeeDB"
        statement => "select * from Employee"
        target => "name"
    }

person Rasitha Ariyarathna    schedule 21.07.2020    source источник
comment
Попробуйте поместить jar-файл драйвера в основную папку. (С:/Драйвер). Я столкнулся с ошибкой того же типа, а затем переустановил драйвер jdbc для монго.   -  person Max    schedule 21.07.2020
comment
@Max - Спасибо за ответ. Я пытался, но не повезло. У меня такая же ошибка.   -  person Rasitha Ariyarathna    schedule 21.07.2020
comment
Очевидно, это что-то с контроллером jar, никогда не используйте logstash в Windows, с которым я не знаю, является ли это официальным контроллером или тем, который вы используете, но, возможно, с помощью этой ссылки вы можете сообщить о своей проблеме: discuss.elastic.co/t/mongodb-logstash-integration-solved/122299   -  person Max    schedule 21.07.2020
comment
Я пробовал почти все решения на их форуме. Ничего не сработало. В любом случае, спасибо за ссылку на форум. Попробую поставить вопрос.   -  person Rasitha Ariyarathna    schedule 21.07.2020


Ответы (1)


Вы также можете попробовать следующее:

  1. загрузите https://dbschema.com/jdbc-drivers/MongoDbJdbcDriver.zip
  2. разархивируйте и скопируйте все файлы по пути (~/logstash-7.8.0/logstash-core/lib/jars/)
  3. изменить файл .config

Пример:

input {
  jdbc{
    jdbc_driver_class => "com.dbschema.MongoJdbcDriver"
    jdbc_driver_library => "mongojdbc2.1.jar"
    jdbc_user => "user"
    jdbc_password => "pwd"
    jdbc_connection_string => "jdbc:mongodb://localhost:27017/EmployeeDB"
    statement => "select * from Employee"
  }
}

output {
    stdout { }
}
person Max    schedule 21.07.2020
comment
Вау, это сработало. Я потратил на это 2 дня. Спасибо. Но мне пришлось указать полный путь для драйвера jdbc_driver_library следующим образом: jdbc_driver_library => C:\Users\iTelaSoft-User\Downloads\logstash-7.8.0\logstash-core\lib\jars\mongojdbc2.1.jar - person Rasitha Ariyarathna; 21.07.2020