问题标签 [resthighlevelclient]

我正在尝试将数据插入到托管在 bonsai.io 云上的 ElasticSearch（版本 7.4.2）中。当我尝试在 Java（Java 高级 REST 客户端）的客户端代码中创建 IndexRequest 和 IndexResponse 时，IndexRequest 和 IndexResponse 都没有可用的导入。

我的 pom.xml 具有以下依赖项：

我什至尝试将以下依赖项添加到我的 pom.xml

有人可以在 7.4.2 版本中帮我解决这个问题吗？

生产环境中偶尔会出现以下异常，

但这只是一个简单的查询，而不是一个复杂的查询

在这段时间内，负载非常低

那么为什么会存在这些超时异常呢？并且有很多搜索查询但是为什么只有这个简单的query by id可能会导致这个异常？

人物索引是从Oracle DB同步的，有一个定时任务，每隔10分钟会同步变化的人物索引，如果在这段时间内访问人物索引，会导致30,000 milliseconds timeout. 那么如何解决呢？而且好像Java客户端访问会出现这种现象，而curl命令行访问则不会出现这种现象。

PS：

并且在这个时候有为人员索引写的索引

休息客户端配置：

我正在尝试在 Scala 程序中插入 ElasticSearch(ES)。

在 build.sbt 我添加了

我的代码是

编译时出现如下错误

我错过了一些进口吗？我的目标是从 Flink 获取流并插入 ElasticSearch 非常感谢任何帮助。

我正在使用弹性搜索 7.0。我有一个必须保存为弹性的模型。

当索引不存在时，我尝试将文档直接保存到弹性：

一切正常，文档将保存到弹性文件中。

但我想要一个自定义分析器，我需要更改映射类型。

所以我尝试在保存任何文档之前设置索引和映射：

但我得到错误：

我该如何解决该错误？

并且创建索引和不是所有参数的映射的计划是否正确，然后使用比创建的参数更多的参数保存文档。那么弹性会将其他缺少的参数添加到映射中还是我必须在创建索引部分中设置完整的映射？

我想对弹性进行完全匹配查询，这里是数据：

如果我使用此代码

它会得到数据，但这是不合理的

我尝试了以下2个代码

两者都返回数据，但不完全匹配

谁能帮忙！Tks

My problem is somewhat as described here. Part of Code (actually took from apache site) is as below

If I add these three statements, I am getting error as below

Error I am getting

If I do not add those import statements, I get error as below

Stackflow question I referred above, some function has been extended. My understanding is, flink.streaming.connectors.elasticsearch have to be extended into REST libraries. 1) Is my understanding correct 2) if Yes, can I have complete extensions 3)If my understanding is wrong, please give me a solution.

Note: I added the following statements in build.sbt

我是新java来的python。我知道有很多答案可以联系ElasticSearch到java。但我很难理解，有些已经过时了。在 python 中，我可以轻松导入elasticsearch模块并连接到它。

这是python中的代码：

但是在java，我已经包含了elasticsearchMaven 依赖项pom.xml。我想连接到elasticsearch. 我才知道RestHighLevelClient可以做这份工作。我找到了这段代码。但不知道如何使其连接到 Elastic Search。

任何人都可以帮助我或向我展示一些使用 java 连接 Elastic Search 的示例代码。在 python 中，它分两行完成。帮我解决java。

我正在关注这篇文章，它解释了如何使用 Java High Level REST Client (JHLRC) 与 ElasticSearch 连接。

这个问题的重要部分在ElasticsearchConfig.java中：

和ProfileService.java：

我们正在自动装配RestHighLevelClient，ObjectMapper那么 Spring 是如何知道RestHighLevelClient我们需要的实例来自哪里的ElasticsearchConfig.restClient()呢？

我正在使用 Java 批量 Api，Elasticsearch 6.6.2，并希望将批量请求发布为
POST /<index>/_bulk，
但我得到了POST /_bulk（请参阅下面捕获的数据包）。

我知道这 2 种 POST 方法是相同的，但是我的应用程序和 ES 之间有一个代理，路径参数出于某些原因用于代理（我不知道为什么）。

所以，我想知道如何在Java中设置路径参数，以便可以POST /<index>/_bulk格式发送请求。

这是代码

和捕获的数据包：

我有 ElasticSearch 查询，我通过 Kibana 获取数据。我的 Java 应用程序中也需要相同的请求。Kibana 生成的查询如下：

我正在尝试使用 ElasticSearch Java API 编写相同的查询，但得到完全不同的结果，这些结果与预期的输出完全不匹配。

你能帮我想出一个正确的吗？我现在的做法如下。

不幸的是，即使“服务”值错误，我的代码也会返回错误的结果。

您能帮我将我的 Java 请求与 JSON 对齐吗？