postgresql - 缺少完整类名 = org.postgresql.util.PGobject、简单名称 = PGobject 的转换器处理

Question

我的 postgres 表中有一个几何类型列。我检查了其余列是否正常工作 postgres->logstash->elasticsearch。 但是，我不确定如何转换几何类型。任何人都可以提供有关如何转换的建议吗？请帮助我。

现在这是我的 session 。

    jdbc {
    jdbc_connection_string => "jdbc:postgresql://localhost:5432/atlasdb?useTimezone=true&useLegacyDatetimeCode=false&serverTimezone=UTC&useSSL=false&useUnicode=true&characterEncoding=utf8"
    jdbc_user => "atlas"
    jdbc_password => "atlas"
    jdbc_validate_connection => true
    jdbc_driver_library => "/lib/postgres-42-test.jar"
    jdbc_driver_class => "org.postgresql.Driver"
    columns_charset => { "region_name_kr" => "UTF-8" }
    schedule => "* * * * *"
    statement => "SELECT region_id, region_name_full, boundaries_nearby from expedia_region_union_copy_jpa_test order by region_id asc limit 100"
}

stdin {
    codec => plain { charset => "UTF-8"}
}

}
filter {
    json { source => "boundaries_nearby" }
}
output {
    elasticsearch {
    hosts => [ "localhost:9200" ]
    index => "2020-05-06-wed"
    doc_as_upsert => true
    action => "update"
    document_id => "%{region_id}"
}
    stdout { codec => rubydebug }
}

https://discuss.elastic.co/t/sql-query-from-logstash-causes-an-error-pgobject/138648它似乎与这个问题重叠，但我无法从中找到线索。

这是我的示例几何数据

POLYGON ((19.969742 52.425483, 19.972195 52.424076, 19.973841 52.422807, 19.976831 52.419417, 19.976941 52.419093, 19.978737 52.414383, something else...))

我也认为这个https://discuss.elastic.co/t/missing-converter-handling-for-full-class-name-org-postgresql-util-pgobject-simple-name-pgobject/163338/3可能是一个答案。但我不太明白这个答案。

"The issue is solved by cast the json result to an string in postgres level and parse the json string in logstash."

如果有人能解释一下，请帮忙。或者请有同样问题的人解答一下。预先感谢您。

Answer 1

我在从 postgres 提取数据进行简单查询时收到了相同的错误，其中列的数据类型为 citext。

Error: "exception when executing jdbc query {:exception=>#<sequel::databaseerror: java::orglogstash::missingconverterexception: missing converter handling for full class name=org.postgresql.util.pgobject,"

将 citext 转换为 text 后错误得到解决。例如

select name::text from contact;