Cosmos DB 调用永远不会通过异步调用返回

Question

我在 WebApi 中有一个方法，该方法通过返回进程配置文件但永远不会返回的 SQL API 调用 Cosmos。任务挂起并且永远不会完成。我可以在 Debug 的 Threads 窗口中看到该任务。对同一数据库容器的其他调用运行良好。几次通话后，我必须重新启动 IIS 以清除任务。不抛出异常。我已经在有和没有尝试捕获的情况下运行它。复制到另一个控制台应用程序项目中的相同方法可以正常工作。是否存在已知的 cosmos 超时导致结果过大的问题？这应该只返回 2 个项目。实时 Cosmos DB 和本地运行的 Cosmos 模拟器的行为相同。

我正在使用最新的 Cosmos 包。

<package id="Microsoft.Azure.Cosmos" version="3.3.2" targetFramework="net472" />

构造函数

client = new CosmosClient(url, primaryKey, new CosmosClientOptions()
{
    RequestTimeout = new TimeSpan(0, 0, 20),
    ApplicationRegion = "West US 2",
    ConnectionMode = ConnectionMode.Gateway,
    GatewayModeMaxConnectionLimit = 1000,
    MaxRetryAttemptsOnRateLimitedRequests = 1000,
});

database = client.GetDatabase("MyDatabase");
container = configDatabase.GetContainer("Configs");

此方法永远不会从等待项中返回。ReadNextAsync()

public async Task<Dictionary<int, string>> GetConfigurationList()
{
   var values = new Dictionary<int, string>();
   var query = new QueryDefinition("SELECT c.ConfigId, c.ConfigDescription FROM c where c.DataSourceType='CSV'");

   var items = container.GetItemQueryIterator<(int ConfigId, string ConfigDescription )>(query);

   while (items.HasMoreResults)
   {
       FeedResponse<(int ConfigId, string ConfigDescription )> configs = await items.ReadNextAsync();

       foreach (var item in configs)
       {
            values.Add(item.ConfigId, item.ConfigDescription);
        }
    }
    return values;
}

这个方法每次都很好用

public async Task<LetterConfiguration> GetConfiguration(int id)
{
  var query = new QueryDefinition("SELECT * FROM c where c.ConfigId= @id").WithParameter("@id",id);

  var configItems = container.GetItemQueryIterator<ConfigFile>(query);

  while (configItems.HasMoreResults)
  {
     FeedResponse<ConfigFile> configs = await configItems.ReadNextAsync();
     if(configs.Count == 1)
     {
        return configs.FirstOrDefault();
     }
  }
  return null;
}

Answer 1

这最终导致调用存储库方法的控制器中缺少等待。感谢大家的意见。

Answer 2

几条建议：

1. 在调用 ReadNextAsync 时是否检查是否有异常？使用 Try...Catch

2. 为 GetItemQueryIterator 和 FeedResponse 使用类型化对象

更新：试试这个来查询选择性字段 -

            var query = new QueryDefinition("SELECT c.ConfigId, c.ConfigDescription FROM c where c.DataSourceType='CSV'");

            var items = container.GetItemQueryStreamIterator(query);


            while (items.HasMoreResults)
            {
                using (ResponseMessage response = await items.ReadNextAsync())
                {
                    using (StreamReader sReader = new StreamReader(response.Content))
                    using (JsonTextReader jsonReader = new JsonTextReader(sReader))
                    {
                        JsonSerializer jsonSerializer = new JsonSerializer();
                        dynamic values = jsonSerializer.Deserialize<dynamic>(jsonReader).Documents;
                        Console.WriteLine($"Name: {values[0].ConfigId}");
                    }
                }
            }