Elasticsearch中Java Rest客户端的批量操作

Question

我正在使用Java Rest客户端进行弹性搜索https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/index.html但找不到批量插入或更新的方法。如何与该客户进行批量操作？

Answer 1

我正在使用中的数据。json文件。

Elasticsearch版本：6.8.0

波姆。xml:

<dependencies>
    <dependency>
        <groupId>org.elasticsearch</groupId>
        <artifactId>elasticsearch</artifactId>
        <version>6.8.0</version>
    </dependency>

    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>transport</artifactId>
        <version>6.8.0</version>
    </dependency>

    <dependency>
        <groupId>commons-io</groupId>
        <artifactId>commons-io</artifactId>
        <version>2.1</version>
        <scope>test</scope>
    </dependency>
</dependencies>`

Java

String bulkContent=new String（Files.readAllBytes（new File（filePath）. toPath（）））； HttpEntity实体=new NStringEntity（bulkContent， ContentType.APPLICATION_JSON）；请求请求=createRequest（indexName， indexType， http方法，实体）； RestClient restClient=RestClient.builder（new HttpHost（主机名，端口，方案））. build（）；响应响应=restClient.perform请求（请求）；

Answer 2

如果您使用Java来处理Elasticsearch服务器，我建议您改用Java API。以下是您可以使用它的地方：https://www.elastic.co/guide/en/elasticsearch/client/java-api/current/index.html

您可以在文档API/批量API中找到如何执行批量操作。

如果出于某种原因仍然需要使用Java Rest客户端，则需要以Elasticsearch的批量请求格式构建有效负载，以便能够执行请求。

请在这里了解如何构建批量请求格式：https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-bulk.html（基本上，它是由json对象列表构建的）

Answer 3

Elasticsearch的5.2 Java Rest客户端是基于字符串的，很快就会变得一团糟。对于批量操作尤其如此，因为它们是通过链接JSON对象构建的。

如果您想/必须通过REST客户端连接到Elasticsearch集群，我建议您改用JEST客户端。

下面是一个关于如何使用JEST客户端进行批量请求的示例：

// Construct a new Jest client according to configuration via factory
JestClientFactory factory = new JestClientFactory();
factory.setHttpClientConfig(new HttpClientConfig
                       .Builder("http://localhost:9200")
                       .multiThreaded(true)
                       .build());
JestClient client = factory.getObject();

// Construct Bulk request from articles
Bulk bulk = new Bulk.Builder()
                .defaultIndex("twitter")
                .defaultType("tweet")
                .addAction(Arrays.asList(
                    new Index.Builder(article1).build(),
                    new Index.Builder(article2).build()))
                .build();

client.execute(bulk);