DynamoDB多条件查询搭配LIMIT、ORDER BY的实现问题排查

• 最初使用的business_id-updated-index GSI仅以business_id为分区键、updated为排序键，type_id、partner_id不属于索引键字段。DynamoDB在该索引上执行查询时，会先匹配business_id对应的分区，再直接按updated倒序读取记录，触发Limit=1条件就立刻返回结果，不会在读取阶段校验type_id、partner_id的匹配性，因此会返回不符合筛选条件的CC记录。
• 后续创建复合分区键GSI时报错，核心原因是查询语句的WHERE子句没有提供该复合分区键的完整等值匹配条件，DynamoDB无法定位到具体查询分区，因此不支持通过ORDER BY调用排序键的有序能力。

1. 配置符合查询模式的复合GSI #

• 新建GSI时，单独新增一个字段作为索引分区键（例如命名为gsi_pk），索引排序键直接使用表现有字段updated，索引名可沿用你之前设置的business_id-type_id-partner_id-updated-index。
• 给表内所有存量、增量记录填充gsi_pk字段值，固定拼接规则为${business_id}#${type_id}#${partner_id}，拼接顺序固定即可，不需要和字段名绑定。以你提供的示例数据为例，business_id=435634652、type_id=3、partner_id=69992528的记录，gsi_pk值为435634652#3#69992528。
• 等待GSI完成全量数据回灌，确认所有记录都同步到索引后再执行查询。

注意：如果业务字段值中可能包含#，可替换为其他不会出现在字段值中的分隔符（如::），只要写入和查询时的拼接规则完全一致即可。

2. 编写匹配索引规则的查询语句 #

查询时不要分开写三个维度字段的匹配条件，直接对复合分区键gsi_pk做等值匹配，再按updated倒序取1条即可，代码示例如下：

$compositePk = $user_company_id . '#' . intval($type['id']) . '#' . $data['cvr'];
$result = $transaction_db->executeStatement([
    'Limit' => 1,
    'Statement' => "SELECT * 
    FROM \"items\".\"business_id-type_id-partner_id-updated-index\" 
    WHERE gsi_pk = '" . $compositePk . "' 
    ORDER BY updated DESC",
]);

方案有效性说明 #

• 成本极低：复合分区键等值查询时，DynamoDB可直接定位到唯一目标分区，不需要跨分区扫描。同一分区内的数据本身就按排序键updated有序存储，倒序读取第一条即为目标结果，单次查询仅消耗最低额度的读容量单位，即使表数据量增长到百万、千万级，查询成本和响应速度都不会出现劣化。
• 结果准确：同一个gsi_pk下的所有记录天然满足business_id、type_id、partner_id三个维度的筛选要求，不需要查询后二次过滤，Limit=1返回的第一条就是符合条件的最新记录。
• 无语法错误：WHERE子句已经提供了分区键的完整等值匹配条件，完全满足DynamoDB执行ORDER BY的语法要求，不会再触发之前的ValidationException报错。

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