logstash批量导入Oracle关联查询的数据到Elasticsearch索引库

1.安装好logstash后，在该文件夹下的bin目录下新建文件夹conf，新建logstash导入数据启动文件，和导入数据的配置

新建要导入数据的索引 newIndex jdbc.conf

 

input { stdin { } jdbc { jdbc_connection_string => "jdbc:oracle:thin:@3.44.10.58:1533/test" jdbc_user => "haige" jdbc_password => "123456" jdbc_driver_library => "D:/lib/ojdbc6-11.2.0.3.jar" jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver" codec => plain { charset => "UTF-8"} jdbc_paging_enabled => "true" jdbc_page_size => "50000000" statement_filepath => "D:/Elasticsearch/logstash-6.5.4/bin/conf/test.sql" schedule => "12 18 * * *" type => "bp_dealer_rp" } } filter { json { source => "message