如何为基于流派和发行年份的DynamoDB查询配置GSI

需求与任务 #

• 需求：根据曲目流派和发行年份查询表中特定行
• 任务：查询release_year=2018且流派包含"pop"的行

Tracks表结构及示例数据 #

当前代码问题 #

当前代码错误地在KeyConditionExpression中尝试匹配genres = :genre（数组类型无法直接做键值匹配），同时使用FilterExpression的CONTAINS方法过滤数组，代码如下：

let queryParams = {
    TableName: tableName,
    IndexName: req.query.index,
    KeyConditionExpression: 'release_year = :release_year and genres = :genre',
    ExpressionAttributeValues: { ':release_year': parseInt(req.query.year), ':genre': req.query.genre},
    FilterExpression : "contains (genres, :genre)", 
    ScanIndexForward: false,
    Limit: 50
  }
  
  dynamodb.query(queryParams, (err, data) => {
    if (err) {
      res.statusCode = 500;
      res.json({error: 'Could not load items: ' + err});
    } else {
      res.json(data.Items);
    }
  });

方案一：反范式拆分数据（最优性能，无Filter） #

DynamoDB不支持数组作为索引键，若想完全避免Filter过滤，需将每个曲目的每个流派拆分为单独条目：

GSI配置

创建全局二级索引：

• 分区键（Partition Key）：release_year（数字类型）
• 排序键（Sort Key）：genre（字符串类型）
• 投影设置：按需投影所需字段（或全部）

调整后的查询代码

let queryParams = {
    TableName: tableName,
    IndexName: "release_year-genre-index", // 替换为你的GSI名称
    KeyConditionExpression: 'release_year = :release_year AND genre = :genre',
    ExpressionAttributeValues: { 
      ':release_year': parseInt(req.query.year), 
      ':genre': req.query.genre
    },
    ScanIndexForward: false,
    Limit: 50
  }
  
  dynamodb.query(queryParams, (err, data) => {
    if (err) {
      res.statusCode = 500;
      res.json({error: 'Could not load items: ' + err});
    } else {
      res.json(data.Items);
    }
  });

方案二：保留原数组结构（需Filter但减少扫描范围） #

若无法修改原数据结构，可通过GSI缩小查询范围，再用Filter过滤流派：

GSI配置

创建全局二级索引：

• 分区键（Partition Key）：release_year（数字类型）
• 投影设置：投影genres及其他需要返回的字段

调整后的查询代码

let queryParams = {
    TableName: tableName,
    IndexName: "release_year-index", // 替换为你的GSI名称
    KeyConditionExpression: 'release_year = :release_year',
    ExpressionAttributeValues: { 
      ':release_year': parseInt(req.query.year), 
      ':genre': req.query.genre
    },
    FilterExpression : "contains(genres, :genre)", 
    ScanIndexForward: false,
    Limit: 50
  }
  
  dynamodb.query(queryParams, (err, data) => {
    if (err) {
      res.statusCode = 500;
      res.json({error: 'Could not load items: ' + err});
    } else {
      res.json(data.Items);
    }
  });

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