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

8nuwlpux  于 2021-06-14  发布在  ElasticSearch
关注(0)|答案(0)|浏览(260)

我尝试使用logstash-7.6.2来同步我的mongo和elasticsearch。我使用的是dbschema jdbc驱动程序。

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驱动程序和unity jdbc驱动程序。我还尝试使用不同版本的mongo,从localhost和远程服务器上进行了尝试。我试着使用不同版本的logstash。一切都归结为这个错误。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题