C#中使用NEST查询Elasticsearch文档时如何反序列化字段内JSON字符串

下面给出两种可直接在查询阶段完成responseBody字段反序列化的实现方式，无需后续额外循环处理：

方案1：自定义JsonConverter（推荐，无需修改ES侧配置） #

这个方案通过给DTO字段指定序列化转换器，实现查询返回时自动将字符串格式的JSON反序列化为对象。

步骤1：定义ResponseBody对应的实体类 #

// 对应responseBody里的结构
public class ResponseBodyContent
{
    public int ProgramId { get; set; }
    public TestInfo Test { get; set; }
}

public class TestInfo
{
    public int TestId { get; set; }
}

步骤2：实现字符串转对象的通用转换器 #

如果用Newtonsoft.Json，转换器写法如下：

public class StringJsonConverter<T> : JsonConverter<T>
{
    public override T ReadJson(JsonReader reader, Type objectType, T existingValue, bool hasExistingValue, JsonSerializer serializer)
    {
        // 字段是字符串格式时先反序列化
        if (reader.TokenType == JsonToken.String)
        {
            var jsonStr = reader.Value?.ToString();
            return string.IsNullOrWhiteSpace(jsonStr) ? default : JsonConvert.DeserializeObject<T>(jsonStr);
        }
        // 兼容部分文档直接存对象的场景
        if (reader.TokenType == JsonToken.StartObject)
        {
            return serializer.Deserialize<T>(reader);
        }
        return default;
    }

    public override void WriteJson(JsonWriter writer, T value, JsonSerializer serializer)
    {
        // 写入ES时序列化为字符串，和现有存储格式对齐
        writer.WriteValue(JsonConvert.SerializeObject(value));
    }
}

如果用System.Text.Json，仅需调整转换器基类和序列化API即可，逻辑完全一致。

步骤3：修改原有DTO定义 #

给TransactionsElasticDto的ResponseBody字段加上转换器属性：

public class TransactionsElasticDto
{
    public long ConsumerId { get; set; }
    public DateTime CreatedDate { get; set; }
    // 绑定自定义转换器
    [JsonConverter(typeof(StringJsonConverter<ResponseBodyContent>))]
    public ResponseBodyContent ResponseBody { get; set; }
}

调整完成后原有SearchAsync查询代码无需任何修改，返回结果里的ResponseBody已经是反序列化完成的对象。

方案2：ES侧Ingest Pipeline预处理 #

如果可以操作Elasticsearch集群配置，也可以通过内置的JSON处理器在查询时提前解析字段。

步骤1：创建预处理Pipeline #

在Kibana Dev Tools执行如下命令创建Pipeline：

PUT _ingest/pipeline/parse_response_body
{
  "processors": [
    {
      "json": {
        "field": "responseBody",
        "target_field": "responseBody",
        "ignore_failure": true
      }
    }
  ]
}

步骤2：查询时指定Pipeline #

修改原有查询代码，增加Pipeline指定参数即可：

var searchResponse = await elasticClient.SearchAsync<TransactionsElasticDto>(s => s
    .Size(1000)
    .Query(q => q
        .DateRange(r => r
            .Field(f => f.CreatedDate).GreaterThanOrEquals(startDate).LessThan(endDate))
    )
    .Scroll("30s")
    .Pipeline("parse_response_body") // 新增这行指定预处理Pipeline
);

该方案下TransactionsElasticDto的ResponseBody直接定义为ResponseBodyContent类型即可，无需额外加转换器。

两种方案均可完全省去后续单独循环反序列化的逻辑，推荐优先选择方案1，不依赖ES侧配置，适配性更强。

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