如何在Node.js Serverless DynamoDB中将数据转为指定关联数组格式

1. 准备工作：获取DynamoDB数据 #

在Serverless环境（如AWS Lambda）中，使用AWS SDK读取DynamoDB数据。推荐使用AWS SDK v3，先安装依赖：

npm install @aws-sdk/client-dynamodb @aws-sdk/util-dynamodb

编写基础数据读取代码，将DynamoDB的结构化数据转为普通JS对象：

import { DynamoDBClient, ScanCommand } from "@aws-sdk/client-dynamodb";
import { unmarshall } from "@aws-sdk/util-dynamodb";

const client = new DynamoDBClient({ region: "你的AWS区域" });

async function fetchUsersFromDynamoDB() {
  const command = new ScanCommand({
    TableName: "你的用户表名称"
  });

  const response = await client.send(command);
  // 转换DynamoDB格式为普通JS对象
  return response.Items.map(item => unmarshall(item));
}

2. 转换为目标关联数组格式 #

拿到用户数据后，将数组转换为以唯一用户ID为键的嵌套对象（示例中的顶层键如e8de014a-22c1-12bf-4653-577c8031138，需对应你表中的唯一标识字段，比如uuid或自定义ID字段）：

async function transformToTargetFormat() {
  const rawUsers = await fetchUsersFromDynamoDB();
  const result = { user: {} };

  rawUsers.forEach(user => {
    // 替换为你表中用来做顶层键的字段名
    const uniqueUserKey = user.uuid;
    // 将用户对象直接挂载到对应键下
    result.user[uniqueUserKey] = user;
  });

  return result;
}

3. 在Serverless函数中完整实现 #

以AWS Lambda为例，完整处理函数示例：

import { DynamoDBClient, ScanCommand } from "@aws-sdk/client-dynamodb";
import { unmarshall } from "@aws-sdk/util-dynamodb";

const client = new DynamoDBClient({ region: "us-east-1" });

export const handler = async (event) => {
  try {
    // 读取数据
    const command = new ScanCommand({ TableName: "UserTable" });
    const response = await client.send(command);
    const rawUsers = response.Items.map(item => unmarshall(item));

    // 转换格式
    const formattedData = { user: {} };
    rawUsers.forEach(user => {
      // 替换为你表中的唯一标识字段
      const uniqueKey = user.unique_id;
      formattedData.user[uniqueKey] = user;
    });

    return {
      statusCode: 200,
      body: JSON.stringify(formattedData, null, 2)
    };
  } catch (error) {
    return {
      statusCode: 500,
      body: JSON.stringify({ error: error.message })
    };
  }
};

关键注意事项 #

• 唯一键匹配：确保你用来做顶层键的字段在每条数据中唯一，避免数据被覆盖。
• 性能优化：如果表数据量较大，避免使用Scan全表扫描，改用Query配合全局二级索引精准获取数据。
• SDK版本兼容：若使用AWS SDK v2，可直接用DocumentClient读取数据，无需手动unmarshall。

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