如何在 Java 中使用 Elasticsearch 摄取附件处理器插件

Question

我正在寻找一种从 Java 高级 REST 客户端使用 Ingest Attachment Processor Plugin 的方法。

您似乎需要做两个步骤，即首先定义一个包含附件处理器的管道（例如，引用字段 data 并使用管道 id attachment em>)

PUT _ingest/pipeline/attachment
{
  "description" : "Extract attachment information",
  "processors" : [
    {
      "attachment" : {
        "field" : "data"
      }
    }
 ]
}

然后你 PUT 引用字段的数据（这里是 data）和管道（这里是 attachment）

PUT my_index/my_type/my_id?pipeline=attachment
{
  "data": "e1xydGYxXGFuc2kNCkxvcmVtIGlwc3VtIGRvbG9yIHNpdCBhbWV0DQpccGFyIH0="
}

现在我想从 Java 高级 REST 客户端执行这两个步骤。看来我可以使用Put Pipeline API 执行第一步（定义管道），但我找不到第二部分的 Java 机制，即在引用管道的同时写入实际数据。

Answer 1

在Java高级REST客户端中有一个使用IndexRequest索引的方法，在创建它的过程中，您可以通过Java方法设置管道。

JavaDoc 参考 - https://artifacts.elastic.co/javadoc/org/elasticsearch/elasticsearch/7.6.2/org/elasticsearch/action/index/IndexRequest.html?is-external=true#setPipeline(java.lang.String)

我希望有这样的代码：

RestHighLevelClient client = new RestHighLevelClient(
        RestClient.builder(new HttpHost("localhost", 9200, "http")));

final IndexRequest indexRequest = new IndexRequest("index-name", "index-type");
indexRequest.setPipeline("pipeline-name");

Map<String, Object> jsonMap = new HashMap<>();
jsonMap.put("data", "e1xydGYxXGFuc2kNCkxvcmVtIGlwc3VtIGRvbG9yIHNpdCBhbWV0DQpccGFyIH0=");

indexRequest.source(jsonMap);
final IndexResponse indexResponse = client.index(indexRequest);