Elasticsearch 6.5.4 Java Api批量插入

在 Elasticsearch 6.5.4 中，可以使用 Java API 批量插入数据。下面是一个示例代码：

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.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.IndexNotFoundException;
import org.elasticsearch.rest.RestStatus;

import java.io.IOException;
import java.util.List;

public class ElasticsearchBulkInsert {

    private static final String INDEX_NAME = "my_index";
    private static final String TYPE_NAME = "_doc";

    public static void bulkInsert(RestHighLevelClient client, List<String> documents) throws IOException {
        BulkRequest bulkRequest = new BulkRequest();

        for (String document : documents) {
            IndexRequest indexRequest = new IndexRequest(INDEX_NAME, TYPE_NAME);
            indexRequest.source(document, XContentType.JSON);
            bulkRequest.add(indexRequest);
        }

        try {
            BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);

            if (bulkResponse.hasFailures()) {
                // 处理错误
                for (BulkItemResponse bulkItemResponse : bulkResponse) {
                    if (bulkItemResponse.isFailed()) {
                        BulkItemResponse.Failure failure = bulkItemResponse.getFailure();
                        String id = bulkItemResponse.getId();
                        String message = failure.getMessage();
                        RestStatus status = failure.getStatus();
                        // 处理错误
                    }
                }
            }
        } catch (IndexNotFoundException e) {
            // 处理索引不存在异常
        }
    }
}

在上面的代码中，我们首先创建了一个 `BulkRequest` 对象，然后循环要插入的文档，将每个文档构造成一个 `IndexRequest` 对象，并调用 `bulkRequest.add()` 方法将其添加到 `BulkRequest` 中。最后，调用 `client.bulk()` 方法执行批量插入操作。

要注意的是，如果批量插入过程中出现错误，可以通过检查 `BulkResponse` 对象中的 `hasFailures()` 方法来判断是否存在错误。如果存在错误，可以通过遍历 `BulkItemResponse` 对象来处理每个文档的错误信息。如果在批量插入时发现索引不存在，可以捕获 `IndexNotFoundException` 异常并进行处理。