Untitled

#/etc/logstash/logstash.conf
input {
  jdbc {
    jdbc_driver_library => "/var/lib/sqoop/ojdbc7.jar"
    jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"
    jdbc_connection_string => "jdbc:oracle:thin:@db:1521/lg_database"
    jdbc_user => "dbuser"
    jdbc_password => "dbpw"
    schedule => "/5 * * * *"
    statement_filepath => "/etc/logstash/packagemetrics.sql"
    type => "ProdDB"
    tags => ["import", "pkgmetrics", "ProdDB"]
  }
}

output {
  stdout { codec => rubydebug }
  elasticsearch {
    hosts => "x.x.x.x:9200"
  }
}

#/etc/logstash/packagemetrics.sql
SELECT DISTINCT
  dq.ID,
  dq.file_size,
  dq.description,
  username,
  dq.modified_date,
  dq.created_date,
  (dq.modified_date - dq.created_date) AS create_time,
  dqis.int_status
FROM
  meta.user_download_queue dq,
  meta.DOWNLOAD_QUEUE_INIT_STATUS dqis,
  meta.ndar_user nu
WHERE
  dqis.status_id = dq.int_status
AND NU.ID        = dq.CREATED_BY
AND dq.created_date >= sysdate - 7
AND dqis.int_status is not NULL
ORDER BY
  dq.ID DESC