데이터베이스/엘라스틱서치 elasticsearch
2021.09.20
input file output mysql input { file { path => "/usr/share/logstash/test/2_minio_file.csv" start_position => "beginning" sincedb_path => "/dev/null" codec => "json" } } filter { } output { jdbc { driver_jar_path => "/usr/share/logstash/jarfile/mysql-connector-java-8.0.15.jar" driver_class => "com.mysql.jdbc.Driver" connection_string => "jdbc:mysql://mysql:3306/test_db?user=root&password=root" st..
데이터베이스/엘라스틱서치 elasticsearch
2021.09.20
input file output minio input { file { path => "/usr/share/logstash/test/2_minio_file.csv" start_position => "beginning" sincedb_path => "/dev/null" codec => "json" } } filter { } output { s3 { access_key_id => "minio" secret_access_key => "minio123" bucket => "bucketcpi" endpoint => "http://nginx:9000" additional_settings => { force_path_style => true follow_redirects => false } rotation_strate..
데이터베이스/엘라스틱서치 elasticsearch
2021.09.20
input api output elasticsearch input { http_poller { urls => { myurl => "http://api.openweathermap.org/data/2.5/weather?q=Seoul&appid=5af8b7bbeacd98abe5e5e4b84a46d520" } schedule => { cron => "*/1 * * * * UTC" } codec => "json" } } filter { mutate { copy => { "[main][pressure]" => "[main_pressure]" "[main][humidity]" => "[main_humidity]" "[main][temp_max]" => "[main_temp_max]" "[main][grnd_level..
데이터베이스/엘라스틱서치 elasticsearch
2021.09.20
input api output kafka input { http_poller { urls => { myurl => "http://api.openweathermap.org/data/2.5/weather?q=Seoul&appid=5af8b7bbeacd98abe5e5e4b84a46d520" } schedule => { cron => "*/1 * * * * UTC" } codec => "json" } } filter { mutate { remove_field => ["weather"] } ruby { code => "event.set('@timestamp', LogStash::Timestamp.new(event.get('@timestamp')+(9*60*60)))" } } output { kafka { boot..
데이터베이스/엘라스틱서치 elasticsearch
2021.09.20
input minio output file input { s3 { access_key_id => "minio" secret_access_key => "minio123" bucket => "bucketfpi" endpoint => "http://nginx:9000" additional_settings => { force_path_style => true follow_redirects => false } codec => "json" } } filter { } output { file { path => "/usr/share/logstash/test/2_minio_file.csv" } }
데이터베이스/엘라스틱서치 elasticsearch
2021.09.20
input api output minio input { http_poller { urls => { myurl => "http://api.openweathermap.org/data/2.5/weather?q=Seoul&appid=5af8b7bbeacd98abe5e5e4b84a46d520" } schedule => { cron => "*/1 * * * * UTC" } codec => "json" } } filter { } output { s3 { access_key_id => "minio" secret_access_key => "minio123" bucket => "apibucket" endpoint => "http://nginx:9000" additional_settings => { force_path_st..
데이터베이스/엘라스틱서치 elasticsearch
2021.09.20
input api output file input { http_poller { urls => { myurl => "http://api.openweathermap.org/data/2.5/weather?q=Seoul&appid=5af8b7bbeacd98abe5e5e4b84a46d520" } schedule => { cron => "*/1 * * * * UTC" } codec => "json" } } filter { } output { file { path => "/usr/share/logstash/test/0_api_file.csv" # start_position => "beginning" # sincedb_path => "/dev/null" } }
데이터베이스/엘라스틱서치 elasticsearch
2021.06.13
1. 엘라스틱서치 실행상태 확인하기 systemctl status elasticsearch 2. 엘라스틱서치 실행 상태가 아니면 실행하기 systemctl start elasticsearch 3. 엘라스틱서치 실행상태 다시 확인하기 systemctl status elasticsearch 4. 다음 명령어 입력으로 버전 확인하기 curl localhost:9200
데이터베이스/엘라스틱서치 elasticsearch
2021.06.13
1. 엘라스틱서치 실행상태 확인하기 systemctl status elasticsearch 2. test 라는 이름을 가진 인덱스 생성하기 curl -XPUT localhost:9200/test?pretty 3. 전체 인덱스 조회하기 curl -XGET localhost:9200/_cat/indices?v 4. test 인덱스 설정 조회해보기 curl -XGET localhost:9200/test?pretty 5. test 인덱스에 a라는 타입을 가지고 1번 id에 "name": "park" 이라는 도큐먼트 추가해보기 curl -XPOST localhost:9200/test/a/1?pretty -H 'Content-Type: application/json' -d ' { "name": "park" } ' ..
데이터베이스/엘라스틱서치 elasticsearch
2021.06.11
1. 인덱스 전체 확인하기 curl -XGET localhost:9200/_cat/indices?v 2. test라는 이름을 가진 인덱스 생성하기 curl -XPUT localhost:9200/test?pretty 3. test 인덱스 상태 조회해보기 curl -XGET localhost:9200/test?pretty 4. test 인덱스의 도큐먼트 조회해보기 curl -XGET localhost:9200/test/_search?pretty 5. test 인덱스에 타입 info를 가진 1번 id에 "name": "park"이라는 도큐먼트 추가해보기 curl -XPOST localhost:9200/test/info/1?pretty -H 'Content-Type: application/json' -d ' {..
