如何在DynamoDB中结合begins_with与BETWEEN实现查询？

先明确原代码存在的几个关键问题：

• FilterExpression语法错误：原写法GSI${index}PK = :gsipk BETWEEN :startdate AND :enddate逻辑混乱，GSI PK已在KeyConditionExpression中匹配，无需重复判断；且BETWEEN的正确语法是属性名 BETWEEN :val1 AND :val2。
• ExpressionAttributeValues格式错误：键名不需要加反斜杠转义（比如"\:gsipk"应改为:gsipk）；startdate和enddate未转换为DynamoDB支持的数据类型（需根据实际存储格式用{S: 日期字符串}或{N: 时间戳}）。
• 未使用size参数：传入的分页条数参数未加到查询配置中。
• 变量名笔误：attributes里的startdate应为传入的startDate参数。

以下是修正后的完整代码：

getMyFunction = async (fromNumber = null, toNumber = null, startDate = null, endDate = null, size = null) => {
  const client = getClient();

  try {
      const index = fromNumber ? 2 : 3;
      let searches = [];

      // 定义表达式属性值，键名无需反斜杠转义
      let attributes = {
          ":gsipk": { S: (fromNumber ? this.getGSI2PK() : this.getGSI3PK()) },
          ...(fromNumber ? { ":from": { S: fromNumber } } : {}),
          ...(!fromNumber && toNumber ? { ":to": { S: toNumber } } : {}),
      };

      // 动态生成过滤条件与对应属性值
      let filterExpression = "";
      if (startDate && endDate) {
          attributes[":startdate"] = { S: startDate }; // 若存储为时间戳则用{N: startDate}
          attributes[":enddate"] = { S: endDate };
          // 替换为实际存储日期的属性名，比如SK或单独的createdAt字段
          filterExpression = "SK BETWEEN :startdate AND :enddate";
      } else if (startDate) {
          attributes[":startdate"] = { S: startDate };
          filterExpression = "SK >= :startdate";
      } else if (endDate) {
          attributes[":enddate"] = { S: endDate };
          filterExpression = "SK <= :enddate";
      }

      const queryParams = {
          TableName: process.env.DB_TABLE_NAME,
          IndexName: `GSI${index}`,
          KeyConditionExpression: `GSI${index}PK = :gsipk AND begins_with(GSI${index}SK, :${fromNumber ? 'from' : 'to'})`,
          ExpressionAttributeValues: attributes,
          ScanIndexForward: false,
          ...(size ? { Limit: size } : {}) // 加入分页条数配置
      };

      // 仅当有过滤条件时添加FilterExpression
      if (filterExpression) {
          queryParams.FilterExpression = filterExpression;
      }

      const result = await client.query(queryParams).promise();

      searches = result.Items.map((item) => unmarshall(item));
      return [null, searches];
  } catch (error) {
      return [error];
  }
}

核心实现说明： #

1. KeyConditionExpression的定位作用：用于精准匹配GSI的分区键（GSI PK），并通过begins_with匹配排序键（SK）的前缀，这一步是基于索引的高效查询，直接缩小数据范围。
2. FilterExpression的过滤作用：仅在KeyCondition查询出的结果集中做二次过滤，不能替代KeyCondition的索引查询——因为Filter是数据加载到内存后执行的，不会减少读取的数据量。
3. 数据类型一致性：确保startDate和endDate的类型与表中存储的类型完全匹配（比如统一用YYYY-MM-DDTHH:mm:ssZ格式的字符串，或时间戳数字）。
4. 动态参数处理：根据传入的参数动态生成查询条件，避免冗余的表达式和属性值。

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