logstash从oracle12c导入数据到elasticsearch

在logstash的config中添加配置信息

cd logstash-5.2.0/config/

vim 12ctoEs.conf

input {
jdbc {
jdbc_driver_library => "/hadoop/logstash-5.2.0/ojdbc8.jar"
jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"
jdbc_connection_string => "jdbc:oracle:thin:@192.168.100.20:1521/orclpdb"
jdbc_user => "test"
jdbc_password => "test"
jdbc_paging_enabled => "true"
jdbc_page_size => "50000"
statement => "select id,name,age from sys.test1"
}
}
filter {
mutate {
remove_field => ["@version","@timestamp"]
}
}
output {
elasticsearch {
hosts => "http://192.168.100.10:9200"
index => "test1"
document_id => "%{id}"
document_type => "test1"
}
}

##执行命令

 cd ../bin/
 ./logstash -f ../config/12ctoEs.conf