使用rest客户端的Elasticsearch批量插入

Question

为了提高性能，我想批量向Elasticsearch发送文档，而不是逐个发送。我在上读过弹性批量APIhttps://www.elastic.co/guide/en/elasticsearch/client/java-api/current/java-docs-bulk.html

但是，我使用的是Elasticsearch rest客户端(https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/index.html)并且找不到任何关于如何进行批量插入的示例或文档。我所能找到的只是通过传输客户端的批量请求。

我想我必须准备请求体，如这里所述（https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-bulk.html），并将其传递给restClient的performRequest方法？有没有其他方法，例如，ES java rest客户端库中的构建器机制，使用rest进行批量插入？

Answer 1

除Val答案外的另一个示例：http://web.archive.org/web/20180813044955/http://cscengineer.net/2016/10/22/elastic-搜索批量api/

只需使用POST而不是PUT（在使用rest模板时要小心. Exchange）

Answer 2

是的，这是正确的，现在REST客户端只允许向ES发送原始REST查询，但不太复杂。弹性正在开发一个高级客户端，它将在REST客户端之上工作，允许您发送DSL查询等。

现在，您可以使用以下示例代码将文档批量发送到ES服务器：

RestClient client = ...;
String actionMetaData = String.format("{ \"index\" : { \"_index\" : \"%s\", \"_type\" : \"%s\" } }%n", index, type);

List<String> bulkData = ...; // a list of your documents in JSON strings    
StringBuilder bulkRequestBody = new StringBuilder();
for (String bulkItem : bulkData) {
    bulkRequestBody.append(actionMetaData);
    bulkRequestBody.append(bulkItem);
    bulkRequestBody.append("\n");
}
HttpEntity entity = new NStringEntity(bulkRequestBody.toString(), ContentType.APPLICATION_JSON);
try {
    Response response = client.performRequest("POST", "/your_index/your_type/_bulk", Collections.emptyMap(), entity);
    return response.getStatusLine().getStatusCode() == HttpStatus.SC_OK;
} catch (Exception e) {
    // do something
}