RestHighLevelClient 批量插入

您可以使用 RestHighLevelClient 来执行批量插入操作。以下是一个示例代码，演示如何使用 RestHighLevelClient 批量插入数据：

import org.apache.http.HttpHost;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;

import java.io.IOException;

public class BulkInsertExample {
    public static void main(String[] args) {
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("localhost", 9200, "http")));

        BulkRequest bulkRequest = new BulkRequest();

        // 创建要插入的文档数据
        String document1 = "{\"title\":\"Document 1\", \"content\":\"This is document 1\"}";
        String document2 = "{\"title\":\"Document 2\", \"content\":\"This is document 2\"}";

        // 添加插入请求到批量请求中
        bulkRequest.add(new IndexRequest("your-index-name")
                .source(document1, XContentType.JSON));
        bulkRequest.add(new IndexRequest("your-index-name")
                .source(document2, XContentType.JSON));

        try {
            // 执行批量插入请求
            BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);
            
            // 处理批量响应结果
            if (bulkResponse.hasFailures()) {
                // 处理插入失败的情况
                System.out.println("Bulk request has failures: " + bulkResponse.buildFailureMessage());
            } else {
                // 处理插入成功的情况
                System.out.println("Bulk request executed successfully");
            }
        } catch (IOException e) {
            e.printStackTrace();
        }

        try {
            // 关闭 RestHighLevelClient 客户端
            client.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

请将上述代码中的 "your-index-name" 替换为您要插入数据的 Elasticsearch 索引名称。同时，确保已经正确配置好 Elasticsearch 的连接信息。