Hello.
I require your support with the following:
Through a database oracle from logstash, however it has not been possible to define a filter so that I do not make a complete scan to the database, you can indicate in favor how I can correct this topic.
input {
jdbc {
jdbc_driver_library => "/datos/jdbc/ojdbc6.jar"
jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"
jdbc_connection_string => "jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=XX.XX.XX)(PORT=1521)))(CONNECT_DATA=(SERVICE_NAME=DEV11G)))"
jdbc_user => "XXX"
jdbc_password => "XXX"
type => "Database"
#statement_filepath => "/datos/logstash/query/sim.sql"
statement => " select id, TRANSACTION_TYPE, msisdn, plu_chip, imsi, sale_type, plan_id, FIRST_DATE, LAST_DATE, ID_PROVIDER, STATUS, VENDOR_CHANNEL_ID from activator.transactions "
use_column_value => true
tracking_column => "id"
tags => ["activador", "SIM"]
schedule => "* * * * * *"
}
}
output {
stdout { codec => rubydebug }
#elasticsearch {
# hosts => ["XX.XX.XX)
thanks for your help