Logstash를 이용하여 Oracle 데이터를 ElasticSearch에 밀어넣기

1. ElasticSearch 버전 확인

 

==> localhost:9200

 

 

2. ElasticSearch와 동일 버전 Logstash 설치

 

==> Logstash 6.5.4 설치(ZIP)  

https://www.elastic.co/kr/downloads/past-releases/logstash-6-5-4

Logstash 6.5.4 | Elastic

3. 압축 해제 후 logstash-6.5.4\config 경로로 이동

 

==> logstash-sample.conf 파일 메모장이나 vsCode로 열기

 

4. Oracle과 ElasticSearch 연동 설정

 

==> 싹 지우고 아래 코드 작성

 

input {
    jdbc {
        jdbc_driver_library => "C:\Users\ehong\Desktop\logstash-6.5.4\lib\ojdbc6.jar"
        jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"
        jdbc_connection_string => "jdbc:oracle:thin:@localhost:1521/orcl"
        jdbc_user => "****"
        jdbc_password => "****"    
        statement => "SELECT * FROM EMP"
        jdbc_validate_connection => "true"
    }
}

output {
  elasticsearch {
    hosts => ["http://localhost:9200"]
    index => "hong-0212"
    #user => "elastic"
    #password => "changeme"
  }
}

 

5. 터미널에서 logstash-6.5.4\bin 경로로 이동 후 명령어 실행

 

==> .\logstash -r -f "../config/logstash-sample.conf"

 

6. Kibana에서 결과 확인