Как указать имя схемы в конфигурационном входе Logsta sh для postgreSQL? - PullRequest
Новая
       79

Как указать имя схемы в конфигурационном входе Logsta sh для postgreSQL?

0 голосов
/ 04 марта 2020

Для конфигурации ниже: 

{
input {
    jdbc {
    jdbc_validate_connection => true
        jdbc_connection_string => "jdbc:postgresql://127.0.0.1:5433/Wallet_DB"
    jdbc_user => "postgres"
    jdbc_password => "postgres"
    jdbc_driver_library => "D:/softwares/logstash-7.6.0/logstash-core/lib/jars/jdbc-postgresql.jar"
    jdbc_driver_class => "org.postgresql.Driver"
    statement => "SELECT * FROM mySchema.customer_wallet_details"
    }
}

Я получаю ошибку: 

[ERROR][logstash.inputs.jdbc     ][main] Java::OrgPostgresqlUtil::PSQLException: ERROR: relation "mySchema.customer_wallet_details" does not exist: SELECT * FROM mySchema.customer_wallet_details
[WARN ][logstash.inputs.jdbc     ][main] Exception when executing JDBC query {:exception=>#<Sequel::DatabaseError: Java::OrgPostgresqlUtil::PSQLException: ERROR: relation "mySchema.customer_wallet_details" does not exist>}

Я видел пример sql для того же в документации, но это просто не работает.

Пожалуйста, руководство!

...