logstsh jdbc input

input {
    //输入源方式：jdbc
    jdbc {
      
      jdbc_connection_string => "jdbc:oracle:thin:@10.35.4.97:1521:OMS1"
      //jdbc驱动包的存放路径
      jdbc_driver_library => "/home/yarn/logstash-2.3.1/lib/ojdbc14.jar"     
      //jdbc驱动类
      jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"
      //用户名
      jdbc_user => "ypt_jk"
      //密码
      jdbc_password => "ypt_jk123"
      //调度方式：使用方式与linux crontab类似，详情可参考crontab语法
      //第一个字段：分
      //第二个字段：时
      //第三个字段：日
      //第四个字段：月
      //第五个字段：星期
      //这里的调度意思为：在11月15号10点58分 开始执行
      schedule => "58 10 15 11 *"
      //sql语句,这是导全量数据的sql：注意：语句结尾不需要加分号
      statement => "SELECT id, '' as loglevel, CONTENT AS datastr,SYSTEM AS sources,LOGFLAG AS type  ,'' AS host,RECORDDATE AS modifydate,RECORDUSER as RECORDUSER,recordyy AS remark FROM AUTO.T_AUTORUNRECORD"
    }
}


output {
    elasticsearch {
        //如果需要，指定es的id为从指定字段获取，document_id => "%{字段名}"，注意必须要保证，该字段是主键，否则，该字段值相同的数据，后录入的会覆盖先录入的数据
        document_id => "%{id}"
         //该字段默认值为logs
        document_type => "log"
        //es的信息
        hosts => ["10.35.8.23:9200"]
        //注意：index必须要小写
        index => "log_t_autorunrecord"

    }
    //将采集数据以json的格式在屏幕上输出，只是为了看的方便，可以省去
    stdout {
        codec => json_lines
    }
}