爲什麼我的TakeLimit不符合TableQuery？

Question

我想用一個簡單的TableQuery從我的Azure Table中取回頂部n行。但通過下面的代碼，無論我對Take的限制如何，所有行都會被提取。

我在做什麼錯？

int entryLimit = 5; 

var table = GetFromHelperFunc(); 

TableQuery<MyEntity> query = new TableQuery<MyEntity>() 
    .Where(TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, "MyPK")) 
    .Take(entryLimit); 

List<FeedEntry> entryList = new List<FeedEntry>(); 
TableQuerySegment<FeedEntry> currentSegment = null; 

while (currentSegment == null || currentSegment.ContinuationToken != null) 
{ 
    currentSegment = table.ExecuteQuerySegmented(query, this.EntryResolver, currentSegment != null ? currentSegment.ContinuationToken : null); 
    entryList.AddRange(currentSegment.Results); 
} 


Trace.WriteLine(entryList.Count) // <-- Why does this exceed my limit? 

Answer 1

存儲SDK上的Take方法不像在LINQ中那樣工作。想象一下，你做這樣的事情：

TableQuery<TableEntity> query = new TableQuery<TableEntity>() 
       .Where(TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, "temp")) 
       .Take(5); 
var result = table.ExecuteQuery(query); 

當你開始遍歷result你最初只得到5個項目。但在下面，如果您繼續迭代result，則SDK將繼續查詢該表（並繼續查看5個項目的下一個「頁面」）。

如果我有我的表5000項，這個代碼將輸出所有5000項（和下面的SDK將做1000個請求，並獲取每個請求的5項）：

TableQuery<TableEntity> query = new TableQuery<TableEntity>() 
       .Where(TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, "temp")) 
       .Take(5); 
var result = table.ExecuteQuery(query); 
foreach (var item in result) 
{ 
    Trace.WriteLine(item.RowKey); 
} 

將下面的代碼究竟取5個項目在1個請求，並停在那裏：

TableQuery<TableEntity> query = new TableQuery<TableEntity>() 
       .Where(TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, "temp")) 
       .Take(5); 
var result = table.ExecuteQuery(query); 
int index = 0; 
foreach (var item in result) 
{ 
    Console.WriteLine(item.RowKey); 
    index++; 
    if (index == 5) 
     break; 
} 

實際上，採取（）方法設置頁面大小或「走數」（上TableQuery TakeCount屬性）。但如果你只需要5條記錄，那麼它仍然取決於你停止迭代。

在你的榜樣，您應該修改while循環停止到達TakeCount（這可以通過調用採取設置）時：

while (entryList.Count < query.TakeCount && (currentSegment == null || currentSegment.ContinuationToken != null)) 
{ 
    currentSegment = table.ExecuteQuerySegmented(query, currentSegment != null ? currentSegment.ContinuationToken : null); 
    entryList.AddRange(currentSegment.Results); 
} 

Answer 2

AFAIK存儲客戶端庫2.0曾在採取執行的錯誤。它已在Ver 2.0.4中修復。
閱讀最後的評論在http://blogs.msdn.com/b/windowsazurestorage/archive/2012/11/06/windows-azure-storage-client-library-2-0-tables-deep-dive.aspx