使用JDBC输入插件解析Logstash输入中的PostgresSQL数据时出错

编程问答 2022-06-11

问题描述

我有一个带有三列表的Postgres DB。表结构为：

  • id BIGSERIAL
  • 输入CUSTOM_ENUMERATION
  • 预设JSONB

CUSTOM ENUMERATION是我创建的自定义枚举。

我想从表中获取数据，并通过JDBC输入过滤器通过Logstash放入elasticsearch。

JDBC过滤器：

jdbc { 
      # Postgres jdbc connection string to our database,mydb
      jdbc_connection_string => "jdbc:postgresql://XXXXXXXXXXXXXXXXXXXXXX"
      # The user we wish to execute our statement as
      jdbc_user => "postgres"
     # The path to our downloaded jdbc driver
     jdbc_driver_library => "/var/lib/postgresql-42.2.16.jar"
     # The name of the driver class for Postgresql
     jdbc_driver_class => "org.postgresql.Driver"
     # our query
     statement => "SELECT id,type::text,preset::text from devices_types"
     schedule => "* * * * *"
     type => "device_types"
}

运行logstash时，出现以下错误：

logstash_1       | [2020-10-01T09:11:00,492][WARN ][logstash.inputs.jdbc     ][main][588d8e1da8fde06883e09c230dd4fdcd8a0f396cb7b4c94588e36857454a9a61] Exception when executing JDBC query {:exception=>"Java::OrgLogstash::MissingConverterException: Missing Converter handling for full class name=org.postgresql.util.PGobject,simple name=PGobject"}

如何解决此错误？

解决方法

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

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

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

jdbclogstashlogstash-jdbc