Node.js中如何根据非主键/非排序键的数字数组查询DynamoDB？

你之前用BatchGetCommand不行是对的——这个API必须传表的主键（分区键+可选排序键），而你的userIds不是主键/排序键，所以得换下面两种方案：

方案一：建全局二级索引（GSI）推荐 #

如果这个查询是高频操作，优先给userIds字段建GSI，这是最高效的方式。

1. 先建GSI #

在DynamoDB控制台或者通过代码给目标表加个GSI，把userIds设为索引的分区键，按需选择要投影的属性（比如只投影需要的字段，减少数据传输）。

2. Node.js查询代码 #

用QueryCommand，借助GSI的分区键，用IN操作符匹配多个userIds：

import { QueryCommand } from "@aws-sdk/lib-dynamodb";

async function getUserDetails(userIds: number[], projectionExpression?: string) {
  // 动态生成查询参数，适配任意长度的userIds（IN操作符最多支持100个值）
  const idPlaceholders = userIds.map((_, idx) => `:id${idx}`).join(", ");
  const expressionAttrs: Record<string, number> = {};
  
  userIds.forEach((id, idx) => {
    expressionAttrs[`:id${idx}`] = id;
  });

  const params = {
    TableName: this.tableName,
    IndexName: "userIds-index", // 换成你创建的GSI名称
    KeyConditionExpression: `userIds IN (${idPlaceholders})`,
    ExpressionAttributeValues: expressionAttrs,
    ...(projectionExpression && { ProjectionExpression: projectionExpression })
  };

  const command = new QueryCommand(params);
  const response = await this.dynamoDocumentClient.send(command);
  return response.Items;
}

注意：如果userIds数组长度超过100，得分成多批查询，再把结果合并。

方案二：用Scan加过滤不推荐大数据量 #

要是不想建索引，也可以用ScanCommand扫全表再过滤，但这种方法性能很差，数据量大的时候别用：

import { ScanCommand } from "@aws-sdk/lib-dynamodb";

async function getUserDetails(userIds: number[], projectionExpression?: string) {
  const idPlaceholders = userIds.map((_, idx) => `:id${idx}`).join(", ");
  const expressionAttrs: Record<string, number> = {};
  
  userIds.forEach((id, idx) => {
    expressionAttrs[`:id${idx}`] = id;
  });

  const params = {
    TableName: this.tableName,
    FilterExpression: `userIds IN (${idPlaceholders})`,
    ExpressionAttributeValues: expressionAttrs,
    ...(projectionExpression && { ProjectionExpression: projectionExpression })
  };

  const command = new ScanCommand(params);
  const response = await this.dynamoDocumentClient.send(command);
  return response.Items;
}

方案对比 #

• GSI+Query：速度快，适合频繁查询，缺点是要额外花存储和索引维护的成本。
• Scan+Filter：不用额外建索引，但会扫全表，数据多的时候延迟高，还容易触发DynamoDB的速率限制。

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