如何使用logstash同步mongodb集合与elasticseatch索引？

问题描述

我正在尝试使用logstash-7.6.2将我的mongo与elasticsearch同步。我正在使用dbschema jdbc driver。

input {
  jdbc{
    jdbc_driver_class => "com.dbschema.MongoJdbcDriver"
    jdbc_driver_library => "/home/user/mongojdbc2.3.jar,/home/user/mongo-java-driver-3.12.6.jar,/home/user/gson-2.8.6.jar"
    jdbc_user => ""
    jdbc_password => ""
    jdbc_connection_string => "jdbc:mongodb://localhost:27027/test"
    statement => "db.mycollection.find()"
  }
}
output {
  elasticsearch {
    hosts => ["http://localhost:9220"]
    manage_template => false
    index => "testing"
  }
  stdout { codec => rubydebug }
}

但是我遇到了下一个错误：

错误：Java :: Javasql :: sqlException：找不到适合的驱动程序 jdbc：mongodb：// localhost：27027 / test异常： Sequel :: DatabaseConnectionError堆栈： java.sql.DriverManager.getConnection（java / sql / DriverManager.java：689） java.sql.DriverManager.getConnection（java / sql / DriverManager.java：247）

我还尝试使用mongo本机Java驱动程序和统一的jdbc驱动程序。我还尝试使用不同版本的mongo，分别从localhost和远程服务器尝试。我尝试使用不同版本的logstash。一切都归结于此错误。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）