PHP使用Amazon DynamoDB Query接口报400错误：需指定KeyCondition参数

这个ValidationException的根源很明确：DynamoDB的Query操作必须指定主键相关的查询条件。Query是专门用来基于主键（分区键+可选排序键）检索数据的API，你必须通过KeyConditionExpression（官方推荐的新版参数）或者旧版的KeyConditions来定义查询规则。而你的代码里只传了TableName，完全没给查询条件，所以DynamoDB返回400 Bad Request来提示你。

下面针对你的代码给出具体的修改方案，优先推荐使用官方支持的KeyConditionExpression：

方案1：使用KeyConditionExpression（推荐） #

假设你的表的分区键是userId（数字类型），要查询userId = 123的所有记录，修改$params部分的代码如下：

$tableName = 'My Table Name';
$userId = 123;

$params = [
    'TableName' => $tableName,
    // 定义主键查询表达式
    'KeyConditionExpression' => 'userId = :userId_val',
    // 绑定表达式中的变量值，注意DynamoDB的数据类型（N代表数字，S代表字符串）
    'ExpressionAttributeValues' => [
        ':userId_val' => ['N' => (string)$userId]
    ]
];

如果你的分区键是字符串类型（比如username），只需要调整值的类型：

$params = [
    'TableName' => $tableName,
    'KeyConditionExpression' => 'username = :username_val',
    'ExpressionAttributeValues' => [
        ':username_val' => ['S' => 'john_doe']
    ]
];

要是你需要结合排序键做范围查询（比如分区键userId，排序键orderDate，查询userId=123且orderDate >= '2024-01-01'的记录），可以这么写：

$params = [
    'TableName' => $tableName,
    'KeyConditionExpression' => 'userId = :userId_val AND orderDate >= :start_date',
    'ExpressionAttributeValues' => [
        ':userId_val' => ['N' => '123'],
        ':start_date' => ['S' => '2024-01-01']
    ]
];

方案2：使用旧版KeyConditions（仅兼容旧代码，不推荐） #

如果是维护老项目，你也可以用旧的KeyConditions参数，但官方已经建议迁移到KeyConditionExpression了：

$params = [
    'TableName' => $tableName,
    'KeyConditions' => [
        'userId' => [
            'AttributeValueList' => [['N' => '123']],
            'ComparisonOperator' => 'EQ' // EQ代表等于操作
        ]
    ]
];

完整修改后的代码 #

把上面的参数替换到你的原有代码里，完整示例如下：

$sdk = new Aws\Sdk([ 
    'region' => 'my region', 
    'version' => 'latest', 
    'credentials' => [ 
        'key' => 'my key', 
        'secret' => 'my secret key' 
    ], 
    'DynamoDb' => [ 
        'region' => 'my region', 
    ], 
]);
$dynamodb = $sdk->createDynamoDb();
$marshaler = new Marshaler();
$tableName = 'My Table Name';

// 构建带查询条件的参数
$params = [
    'TableName' => $tableName,
    'KeyConditionExpression' => 'userId = :userId_val',
    'ExpressionAttributeValues' => [
        ':userId_val' => ['N' => '123']
    ]
];

try {
    $result = $dynamodb->query($params);
    // 遍历并处理查询结果
    foreach ($result['Items'] as $item) {
        // 用Marshaler把DynamoDB格式的数据转换为普通PHP数组
        $normalizedItem = $marshaler->unmarshalItem($item);
        print_r($normalizedItem);
    }
} catch (DynamoDbException $e) {
    echo "Unable to query:\n";
    echo $e->getMessage() . "\n";
}

• 一定要确保你用的主键字段名和表定义的完全一致（DynamoDB的字段名是大小写敏感的）
• 如果需要查询非主键字段，不要用Query，应该用Scan操作，但Scan性能较差，建议优先考虑创建全局二级索引（GSI）来支持非主键的高效查询
• 可以用Marshaler的marshalValue方法简化数据类型处理，比如$marshaler->marshalValue(123)会自动生成['N' => '123']，让代码更简洁

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