Logstash拒绝查看postgres表

bq3bfh9z  于 2023-01-19  发布在  Logstash
关注(0)|答案(1)|浏览(175)

所以我创建了我的logstash配置文件,并在一个docker合成文件中旋转了logstash,kibana,Postgres和elasticsearch,它与我的数据库无缝连接,但它说表“产品”不存在。
[2023-01-18T14:06:00,182][WARN ][logstash.inputs.jdbc ][main][6a13cd40fa144828caae9db4ed20b978765149c99cc59d5830fa4ccad80b4017] Exception when executing JDBC query {:exception=>"Java::OrgPostgresqlUtil::PSQLException: ERROR: relation \"products\" does not exist\n Position: 15"}
"这是我的会议"

input {
    jdbc {
        jdbc_connection_string => "jdbc:postgresql://elastic-postgres-1:5432/shopdb"
        jdbc_user => "postgres"
        jdbc_password => "****"
        jdbc_driver_library => "./postgresql-42.2.27.jre7.jar"
        jdbc_driver_class => "org.postgresql.Driver"
        statement => "SELECT * FROM products;"
        schedule => "* * * * *"
    }
}

output {
    elasticsearch {
        hosts => ["http://elasticsearch:9200"]
        index => "PostgreSQL"
    }
}

当然我在创建表之前确实用conf把我的postgres链接到了logstash,但是我再次尝试重新启动容器。同样错误仍然存在,我尝试放入错误的表,想知道它是否更新了它注意到的conf,那么为什么它看不到现在已经创建和填充的表“products”呢?

6tqwzwtp

6tqwzwtp1#

尝试显式地使用您的查询中的对象架构名称,以避免此错误找不到表。
SELECT * FROM schema_name.object_name

相关问题