.NET 6版Azure Function v4获取Azure Table Storage全量数据的新方法

旧版本.NET及Azure Functions v2依赖的Microsoft.Azure.Cosmos.Table包已被官方弃用，当前.NET 6+环境下的Azure Functions v4需使用Azure.Data.Tables SDK（Azure SDK for Tables）操作Azure Table Storage，以下是获取表中所有数据集的标准实现方式：

步骤1：安装必要的NuGet包 #

在Function项目中安装Azure SDK的Table存储包：

Install-Package Azure.Data.Tables

或通过.NET CLI执行：

dotnet add package Azure.Data.Tables

步骤2：实现全量数据获取逻辑 #

Azure Table Storage单页查询最多返回1000条数据，需通过分页续令牌循环获取所有数据。以下是Azure Functions推荐的异步实现示例：

异步代码示例 #

using Azure.Data.Tables;
using Azure;

public static async Task<List<T>> GetAllTableEntities<T>(string connectionString, string tableName) 
    where T : class, ITableEntity, new()
{
    var tableClient = new TableClient(connectionString, tableName);
    var allEntities = new List<T>();
    string? continuationToken = null;

    do
    {
        Pageable<T> queryResult = tableClient.Query<T>(continuationToken: continuationToken);
        AsyncPageable<T> asyncQueryResult = queryResult.AsAsyncPageable();

        await foreach (Page<T> page in asyncQueryResult.AsPages(continuationToken))
        {
            allEntities.AddRange(page.Values);
            continuationToken = page.ContinuationToken;
        }
    } while (!string.IsNullOrEmpty(continuationToken));

    return allEntities;
}

同步代码示例（适用于非异步场景） #

using Azure.Data.Tables;
using Azure;

public static List<T> GetAllTableEntitiesSync<T>(string connectionString, string tableName) 
    where T : class, ITableEntity, new()
{
    var tableClient = new TableClient(connectionString, tableName);
    var allEntities = new List<T>();
    string? continuationToken = null;

    do
    {
        Pageable<T> queryResult = tableClient.Query<T>(continuationToken: continuationToken);
        foreach (Page<T> page in queryResult.AsPages(continuationToken))
        {
            allEntities.AddRange(page.Values);
            continuationToken = page.ContinuationToken;
        }
    } while (!string.IsNullOrEmpty(continuationToken));

    return allEntities;
}

关键说明 #

• 使用TableClient替代旧版CloudTable，这是Azure SDK for Tables的核心客户端类
• 通过AsPages()方法处理分页，当continuationToken为null时表示已获取全部数据
• 泛型约束ITableEntity确保实体符合Table Storage规范（需包含PartitionKey、RowKey等必要字段）

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