Azure Table 获取下一个功能？

Question

查询 Cosmos DB（表存储 API）以获取存储中的“下一个”项目的好策略是什么？“下一个”定义为上次调用未返回的前 1 个项目。上次调用返回的项目保存在内存中。使用 .NET 框架，C#。表预计可容纳大约 200 万个条目，因此不首选表扫描。:)

表存储看起来像这样：分区键（多个值的组合）：“0000/00/01/2020-01-11”。例如，行键单个 int 值 1。行包含其他字符串数据。

所以键值对（分区键和行键）如下所示。该应用程序需要大量读取，但不一定使用日志尾模式 ( https://docs.microsoft.com/en-us/azure/cosmos-db/table-storage-design-guide#log-tail-pattern ) .

0000/00/01/2020-01-11,1,aaa,x
0000/00/01/2020-01-11,2,aaa,y
0000/00/01/2020-01-11,3,aaa,z
0000/00/01/2020-01-11,4,bbb,x
0001/00/01/2020-01-11,5,aaa,x
0001/00/01/2020-01-11,6,ddd,x

（注意底部的两个实体将在不同的分区中，因此“aaa,x”存在于两个分区中）。

所以我认为查询只获得一项是

TableQuery<MyClass> query = new TableQuery<MyClass>()
                    .Where(TableQuery.GenerateFilterCondition("0000/00/01/2020-01-11", QueryComparisons.Equal, "aaa")).Take(1);

如果那是代码正确，并返回“aaa,x”如何确保后续查询得到“aaa,y”，下一次得到“aaa,z”，下一次得到“bbb,x”和下一个将在同一分区中再次获得“aaa，x”？

如果制作富对象没有意义，而是直接查询 REST API 并可能保留上次在另一个表中使用的项目和两个表之间的外部联接或其他过滤条件，我愿意设计那个方向。

谢谢！

Answer 1

根据您的其他要求，两种可能的想法：

• 通过跟踪您的最后一个行键手动遍历行
• 定义查询以获取与您的条件匹配的所有行，并利用 TableContinuationToken

您可能需要根据您的具体要求调整我示例中的过滤器，但该想法应该适合任何一种方式。

通过跟踪您的最后一个行键手动遍历行

string currentPartitionKey = "0000/00/01/2020-01-11";
string currentRowKey = "-1";

var query = new TableQuery()
    .Where(TableQuery.CombineFilters(
        TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, currentPartitionKey),
        TableOperators.And,
        // For the very first query, you may be able to omit this condition
        TableQuery.GenerateFilterCondition("RowKey", QueryComparisons.GreaterThan, currentRowKey)))
    .Take(1);

// Execute, do stuff
// Switch to next partitionKey if no results were found

定义查询以获取与您的条件匹配的所有行，并利用TableContinuationToken

代码可能如下所示：

string currentPartitionKey = "initialParitionkey";
do
{
    TableContinuationToken continuationToken = null;
    do
    {

        TableQuery query = new TableQuery()
            .Where(TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, currentPartitionKey));

        var segment = await table.ExecuteQuerySegmentedAsync(query, continuationToken,
            new TableRequestOptions { TableQueryMaxItemCount = 1 }, cancellationToken);
        continuationToken = segment.ContinuationToken;

        // process results
    }
    while (continuationToken != null)

    currentPartitionKey = getNextPartitionKey(currentPartitionKey);
}
while (currentPartitionKey != null)