Elasticsearch 7-使用Kibana的原始JSON进行查询

Question

最近，我开始在Java后端使用Elasticsearch（7.6.x）（我基本上是ES的初学者），我有一个一般性的问题，我搜索了这个问题，但没有找到答案：

我的工作流程如下：

>

我打开kibana的开发工具控制台，想出一个要搜索的查询。因为语法对我来说是新的，所以需要一些时间。

然后我的DAO-s中有了RestHighLevelClient。我正试图将我在kibana中创建的查询“翻译”给众多的构建者，用java API构建一个查询。显然，这也需要一些努力。

所以我想知道是否有一个方便的API允许我通过Java API直接在ElasticSearch上执行我在步骤1中准备的JSON查询。如果存在，我可以使用一些模板引擎来填充占位符，并使用应用的占位符解析执行编译后的模板。我认为这种方法有很大的优势，因为它可以让我完全绕过我的步骤“2”。。。

Kibana中的查询示例：

GET telemetry/_search
{
  
  "aggs": {
    "value": {
      "histogram": {
        "field": "value",
        "interval": 50
      }
    }
  }
} 

因此，我可以将json文件存储在我的src/main/resources或其他文件中，因为“interval”是一个参数，所以它可能看起来像这样：

{
  
  "aggs": {
    "value": {
      "histogram": {
        "field": "value",
        "interval": {{interval_param}}
      }
    }
  }
} 

然后模板引擎将编译查询（只能执行一次，但它与问题并不真正相关），查询json可以直接执行：

TemplateEngine engine ...
String query = engine.compile(json_resource).execute(Map.of("interval_param", 50))
API_THAT_IM_LOOKING_FOR.executeQuery(query, "telemetry")

如果存在这样的API，这种方法的“正反”是什么？与Java API相比，它的性能会更低吗？它会有一些与安全相关的约束（比如SQL注入等）？

Answer 1

您可以使用Java低级REST客户端，并通过以下方法直接将查询正文作为字符串传递：

request.setJsonEntity("{\"json\":\"text\"}");

一般来说，低级REST客户端应该更快一些，因为它不会序列化请求或解析响应。缺点是需要额外的代码，这些查询字符串可能更难维护。也就是说，我知道您更喜欢直接将查询体作为字符串传递，因为高级rest客户机有点不直观，而且设计过度。

低级REST客户端为您提供了跨可用节点和故障切换机制的负载平衡，高级REST客户端在后台使用它。

您也可以使用任何HTTP客户端直接与Elasticsearch实例对话。我曾经在一个c#项目中工作，在我们意识到高层带来的开销之后，我们就这样做了。NET客户端是认真的，因为它使用了大量的反射。然后，您必须实施自己的负载平衡或故障切换策略。