未知分区键时，如何通过Id查询Cosmos容器并获取ItemResponse

首先，你之前的代码错误在于泛型参数使用不当：GetItemLinqQueryable的泛型类型应为实体类OrderEntity，而非ItemResponse<OrderEntity>。该方法返回的是实体的可查询集合，并非ItemResponse对象，这也是你得到空Resource的核心原因。

由于不知道分区键，必须执行跨分区查询，再从查询结果中提取ETag（Cosmos DB中ETag以_etag系统属性存储）。以下是两种可行的实现方式：

方式一：通过LINQ查询并映射ETag到实体类 #

1. 先在OrderEntity类中添加ETag属性，映射Cosmos的_etag系统字段：

using System.Text.Json.Serialization; // 或Newtonsoft.Json，根据项目序列化方式选择

public class OrderEntity
{
    public string Id { get; set; }
    // 其他业务属性...
    
    [JsonPropertyName("_etag")] // System.Text.Json使用此特性
    // [JsonProperty("_etag")] // Newtonsoft.Json使用此特性
    public string ETag { get; set; }
}

2. 执行跨分区查询并提取ETag：

var queryOptions = new QueryRequestOptions
{
    EnableCrossPartitionQuery = true, // 显式开启跨分区查询（SDK v3+默认允许，建议显式声明）
    MaxItemCount = 1 // 因ID全局唯一，仅需返回一条结果
};

var query = container.GetItemLinqQueryable<OrderEntity>(requestOptions: queryOptions)
    .Where(t => t.Id == orderId)
    .ToFeedIterator();

OrderEntity targetEntity = null;
string entityEtag = null;

while (query.HasMoreResults)
{
    var response = await query.ReadNextAsync();
    if (response.Any())
    {
        targetEntity = response.First();
        // 从FeedResponse中获取对应实体的ETag
        entityEtag = response.ResourceResponse(targetEntity).ETag;
        break;
    }
}

// 若需要构造ItemResponse对象，可手动实例化
var itemResponse = new ItemResponse<OrderEntity>(targetEntity)
{
    ETag = entityEtag,
    StatusCode = targetEntity != null ? System.Net.HttpStatusCode.OK : System.Net.HttpStatusCode.NotFound
};

方式二：使用SQL查询直接获取ETag（无需修改实体类） #

如果不想修改实体结构，可通过SQL查询直接投影_etag字段：

var sqlQuery = "SELECT c.*, c._etag FROM c WHERE c.id = @orderId";
var parameters = new QueryParameterCollection { new QueryParameter("@orderId", orderId) };

var queryOptions = new QueryRequestOptions
{
    EnableCrossPartitionQuery = true,
    MaxItemCount = 1
};

var query = container.GetItemQueryIterator<dynamic>(sqlQuery, parameters: parameters, requestOptions: queryOptions);

dynamic queryResult = null;
string entityEtag = null;

while (query.HasMoreResults)
{
    var response = await query.ReadNextAsync();
    if (response.Any())
    {
        queryResult = response.First();
        entityEtag = queryResult._etag;
        break;
    }
}

// 将动态结果转换为OrderEntity并构造ItemResponse
OrderEntity targetEntity = null;
if (queryResult != null)
{
    targetEntity = JsonConvert.DeserializeObject<OrderEntity>(JsonConvert.SerializeObject(queryResult));
}

var itemResponse = new ItemResponse<OrderEntity>(targetEntity)
{
    ETag = entityEtag,
    StatusCode = targetEntity != null ? System.Net.HttpStatusCode.OK : System.Net.HttpStatusCode.NotFound
};

关键注意事项 #

• 跨分区查询会消耗更多RU（请求单位），若频繁执行此类查询，建议重新设计数据模型，或维护ID到分区键的映射表来优化性能。
• Cosmos DB中Id仅在单个逻辑分区内唯一，若全局存在重复ID的实体，需额外处理多结果场景。

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