How to insert document into ElasticSearch using RestHighLevelClient in Java Spring Boot

Question

I am developing a Spring Boot program that use RestHighLevelClient to insert document into ElasticSearch. Now I have built the configuration for the client, however, I am not sure how to insert/index. The documentation on ElasticSearch seems confusing to me..

Here is the piece of code I tried so far:

@KafkaListener(topics = "${kafka.topic}",groupId = "test")
public void receive(String message) {

    LOGGER.info(message);
    insertData(message);
    latch.countDown();
}

private void insertData(String message){
    IndexRequest request = new IndexRequest(
            "fx-rate",
            "_doc",
            "1");
    request.source(message, XContentType.JSON);
}

Egor K. · Accepted Answer · 2018-03-14 14:37:53Z

1

A RestHighLevelClient instance needs a REST low-level client builder to be built as follows:

   RestHighLevelClient client = new RestHighLevelClient(
        RestClient.builder(
                new HttpHost("localhost", 9200, "http"),
                new HttpHost("localhost", 9201, "http")));

Create an index (if it not exist)

CreateIndexRequest request = new CreateIndexRequest("twitter");

Update document:

XContentBuilder builder = XContentFactory.jsonBuilder();
builder.startObject();
{
    builder.field("updated", new Date());
    builder.field("reason", "daily update");
}
builder.endObject();
UpdateRequest request = new UpdateRequest("posts", "doc", "1")
        .doc(builder);

Use your client for send request.

P.S. es high level client

edited Mar 14, 2018 at 14:37

answered Mar 14, 2018 at 11:44

Egor K.

1716 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

Bui Hai Duong · Accepted Answer · 2022-10-05 09:56:09Z

0

If you know how to insert documents through API then this way will much more easy for you to do anything similar API (DELETE,POST,PUT...) First, you will need RestHighLevelClient and all you have to do

String index = "/s3-upload-2022.10.04/_doc/2"; <-- Your path
Request request = new Request("POST", index);  <-- Your method
request.setJsonEntity(
          "{ \"message\": \" example add insert\" }"  <-- Your request body
);

client.getLowLevelClient().performRequest(request); <-- Run Action

This will execute like how API does.

edited Oct 5, 2022 at 9:56

answered Oct 5, 2022 at 9:48

Bui Hai Duong

2713 silver badges12 bronze badges

Collectives™ on Stack Overflow

How to insert document into ElasticSearch using RestHighLevelClient in Java Spring Boot

2 Answers 2

Comments

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Related