c# - 如果不使用 AsPages()，TableClient.Query 将发出多少个请求？

Question

我有一个关于 Pageable< T > 的问题在 C# 中。我在 Azure 命名域中有表存储。我正在使用 Azure.Data.Tables nuget 包，并查询我正在使用的所有域:

 var domains = _localDomainTableClient
                .Query<Domain>()
                .AsPages()
                .SelectMany(d => d.Values);

但我不明白一些事情。如果我使用 Query< T > 而不使用 AsPages 方法会怎样？

IEnumerable<Domain> domainsPAges = tableClient.Query<Domain>();

我知道AsPages()返回页面集合。例如，如果表中有 10000 个项目，Query<Domain>().AsPages()应该向表发出 10 个请求，并返回 10 页，每页包含 1000 个项目(除非我更改了默认值)，但我不明白如果我不使用 AsPages() ? 到底会发生什么

示例:

IEnumerable<Domain> domainsPAges = tableClient.Query<Domain>(); 

Query<Domain>()返回Pageble< T >但是，它会再次向表发出 10 个请求，还是会获取所有元素直到内存溢出(默认情况下为 4 MB)，还是一次获取所有元素？

我检查documentation ，但我找不到我需要的东西。

A collection of values that may take multiple service requests to iterate over.

A collection of values retrieved in pages

这到底是什么意思？

感谢您的帮助。

Answer 1

How many requests Query will make, if AsPages() is not used?

在 C# 中，查询方法是 Azure Cosmos DB SDK 的一部分。

Query<T>方法将在对数据库的单个请求中检索所有匹配结果。此行为称为单分区查询。

如果查询涉及多个分区，则 Query 方法将发出多个请求来检索所有匹配的结果。确切的请求数量取决于涉及的分区数量和结果集的大小。

如果AsPages()不使用方法，那么查询结果将作为单个可枚举对象返回。如果AsPages()使用方法时，查询结果将作为页面序列返回，每个页面包含查询结果的子集。在这种情况下，发出的请求数量将取决于每个页面的大小以及符合查询条件的结果总数。

What if i use Query< T > without AsPages method

在 C# 中，如果使用 Query<T>如果没有 AsPages 方法，您将一次性收到所有查询结果。

Query<T>方法返回一个表示查询结果的 IEnumerable。如果不使用AsPages，整个结果集将立即加载到内存中。这会导致内存使用率较高，并且性能可能会下降，因为它会消耗大量内存。

AsPages 方法还使您能够以更有效的方式检索结果。它允许您以较小的批处理或页面检索结果，这有助于减少内存使用并提高性能。 AsPages 方法返回 IAsyncEnumerable<Page<T>> ，其中每个页面代表一页结果。

Query() return Pageble< T > but, does it make 10 requests to the table again or does it take all the elements until the memory overflows (4 MB by default) or take all the elements at once?

Query() 的行为取决于方法的实现和底层数据库系统。

当您执行返回可分页结果的查询时，数据库将执行查询并根据页面大小和当前页码仅将结果的子集返回给应用程序。其余结果将在后续页面的后续请求中检索。

所以如果你打电话Query<Domain>()对于特定的页面大小，它只会检索该页面大小中指定的元素数量，而不是表中的所有元素。

对表发出的请求数量取决于返回所有查询结果所需检索的页面数量。

用于存储检索结果的内存将取决于检索对象的大小以及每个页面中检索对象的数量。使用可分页结果时，通常会限制返回对象的大小以减少内存使用量，因此内存使用量不太可能超过默认的 4 MB 限制。

有关更多信息，请参阅此 Query table entities和 SO Thread.