关系型数据库导入es插件推荐

附上配置文件  

input{

   jdbc{

     jdbc_connection_string => "jdbc:oracle:thin:@//127.0.0.1:1521/appsync"

     jdbc_user => "root"

     jdbc_password => "123"

     jdbc_driver_library => "/usr/local/logstash-5.3.0/input-jdbc/ojdbc14.jar"

     jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"

     record_last_run => "true"

     use_column_value => "true"

     tracking_column => "GXSJ"

     tracking_column_type => timestamp

     jdbc_paging_enabled => "true"

     jdbc_page_size => "150000"

     statement_filepath => "/usr/local/logstash-5.3.0/input-jdbc/vio.sql"

     schedule => "54 11 * * *"

     type => "vio_type"

     lowercase_column_names => false

     last_run_metadata_path => "/usr/local/logstash-5.3.0/input-jdbc/logstash_jdbc_last_run"

   }

}

output{

     elasticsearch{

       hosts => "127.0.0.1:9200"

       index => "vio_2017"

       document_id => "%{WFBH}"

}

     stdout{

       codec => json_lines

     }

}

SELECT * FROM

TRFF_APP.VIO_VIOLATION WHERE to_timestamp(to_char(GXSJ, 'YYYY-MM-DD HH24:mi:ss'),'yyyy-MM-dd hh24:mi:ss:ff9') > :sql_last_value