Elasticsearch 5.4 Java RestClient批量更新文档字段技术求助

Since you can’t use the Transport Client and are struggling to find RestClient docs for ES 5.4.3, let’s break this down into practical, actionable steps. The key here is leveraging Elasticsearch’s _update_by_query REST API—this has been supported since ES 5.x and works seamlessly with the RestClient, even for bulk updates across an entire index.

1. Confirm Your Dependencies #

First, make sure your project includes the correct RestClient artifacts for ES 5.4.3. If you’re using Maven, add these to your pom.xml:

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>rest-client</artifactId>
    <version>5.4.3</version>
</dependency>
<dependency>
    <groupId>org.elasticsearch</groupId>
    <artifactId>elasticsearch</artifactId>
    <version>5.4.3</version>
</dependency>

2. Initialize the RestClient #

Set up the low-level RestClient (the primary client for ES 5.x) with your cluster nodes:

import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;

RestClient restClient = RestClient.builder(
        new HttpHost("localhost", 9200, "http"),
        new HttpHost("localhost", 9201, "http") // Add other cluster nodes as needed
).build();

3. Build the Update-by-Query Request #

To update a specific field across all documents, use a Painless script (ES 5.4 supports Painless as the default scripting language). Here’s a complete example to update a field for every document in your index:

Example: Update status Field to active for All Documents #

import org.apache.http.entity.ContentType;
import org.apache.http.nio.entity.NStringEntity;
import org.apache.http.util.EntityUtils;
import org.elasticsearch.client.Response;
import java.io.IOException;
import java.util.Collections;

public void updateAllDocuments(String indexName) throws IOException {
    // Define the update logic and target all documents with match_all
    String requestBody = "{\n" +
            "  \"script\": {\n" +
            "    \"inline\": \"ctx._source.status = 'active'\",\n" +
            "    \"lang\": \"painless\"\n" +
            "  },\n" +
            "  \"query\": {\n" +
            "    \"match_all\": {}\n" +
            "  },\n" +
            "  \"conflicts\": \"proceed\" // Optional: Ignore version conflicts and continue updating\n" +
            "}";

    // Send POST request to the _update_by_query endpoint
    Response response = restClient.performRequest(
            "POST",
            "/" + indexName + "/_update_by_query",
            Collections.emptyMap(),
            new NStringEntity(requestBody, ContentType.APPLICATION_JSON)
    );

    // Print and process the response
    System.out.println("Update Status: " + response.getStatusLine());
    String responseBody = EntityUtils.toString(response.getEntity());
    System.out.println("Update Results: " + responseBody);
}

Key Details to Adjust: #

• Script Logic: Modify the inline script to fit your field update (e.g., ctx._source.view_count += 1 to increment a number, or ctx._source.new_field = 'value' to add a new field).
• Target Subset of Docs: Replace match_all with a specific query (like a term or range query) if you only need to update a subset of documents.
• Conflict Handling: The conflicts: proceed flag lets the update continue even if some documents have version conflicts—omit this if you want the operation to fail on conflicts.

4. Clean Up Resources #

Don’t forget to close the RestClient when you’re done to avoid resource leaks:

try {
    restClient.close();
} catch (IOException e) {
    e.printStackTrace();
}

Important Performance & Security Tips #

• Batch Size: For large indices, add ?scroll_size=1000 to the endpoint URL to control the number of documents processed per batch (reduces cluster load).
• Refresh: If you need updates to be immediately visible, append ?refresh=true to the request—but note this can impact cluster performance.
• Script Permissions: Verify your ES cluster allows inline scripts (check script.inline in elasticsearch.yml—it’s enabled by default in 5.4.3, but some clusters restrict this for security).

内容的提问来源于stack exchange，提问作者Rajat Khandelwal