Azure Cosmos DB：如何忽略FeedIterator序列化失败并读取有效文档

问题核心在于默认的ReadNextAsync<T>会对整个批次的文档进行批量反序列化，只要其中一个文档序列化失败就会抛出异常，导致整个批次的有效文档都无法被保留。要实现忽略单个失败文档、继续读取其余有效文档的需求，我们可以先读取原始JSON格式的文档，再逐个尝试反序列化：

1. 将迭代器的泛型类型改为JObject（依赖Newtonsoft.Json，Cosmos SDK 3.x默认使用该序列化库），这样可以获取到每个文档的原始JSON结构，避免批量反序列化失败。
2. 遍历每个JObject，单独尝试反序列化为目标类型T，捕获单个文档的序列化异常并跳过该文档，有效文档则正常加入结果集合。

修改后的代码如下：

using Newtonsoft.Json.Linq;

public async Task<ICollection<T>> FetchAll(CancellationToken cancellationToken)
{
    var items = new List<T>();
    using var iterator = this.container.GetItemQueryIterator<JObject>();
    while (iterator.HasMoreResults)
    {
        var response = await iterator.ReadNextAsync(cancellationToken).ConfigureAwait(false);
        foreach (var jObject in response)
        {
            try
            {
                var item = jObject.ToObject<T>();
                items.Add(item);
            }
            catch (JsonSerializationException ex)
            {
                // 可在此处记录日志，比如记录失败文档的ID
                var documentId = jObject["id"]?.ToString();
                // _logger.LogError(ex, "序列化文档ID {DocumentId} 失败", documentId);
            }
        }
    }

    return items;
}

补充说明 #

• 如果项目使用的是System.Text.Json而非Newtonsoft.Json，可以将JObject替换为JsonElement，并使用JsonSerializer.Deserialize<T>(jsonElement)进行逐个反序列化。
• 该方案确保了单个文档的序列化失败不会影响整个批次的其他有效文档，同时可以针对性地记录失败文档的信息，便于后续排查问题。

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