Java API Client Bulk Response Error Handling

ravneet21 · October 26, 2023, 9:49am

Hi All,
While migrating from Elastic HighLevelRestClient to bnew Java API Client, we are facing issues in handling error scenarios in BulkResponse.
Earlier in HLRC, in BulkItemResponse, there was Failure type field, which contained RestStatus which is an enum of all the HTTP status codes. In Java API Client, we have BulkResponseItem, which has status(int) and result(string) fields, but there is no such mapping of all the rest statuses as earlier.
How should that be handled?

dadoonet · October 26, 2023, 1:20pm

Welcome!

I guess you could reuse this class in your code I believe:

github.com

elastic/elasticsearch/blob/main/server/src/main/java/org/elasticsearch/rest/RestStatus.java

/*
 * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
 * or more contributor license agreements. Licensed under the Elastic License
 * 2.0 and the Server Side Public License, v 1; you may not use this file except
 * in compliance with, at your election, the Elastic License 2.0 or the Server
 * Side Public License, v 1.
 */

package org.elasticsearch.rest;

import org.elasticsearch.action.ShardOperationFailedException;
import org.elasticsearch.common.io.stream.StreamInput;
import org.elasticsearch.common.io.stream.StreamOutput;
import org.elasticsearch.common.util.Maps;

import java.io.IOException;
import java.util.Map;

import static java.util.Collections.unmodifiableMap;

This file has been truncated. show original

And call this method:

github.com

elastic/elasticsearch/blob/main/server/src/main/java/org/elasticsearch/rest/RestStatus.java#L524-L526


      
          public static RestStatus fromCode(int code) {
              return CODE_TO_STATUS.get(code);
          }

I'm normally just using the int value on my side. Like

if (status >= 400) { 
  // Do something
}

Does this help?

system · November 23, 2023, 1:21pm

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.