•
logstash 사용하여 ES의 인덱스에 documents 삽입할 때 사용
◦
logstash dir에서 실행하며 현재 경로는 /home/ec2-user/tools/ls 다음과 같음
◦
bin/logstash -f {name}.conf로 실행
input {
jdbc {
#logstash 구동 환경 설정
jdbc_driver_class => "com.mysql.cj.jdbc.Driver"
jdbc_driver_library => "/home/ec2-user/tools/mc/mysql-connector-java-8.0.27.jar"
#DB 접속 정보
jdbc_connection_string => "jdbc:mysql://indj-database2.cw7ggpqhhqne.ap-northeast-2.rds.amazonaws.com:3306/"
jdbc_user => "admin"
jdbc_password => "indj2020#"
#jdbc 관련 설정
jdbc_fetch_size => 500
jdbc_page_size => 500
jdbc_validate_connection => true
# 쿼리 실행문
statement => "{query}"
}
}
filter {
mutate {
add_field => { #document의 하위 문서인 field를 추가하는 항목
"pkid" => "%{idx}" #pkid를 table column인 idx로 지정
}
}
}
output {
elasticsearch {
hosts => ["localhost:9200"] #ES 서버 호스트
index => "test_v1.0.3" #삽입할 인덱스 지정
document_id => "%{pkid}" #documents id 지정
}
}
YAML
복사
현재 사용중인 logstash.conf file
