DynamoDB GSI查询优化：多条件匹配+排序高效实现方案

你当前用FilterExpression过滤senderWallet的方案确实存在高读成本问题——DynamoDB会先读取所有匹配platform = "x"的项，再在内存中过滤senderWallet = "y"的结果，读请求容量按读取的总项数计费，哪怕大部分数据会被过滤掉。

最优实现方案 #

通过调整全局二级索引（GSI）的键结构，将platform和senderWallet组合为复合哈希键，搭配tx_time作为排序键，就能实现精准查询+排序，完全避免过滤操作，大幅降低读成本。

核心思路

DynamoDB的GSI哈希键支持精准匹配，排序键支持范围查询和排序。我们可以预先计算一个复合属性（比如platform_sender），值格式为${platform}#${senderWallet}，将其作为GSI的哈希键，tx_time作为排序键。这样查询时只需精准匹配复合哈希键，就能直接获取符合双属性条件的结果，同时按时间排序。

具体实现步骤 #

1. 修改表结构Schema

新增复合属性定义，并添加对应的GSI：

AttributeDefinitions: [
  {
    AttributeName: 'txHash',
    AttributeType: 'S',
  },
  {
    AttributeName: 'senderWallet',
    AttributeType: 'S',
  },
  {
    AttributeName: 'tx_time',
    AttributeType: 'N',
  },
  {
    AttributeName: 'platform',
    AttributeType: 'S',
  },
  {
    AttributeName: 'platform_sender', // 新增复合属性，存储platform和senderWallet的组合值
    AttributeType: 'S',
  }
],
GlobalSecondaryIndexes: [
  // 保留原有的PlatformIndex（若其他场景需要）
  {
    IndexName: 'PlatformIndex',
    KeySchema: [
      {
        AttributeName: 'platform',
        KeyType: 'HASH',
      },
      {
        AttributeName: 'tx_time',
        KeyType: 'RANGE',
      },
    ],
    Projection: {
      ProjectionType: 'ALL',
    },
  },
  // 新增用于双属性匹配+排序的GSI
  {
    IndexName: 'PlatformSenderIndex',
    KeySchema: [
      {
        AttributeName: 'platform_sender',
        KeyType: 'HASH',
      },
      {
        AttributeName: 'tx_time',
        KeyType: 'RANGE',
      },
    ],
    Projection: {
      ProjectionType: 'ALL',
    },
  }
]

2. 数据写入时维护复合属性

每次写入或更新数据时，同步计算并设置platform_sender的值：

// 示例写入代码
const putItemParams = {
  TableName: userTxHistorySchema.TableName,
  Item: {
    txHash: "xxx",
    senderWallet: "y",
    tx_time: 1699999999,
    platform: "x",
    platform_sender: "x#y" // 按platform#senderWallet格式拼接
  }
};
await putItem(putItemParams);

3. 优化后的查询代码

直接通过新GSI执行精准查询，无需过滤：

const query = {
  TableName: userTxHistorySchema.TableName,
  IndexName: 'PlatformSenderIndex',
  ExpressionAttributeValues: {
    ':platform_sender': `${platform}#${senderWallet}`, // 传入组合值
  },
  ScanIndexForward: false, // false为降序，true为升序
  KeyConditionExpression: 'platform_sender = :platform_sender',
  Limit: limit,
  ExclusiveStartKey: lastEvaluatedKey,
};

const response = await queryItems(query);
console.log('response', response);

方案优势 #

• 读成本大幅降低：仅读取符合platform和senderWallet双条件的项，读请求容量与实际返回的结果数一致
• 查询效率更高：跳过内存过滤步骤，直接返回目标数据
• 天然支持排序：通过tx_time排序键实现升序/降序，无需额外处理

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