如何通过单次调用获取Azure Table Storage同分区多行键记录

当然可以通过单次调用完成同一分区内多个行键的记录获取，以下是两种可行方案：

方案1：使用TableBatchOperation批量检索 #

TableBatchOperation支持在同一分区内批量执行最多100个检索操作，所有操作会合并为单次网络请求发送。

示例代码：

var batchOperation = new TableBatchOperation();
foreach (var rk in rowKeys)
{
    batchOperation.Add(TableOperation.Retrieve<MyRecordSchema>(partitionKey, rk));
}

// 执行批量操作，返回对应结果集合
var batchResults = await table.ExecuteBatchAsync(batchOperation);

// 遍历结果处理实体
foreach (var result in batchResults)
{
    if (result.Result != null)
    {
        var record = (MyRecordSchema)result.Result;
        // 处理获取到的记录
    }
}

方案2：构造分区内的行键查询 #

通过TableQuery构造过滤条件，指定PartitionKey匹配目标分区，同时RowKey在目标行键集合中，这样也能单次请求获取所有符合条件的记录。

示例代码：

// 构造行键的过滤条件
var rowKeyFilters = rowKeys.Select(rk => TableQuery.GenerateFilterCondition("RowKey", QueryComparisons.Equal, rk));
var combinedRowFilter = TableQuery.CombineFilters(rowKeyFilters.First(), Operators.Or, string.Join($" {Operators.Or} ", rowKeyFilters.Skip(1)));

// 组合分区键过滤条件
var partitionFilter = TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, partitionKey);
var finalFilter = TableQuery.CombineFilters(partitionFilter, Operators.And, combinedRowFilter);

// 创建查询并执行
var query = new TableQuery<MyRecordSchema>().Where(finalFilter);
var queryResult = await table.ExecuteQuerySegmentedAsync(query, null);

// 获取所有匹配的记录
var records = queryResult.Results;

两种方案对比 #

• TableBatchOperation：适合精确指定少量（≤100）行键的场景，返回结果顺序与添加操作的顺序一致，能直接对应每个行键的结果。
• TableQuery：适合行键数量较多（超过100）或需要更灵活过滤规则的场景，返回结果是符合条件的实体集合，无需逐个对应行键。

内容的提问来源于stack exchange，提问作者binga58