使用Cosmos DB SQL API同时运行查询

Question

我遇到了一个问题，即Cosmos SDK生成一个查询，该查询的错误太多了

// A list with over 100k items
var carPositionIds = new List<CarPositionsIds>()

...

var iterator = CarContainer
.GetItemLinqQueryable<Car>(true)
.Where(x => carPositionIds.Contain(x.Id))
.ToFeedIterator();

：SQL查询文本超过了Azure CosmosDB中30720个字符的最大限制，

我知道这是因为.CONTAINS。 因此，我有一个大查询，而是将carpositionD列表分为较小的列表，并

var ListOfIds = carPositionIds.Split(10000); // Returns a IEnumerable<IEnumerable<T>>, where each list has up to 10000 items


var conTasks = new List<Task<FeedResponse<Car>>>();

foreach(var ids in listOfIds)
{
    var iterator = CarContainer
      .GetItemLinqQueryable<Car>(true)
      .Where(x => ids.Contain(x.Id))
      .ToFeedIterator();

 while(iterator.HasMoreResults)
       {
         var i = iterator.ReadNextAsync();
         conTasks.Add(i);
       {
}

await Task.WhenAll(conTasks);
    
    var cars = new List<Cars>();
    foreach(var t in conTasks)
    {
        cars.AddRange(t.Result);
    }

在每次运行此运行时同时运行许多较小的查询，我会在汽车列表中获得不同数量的汽车。如何同时运行多个查询？

Answer 1

• Thank you and glad that you have cleared the

• 在此处发布答案，以便对其他社区成员有帮助。

• 以下是分辨率步骤：

public async Task<List<Cars>> GetCarsByIds(int ids)
{
    var result = new List<Cars>();

    var iterator = CarContainer
        .GetItemLinqQueryable<Car>(true)
        .Where(x => ids.Contain(x.Id))
        .ToFeedIterator();   

    while(iterator.HasMoreResults) 
    {          
        var i = await iterator.ReadNextAsync();          
        result.AddRange(i);        
    }  

    return result;
}

//...

var conTasks = new List<Task<FeedResponse<Car>>>();  
foreach(var ids in listOfIds) {     
    conTasks.Add(GetCarsByIds(ids))
}

// Add results into array