使用DynamoDB二级索引查询无分区键时报错‘query key condition not supported’

错误原因 #

你遇到的Query key condition not supported错误，核心是违反了DynamoDB Query操作的规则：

• 无论查询主表还是二级索引，Query必须指定分区键（Partition Key）的相等匹配条件，仅能对排序键（Sort Key）使用范围条件（比如BETWEEN）。
• 你的timeStamp-index应该是将timeStamp设为排序键，而没有在请求中指定对应分区键的条件，因此触发了这个错误。

可行解决方案 #

方案1：调整二级索引结构（推荐用于大数据量场景） #

将timeStamp设为全局二级索引（GSI）的分区键，这样可以直接用Query通过BETWEEN筛选时间范围。

• 注意：如果timeStamp的基数极高（比如毫秒级唯一值），直接作为分区键会导致每个分区仅存一条数据，影响查询性能。这种情况建议用时间分片优化：
  1. 新增一个属性（比如timePartition），格式为YYYY-MM或YYYY-MM-DD，按月份/天分片；
  2. 创建GSI，将timePartition设为分区键，timeStamp设为排序键；
  3. 查询时，先确定过去两个月对应的timePartition值，对每个分区执行Query，再合并结果。

方案2：使用Scan + FilterExpression（适合中等数据量） #

你之前对Scan的理解有误：Scan默认会遍历全表，只要处理分页（LastEvaluatedKey）就能获取所有数据。通过FilterExpression可以过滤出目标时间范围的数据：

const dateFilter = {
    ':from_time': twoMonthsAgo,
    ':to_time': todayFormatted,
};
const paramsScan = {
    TableName: JSON.parse(process.env.dynamoTables).myTable,
    ExpressionAttributeNames: { '#time': 'timeStamp' },
    FilterExpression: '#time BETWEEN :from_time and :to_time',
    ExpressionAttributeValues: dateFilter,
};

// 递归处理分页，获取全量数据
const scanAll = (params, callback, accumulator = []) => {
    this.dynamoClient.scan(params, (error, data) => {
        if (error) return callback(error, null);
        
        const allItems = [...accumulator, ...data.Items];
        if (data.LastEvaluatedKey) {
            scanAll({...params, ExclusiveStartKey: data.LastEvaluatedKey}, callback, allItems);
        } else {
            callback(null, allItems);
        }
    });
};

scanAll(paramsScan, (error, data) => {
    error ? callback(error, null) : callback(null, data);
});

• 注意：Scan会消耗较多读取容量单位（RCU），且Filter是在扫描后过滤数据，若表中大部分数据不在目标时间范围内，不推荐此方案。

方案3：使用PartiQL查询（语法更简洁） #

PartiQL支持类SQL的查询语法，可直接过滤时间范围，底层会自动适配索引（若存在合适的索引）：

const queryStmt = `SELECT * FROM "${JSON.parse(process.env.dynamoTables).myTable}" WHERE timeStamp BETWEEN ? AND ?`;
const paramsPartiQL = {
    Statement: queryStmt,
    Parameters: [twoMonthsAgo, todayFormatted]
};

// 处理分页获取全量数据
const executeAll = (params, callback, accumulator = []) => {
    this.dynamoClient.executeStatement(params, (error, data) => {
        if (error) return callback(error, null);
        
        const allItems = [...accumulator, ...data.Items];
        if (data.LastEvaluatedKey) {
            executeAll({...params, ExclusiveStartKey: data.LastEvaluatedKey}, callback, allItems);
        } else {
            callback(null, allItems);
        }
    });
};

executeAll(paramsPartiQL, (error, data) => {
    error ? callback(error, null) : callback(null, data);
});

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