input {
jdbc {
jdbc_connection_string => "jdbc:postgresql://db.coa.interno.trans.com.br:7432/trans"
jdbc_user => "ana"
jdbc_password => "Hbt"
jdbc_driver_library => "/usr/share/logstash/vendor/jar/jdbc/postgresql-42.2.24.jar"
jdbc_driver_class => "org.postgresql.Driver"
schedule => "* * * * *"
statement => "SELECT oid_conhecimento, oid_nota_fiscal FROM nota_fiscal_conhecimento where oid_nota_fiscal = 489041"
tracking_column => "oid_conhecimento"
use_column_value => true
tracking_column_type => "numeric"
last_run_metadata_path => "/usr/share/logstash/.logstash_jdbc_last_run"
}
}
output {
jdbc {
connection_string => "jdbc:postgresql://10.0.0.20:5432/trans_tms?user=postgres&password=Linc"
driver_class => "org.postgresql.Driver"
statement => "INSERT INTO nota_fiscal_conhecimento (oid_conhecimento, oid_nota_fiscal) VALUES (?, ?)"
}
}
is showing the error
Logstash is reporting an error when trying to insert data into a database table using JDBC output. It appears that the error is related to the fact that no value is being specified for parameter 1 in the SQL statement.
[2024-04-09T21:17:00,617][ERROR][logstash.outputs.jdbc ][main][41df2148178963aff4526348b707c622dedd50c29a7ea64fb00c58248f4c5fa7] JDBC - Exceção. Não está tentando novamente {:exception=>#<Java::OrgPostgresqlUtil::PSQLException: Nenhum valor especificado para o parâmetro 1.>, :statement=>"INSERT INTO nota_fiscal_conhecimento (oid_conhecimento, oid_nota_fiscal) VALUES (?, ?)", :event=>"{"@timestamp":"2024-04-09T21:17:00.353381368Z","oid_nota_fiscal":489041,"oid_conhecimento":366304,"@version":"1"}"}
there are some empty columns but I need to record the data anyway, just avoiding duplication
please help me