1) host, port 주입
RestClient restClient = RestClient.builder(
new HttpHost("localhost", 9200, "http"),
new HttpHost("localhost", 9201, "http")).build();
BulkRequest.Builder br = new BulkRequest.Builder();
ElasticsearchTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper());
ElasticsearchClient esClient = new ElasticsearchClient(transport);
2) String으로 된 JSON 데이터 정의
String json = "{\"test\":1}"
Reader input = new StringReader(json);
IndexRequest<JsonData> request = IndexRequest.of(i -> i
.index("test-log") //set index
.withJson(input)
);
3) 전송
IndexResponse response = esClient.index(request);
log.info("Indexed with version " + response.version());
출처
https://www.elastic.co/guide/en/elasticsearch/client/java-api-client/7.17/indexing.html
반응형
'빅데이터 > Elasticsearch' 카테고리의 다른 글
RestHighLevelClient로 구현한 idempotence 데이터 적재 (0) | 2022.11.29 |
---|---|
엘라스틱서치에 중복 id로 값을 보내면? (0) | 2020.09.27 |
Elasticsearch, Logstash, Kibana 버젼별 하위호환표 (0) | 2020.03.26 |
엘라스틱서치에서 field 와 field.keyword 의 차이(text와 keyword) (0) | 2020.03.06 |
Python으로 elasticsearch에 document 넣기 예제 및 결과물 (263) | 2019.08.07 |