java 批量写入es

您可以使用 Elasticsearch 的 Java API 来批量写入数据。

以下是一个示例代码：

// 创建 Elasticsearch 客户端
RestHighLevelClient client = new RestHighLevelClient(
        RestClient.builder(
                new HttpHost("localhost", 9200, "http")));

// 创建批量请求
BulkRequest bulkRequest = new BulkRequest();

// 添加需要写入的数据
XContentBuilder builder = XContentFactory.jsonBuilder();
builder.startObject();
builder.field("field1", "value1");
builder.field("field2", "value2");
builder.endObject();
IndexRequest indexRequest = new IndexRequest("index_name").source(builder);
bulkRequest.add(indexRequest);

// 执行批量请求
BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);

// 关闭 Elasticsearch 客户端
client.close();

在上面的代码中，您需要将 `localhost` 和 `9200` 替换为 Elasticsearch 的主机名和端口号，将 `index_name` 替换为您要写入的索引名称，将 `field1` 和 `field2` 替换为您要写入的字段名称，将 `value1` 和 `value2` 替换为您要写入的字段值。

同时，您可以根据需要添加更多的 `IndexRequest` 对象到 `bulkRequest` 中，以实现批量写入数据的功能。