求助基于Azure.Data.Tables查询未知结构Table存储实体的C#代码

• 前置依赖：先安装NuGet包 Azure.Data.Tables

完整代码片段 #

using Azure.Data.Tables;
using Azure;

// 1. 初始化TableClient，替换为你的存储账号连接串、表名
var connectionString = "你的Azure存储账户连接字符串";
var tableName = "目标表名";
var tableClient = new TableClient(connectionString, tableName);

// 2. 配置查询过滤条件
// 场景1：仅查询指定PartitionKey下的所有实体
string filter = TableClient.CreateQueryFilter($"PartitionKey eq {"替换为目标PartitionKey"}");
// 场景2：查询指定PartitionKey+RowKey的单个实体，替换上面的filter即可
// string filter = TableClient.CreateQueryFilter($"PartitionKey eq {"目标PartitionKey"} and RowKey eq {"目标RowKey"}");

// 3. 执行查询，DynamicTableEntity无需提前定义实体结构，适配频繁变动的数据模型
Pageable<DynamicTableEntity> queryResults = tableClient.Query<DynamicTableEntity>(filter);

// 4. 遍历实体导出数据
foreach (DynamicTableEntity entity in queryResults)
{
    // 系统属性可直接读取
    Console.WriteLine($"PartitionKey: {entity.PartitionKey}, RowKey: {entity.RowKey}, Timestamp: {entity.Timestamp}");
    
    // 所有自定义属性都存储在Properties字典中，直接遍历即可，无需提前知道结构
    foreach (var property in entity.Properties)
    {
        Console.WriteLine($"属性名: {property.Key}, 属性值: {property.Value}, 类型: {property.Value.Type}");
        // 此处可自行实现写入文件/其他导出逻辑
    }
    Console.WriteLine("------------------------");
}

异步版本示例（推荐） #

// 异步执行查询
AsyncPageable<DynamicTableEntity> asyncResults = tableClient.QueryAsync<DynamicTableEntity>(filter);

await foreach (DynamicTableEntity entity in asyncResults)
{
    // 处理逻辑和同步版本完全一致
}

说明：TableClient.CreateQueryFilter方法会自动处理特殊字符转义，避免OData查询语法错误，比手动拼接字符串更安全。单次查询百条级数据无需额外分页处理，上述代码可直接运行。

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