如何通过 JSON 将查询设置为 Elasticsearch SearchRequest？

Question

弹性搜索：6.1.2

我有一个通过 JSON 的输入查询，我想使用 high level Java API 使用该查询数据构建一个搜索请求。

String jsonQuery = "..."
SearchRequest searchRequest = new SearchRequest()
SearchSourceBuilder builder = ?
searchRequest.source(builder);

我试图通过以下方式构建生成器：

SearchSourceBuilder.fromXContent(XContentType.JSON.xContent().createParser(NamedXContentRegistry.EMPTY, query));

但这会产生：

Caused by: org.elasticsearch.ElasticsearchException: namedObject is not supported for this parser at org.elasticsearch.common.xcontent.NamedXContentRegistry.parseNamedObject(NamedXContentRegistry.java:129) ~[elasticsearch-6.1.2.jar:6.1.2] at org.elasticsearch.common.xcontent.support.AbstractXContentParser.namedObject(AbstractXContentParser.java:402) ~[elasticsearch-6.1.2.jar:6.1.2] at org.elasticsearch.index.query.AbstractQueryBuilder.parseInnerQueryBuilder(AbstractQueryBuilder.java:313) ~[elasticsearch-6.1.2.jar:6.1.2] at org.elasticsearch.search.builder.SearchSourceBuilder.parseXContent(SearchSourceBuilder.java:1003) ~[elasticsearch-6.1.2.jar:6.1.2] at org.elasticsearch.search.builder.SearchSourceBuilder.fromXContent(SearchSourceBuilder.java:115) ~[elasticsearch-6.1.2.jar:6.1.2]

Answer 1

在 createParser 方法中将第一个参数 NamedXContentRegistry.EMPTY 替换为 JsonXContent.jsonXContent

Answer 2

我现在以这种方式生成 SearchSourceBuilder：

String query = "..."
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
SearchModule searchModule = new SearchModule(Settings.EMPTY, false, Collections.emptyList());
try (XContentParser parser = XContentFactory.xContent(XContentType.JSON).createParser(new NamedXContentRegistry(searchModule
            .getNamedXContents()), query)) {
    searchSourceBuilder.parseXContent(parser);
}

Answer 3

我也遇到了同样的问题。我们一直在从 ES 1.4.4 更新到 ES 6.4.2，我使用了 ES 提供的 Java High Level Rest Client 在 ES 中进行 create/update/delete 操作。我找不到使用高级 Rest 客户端将上一个 ES 版本中使用的查询 JSON 转换为适当的 searchRequest 的简单方法。下面是我最终使用的。

import org.elasticsearch.client.Response;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.Request;

public static Response executeGetRequest(RestHighLevelClient client,
            String api, String body) throws Exception {

            Request request = new Request("GET", api);
            if(body != null && !body.isEmpty()) {
                request.setJsonEntity(body);
            }            
            Response response = client.getLowLevelClient()
                    .performRequest(request);
            if (response == null) {
                throw new Exception(
                        "Get request have failed");
            }
            return response;        
    }

如何通过 JSON 将查询设置为 Elasticsearch SearchRequest？

How to set the query via JSON to an Elasticsearch SearchRequest?

elasticsearch

elasticsearch-java-api