mongodb - 在Logstash管道中将mongodb _id对象转换或转换为字符串

Question

我正在创建一个管道，以使用Logstash将数据从MongoDB获取到ElasticSearch。
我正在使用dbschema mongodb jdbc驱动程序。我可以使用驱动程序连接到数据库，但是我遇到了_id的问题。就像在MongoDB中一样，它的类型为object。这是我遇到的错误。

Exception when executing JDBC query {:exception=>#<Sequel::DatabaseError: Java::OrgLogstash::MissingConverterException: Missing Converter handling for full class name=org.bson.types.ObjectId, simple name=ObjectId>}

我的管道如下:

input{
jdbc{
jdbc_driver_library => "C:/logstash-6.1.0/logstash-6.1.0/bin/driver/mongo/dbschema/mongojdbc1.2.jar"
jdbc_driver_class => "Java::com.dbschema.MongoJdbcDriver"
jdbc_connection_string => "jdbc:mongodb://abc.com:27017/test"
jdbc_user => ""
statement => "db.getCollection('Employee').find({})"
codec => json
}
}

output {
elasticsearch {
hosts => 'http://localhost:9200'
index => 'mongodbschema'
codec => json   
}
stdout { codec => rubydebug }
}

有什么办法可以转换/广播或在过滤器中执行某些操作以将_id的数据类型从对象更改为字符串

Answer 1

尝试

statement => "db.getCollection('Employee').find({ },{'_id': false})"