How to index array of objects in elastic search using rest API in Java

Question

I'm using ES 7.5.1 for storing data, with Rest API (Spring-boot). It's working fine with a single object but when I tried to pass an array of objects it's throwing bad request or not acceptable error(406).

Code:

List<UserBean> objectList;
String response = restTemplate.postForObject("http://localhost:9200/employeedata/users", objectList, String.class);

this information provided is not sufficient for helping, please give share more information. — Yash Tandon
– Yash Tandon, Commented Jan 2, 2020 at 12:32
Thanks for your quick response, I'm new to elastic search please specify what information is required. — Pramod H G
– Pramod H G, Commented Jan 2, 2020 at 13:02

Alex Baidan · Accepted Answer · 2020-07-13 13:33:50Z

1

You need to use Bulk API. Docs This API accepting arrays of objects in JSON (NDJSON) structure.

Performs multiple indexing or delete operations in a single API call. This reduces overhead and can greatly increase indexing speed.

edited Jul 13, 2020 at 13:33

answered Jan 2, 2020 at 13:32

Alex Baidan

1,0757 silver badges15 bronze badges

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

Comments

Pramod H G · Accepted Answer · 2020-07-13 09:59:11Z

We can index bulk data into elastic using RestHighLevelClient

Maven dependencies:

<dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>elasticsearch-rest-high-level-client</artifactId>
        <version>${elastic.version}</version>
    </dependency>

    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>elasticsearch-rest-client</artifactId>
        <version>${elastic.version}</version>
    </dependency>

Configuration :

@Bean
protected RestHighLevelClient createInstance() throws Exception
{
    try
    {
        RestHighLevelClient restHighLevelClient = new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", "9200", "http")));
    }
    catch (Exception e)
    {
        LOG.error("Error while creating RestHighLevelClient", e);
    }
    return restHighLevelClient;
}

Usage :

@Autowired
private RestHighLevelClient restHighLevelClient;

@Override
public void storeBulkDataInElastic(List<UserBean> dataBeanList) throws IOException
{
    BulkRequest bulkRequest = new BulkRequest();
    ObjectMapper objectMapper = new ObjectMapper();
    dataBeanList.forEach(data -> {
        IndexRequest indexRequest = new IndexRequest("ElasticIndex", "ElasticType", "ElasticId").source(objectMapper.convertValue(data, Map.class));
        bulkRequest.add(indexRequest);
    });

    restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
}

Collectives™ on Stack Overflow

How to index array of objects in elastic search using rest API in Java

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