azure - 返回 Windows Azure 表查询的 1000 多个实体

Question

我的问题正是this one 。但是，Azure 存储 API 已更改，我可以找到的此问题的所有答案都涉及旧版本。在当前 API 版本中如何处理返回超过 1000 个项目的查询？获取少于 1000 个项目的查询如下所示:

var query = new TableQuery<TermScoreEntity>()
            .Where(TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal,    Name));

var table = _tableClient.GetTableReference("scores");

foreach (var termScoreEntity in table.ExecuteQuery(query))            
    result.Add(termScoreEntity.RowKey, termScoreEntity.Score);

Answer 1

您是否尝试过使用上述代码检索超过 1000 个实体？我认为使用简单ExecuteQuery就够了。

文档只说它对纯 REST 请求有 1,000 限制，即 ExecuteQuery API内部使用这个rest api，但是自动切分成多个请求，每个请求有1,000的限制。

因此，如果您使用 .NET 包，则无需担心此限制，该库已经为您处理了此问题。可以引用这个thread了解更多信息。

这是 ExecuteQuery 的一些关键代码从Azure SDK中，你会发现实际上最大数量是9223372036854775807L如果您不指定 take数量:

internal IEnumerable<DynamicTableEntity> Execute(CloudTableClient client, CloudTable table, TableRequestOptions requestOptions, OperationContext operationContext)
{
  CommonUtility.AssertNotNullOrEmpty("tableName", table.Name);
  TableRequestOptions modifiedOptions = TableRequestOptions.ApplyDefaults(requestOptions, client);
  operationContext = operationContext ?? new OperationContext();
  return CommonUtility.LazyEnumerable<DynamicTableEntity>((Func<IContinuationToken, ResultSegment<DynamicTableEntity>>) (continuationToken =>
  {
    TableQuerySegment<DynamicTableEntity> local_0 = this.ExecuteQuerySegmented((TableContinuationToken) continuationToken, client, table, modifiedOptions, operationContext);
    return new ResultSegment<DynamicTableEntity>(local_0.Results)
    {
      ContinuationToken = (IContinuationToken) local_0.ContinuationToken
    };
  }), this.takeCount.HasValue ? (long) this.takeCount.Value : long.MaxValue);
}