policyproinfo.conf 1.23 KB
input {  
    stdin {  
    }  
    jdbc {  
     
      jdbc_connection_string => "jdbc:oracle:thin:@//192.168.25.92:1521/esdb01"  
        
      jdbc_user => "graopr"  
      jdbc_password => "life12345"  
        
      jdbc_driver_library => "/data/funde/logstash-6.1.1/oraclesyc/ojdbc14-10.2.0.4.0.jar" 
       
      jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"
      jdbc_paging_enabled => "true"  
      jdbc_page_size => "1000000"
      last_run_metadata_path => "/data/funde/logstash-6.1.1/bin/synclogs/policyinfo.txt" 
      statement_filepath => "/data/funde/logstash-6.1.1/bin/policyproinfo.sql"
      schedule => "* * * * * *"  
      jdbc_default_timezone =>"Asia/Shanghai"       
       
    }  
}  
  
filter {  
    json {  
        source => "message"  
        remove_field => ["host", "@timestamp", "httpversion", "@version"]  
    }
        date{
               match => ["timestamp","yyyy-MM-dd-HH:mm:ss"]
	locale => "cn"
	}  
}

  
output {  
    elasticsearch {  
        hosts => ["http://192.168.25.81:9200","http://192.168.25.89:9200","http://192.168.25.80:9200","http://192.168.25.87:9200"] 
        index => "policyproinfo"  
        document_id => "%{po_policy_no}+%{pp_prod_seq}"
    }  
    stdout {}  
}