如何将已构建的查询字符串传入Nest客户端并用于Elasticsearch查询

可行方案 #

你完全可以将预构建的JSON查询传入NEST客户端，之前的写法不生效是因为SearchRequest的Query属性仅接收NEST封装的QueryContainer类型对象，不能直接赋值字符串。以下是两种可直接落地的修改方式：

方案1：使用NEST内置的低级客户端执行（推荐）

不需要修改你生成JSON的逻辑，直接通过ElasticClient暴露的LowLevel低级客户端接口传入原始JSON即可，适配性最高：

public long JobCount(string elasticSearchJson)
{
    var settings = new ConnectionSettings(new Uri("你的ES服务地址")).DefaultIndex("你的索引名");
    var client = new ElasticClient(settings);

    // 直接传入原始JSON执行查询
    // 泛型参数替换为你自己的文档实体类，无对应实体可填dynamic/object
    var searchResponse = client.LowLevel.Search<SearchResponse<dynamic>>(
        PostData.String(elasticSearchJson)
    );

    if (!searchResponse.IsValid)
    {
        // 按需处理查询失败逻辑
        throw new InvalidOperationException($"查询失败：{searchResponse.ServerError?.Error?.Reason}", searchResponse.OriginalException);
    }

    // 返回匹配的总文档数
    return searchResponse.Total;
}

如果仅需要统计数量不需要返回文档内容，可以将Search改为Count请求，性能更高：

var countResponse = client.LowLevel.Count<CountResponse>(PostData.String(elasticSearchJson));
return countResponse.Count;

方案2：反序列化JSON为QueryContainer后使用高级客户端

如果你需要继续使用SearchRequest对象做后续配置，可以先将JSON反序列化为QueryContainer类型再赋值：

using System.Text;

public long JobCount(string elasticSearchJson)
{
    var settings = new ConnectionSettings(new Uri("你的ES服务地址")).DefaultIndex("你的索引名");
    var client = new ElasticClient(settings);

    // 将JSON反序列化为QueryContainer
    using var stream = new MemoryStream(Encoding.UTF8.GetBytes(elasticSearchJson));
    var query = client.RequestResponseSerializer.Deserialize<QueryContainer>(stream);

    var searchRequest = new SearchRequest<dynamic>
    {
        Query = query
    };

    var response = client.Search<dynamic>(searchRequest);
    if (!response.IsValid)
    {
        throw new InvalidOperationException($"查询失败：{response.ServerError?.Error?.Reason}", response.OriginalException);
    }
    return response.Total;
}

注意事项 #

• 你原有代码中SearchRequest<string>的泛型参数不正确，需要替换为你存储在ES中的文档对应的实体类，没有对应实体可以用dynamic或object代替
• 如果你的预构建JSON已经包含了分页、排序、聚合等参数，优先使用方案1，不需要在SearchRequest中重复配置
• 注意检查你生成的JSON格式是否符合Elasticsearch的查询规范，可打印出来在Kibana Dev Tools中验证有效性

内容的提问来源于stack exchange，提问作者Chinnadurai Mani