AWS C# SDK DynamoDB QueryAsync调用报错及QueryAsync、ScanAsync使用方法

你混淆了AWS DynamoDB C# SDK的两层API的使用方式：
DynamoDBContext属于高级ORM层API，它的QueryAsync<T>方法第一个参数要求传入分区键的实际值（你的场景是string类型的PK值），而你传入了属于低级原生API的QueryRequest对象，SDK尝试将QueryRequest对象转换为string类型的分区键值，因此抛出类型转换异常。

提供两种可行的修改方式，根据你的业务需求选择即可：

方式1：使用DynamoDBContext高级API（推荐写法） #

不需要手动构建QueryRequest，直接传入键值即可，ORM会自动处理参数映射和结果解析：

// 直接传入PK值、SK的匹配条件即可
var res = context.QueryAsync<DataModelSchema>(
    hashKeyValue: "ORG#prueba2",
    operator: QueryOperator.Equal,
    sortKeyValue: "EMP#prueba2"
).GetRemainingAsync().GetAwaiter().GetResult();

foreach(var item in res)
{
    Console.WriteLine(item);
}

方式2：使用IAmazonDynamoDB低级原生API #

如果你需要使用自定义的QueryRequest配置复杂查询逻辑，直接用初始化好的client对象调用方法，再手动转换结果：

var request = new QueryRequest
{
    TableName = "happy-projects",
    KeyConditionExpression = "PK = :PK and SK = :SK",
    ExpressionAttributeValues = new Dictionary<string, AttributeValue> 
    {
        {":PK", new AttributeValue { S =  "ORG#prueba2" }},
        {":SK", new AttributeValue { S = "EMP#prueba2" }}
    }
};
// 用底层client调用QueryAsync
var response = client.QueryAsync(request).GetAwaiter().GetResult();
// 将返回的原始属性集合转换为实体对象
var res = response.Items.Select(attrMap => 
    context.FromDocument<DataModelSchema>(Document.FromAttributeMap(attrMap))
).ToList();

foreach(var item in res)
{
    Console.WriteLine(item);
}

AWS C# SDK提供两层DynamoDB操作API，两类API下的QueryAsync、ScanAsync用法差异较大：

两层API的区别 #

• 低级原生API：挂载在IAmazonDynamoDB接口下，需要手动构造请求对象、处理参数、解析结果，灵活性最高，适合复杂查询场景
• 高级ORM API：挂载在DynamoDBContext类下，基于实体类的特性注解自动完成参数映射、结果序列化，写法简洁，适合绝大多数业务场景

QueryAsync用法 #

Query是针对性查询操作，必须指定分区键的值，性能远高于Scan，支持搭配排序键条件做范围查询。

高级API使用要点 #

• 第一个参数必填，为分区键的实际值，类型要和实体类定义的分区键类型一致
• 可选传入排序键查询操作符（Equal/LessThan/GreaterThan/Between等）和对应的值
• 可选传入DynamoDBOperationConfig配置索引名、一致性读取、后置过滤条件等
• 调用GetRemainingAsync()可自动处理分页，一次性返回所有匹配结果

低级API使用要点 #

• 手动构建QueryRequest，必填参数为TableName、KeyConditionExpression
• 用ExpressionAttributeValues传递查询参数，避免注入风险
• 返回结果的Items属性为原始属性字典，需要自行转换为业务实体

ScanAsync用法 #

Scan是全表扫描操作，会遍历表内所有数据，性能差、成本高，非必要不建议使用，仅适合小表全量读取、或者无法通过Query满足的特殊场景。

高级API使用要点 #

• 无参数调用ScanAsync<T>()可直接读取全表数据
• 可选传入ScanCondition列表添加后置过滤条件，注意过滤是扫描全表后再执行，不会降低扫描的资源消耗
• 同样支持通过DynamoDBOperationConfig配置额外参数

低级API使用要点 #

• 手动构建ScanRequest，必填参数为TableName
• 可选设置FilterExpression添加后置过滤条件，设置Limit控制单次扫描返回的数据量
• 大表扫描需要处理LastEvaluatedKey做分页，避免单次返回数据量过大引发性能问题

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