java - 使用elasticsearch java客户端时如何将pdf上传到elasticsearch？

Question

这个link说明如何使用 REST API 上传附件。

但是我想用java客户端上传附件...

我认为以下类(class)是相关的(尽管我可能是错的)...

org.elasticsearch.ingest.IngestService
org.elasticsearch.ingest.PipelineStore

我意识到我可以退回到 REST 界面，但我宁愿先尝试使用 native 客户端...

Answer 1

只需在以下字段中发送 BASE64 编码的 PDF:

String base64;
try (InputStream is = YourClass.class.getResourceAsStream(pathToYourFile)) {
    byte bytes[] = IOUtils.toByteArray(is);
    base64 = Base64.getEncoder().encodeToString(bytes);
}

IndexRequest indexRequest = new IndexRequest("index", "type", "id")
   .setPipeline("foo")
   .source(
       jsonBuilder().startObject()
           .field("field", base64)
       .endObject()
   );

如果您不知道，我还链接到 FSCrawler project万一它解决了您已经想做的事情。