如何在Lambda的Express.js服务中实现DynamoDB数据部分更新？

我在Lambda上部署了Express.js服务，已经通过以下GET接口成功读取DynamoDB中users表的数据：

app.get("/profile/general", async function (req, res) {
  
  const params = {
    TableName: "users",
    Key: {
      id: `${req.user.sub}`,
    },
  };

  try {
    let userObj = await docClient.get(params).promise();
    res.json({ "data": userObj });
  } catch (err) {
    console.log("error: ", err); 
    res.json({ "error": err });
  }
});

现在想实现对用户对象的部分更新（不想用PUT替换整个对象），写了如下PATCH接口，但不确定这种多UpdateExpression键值对的写法是否正确：

app.patch("/profile/general", async function (req, res) {
  
  const params = {
    TableName: "users",
    Key: {
      id: `${req.user.sub}`,
    },
    UpdateExpression: "set age = req.body.age",
    UpdateExpression: "set country = req.body.country",
    UpdateExpression: "set skills = req.body.skills",
    ReturnValues: "ALL_NEW",
  };

  try {
    
    let newUserObj = await docClient.UpdateItem(params).promise(); 
    res.json({ "newData": newUserObj });
  } catch (err){
    console.log("error: ", err); 
    res.json({ "error": err });
  }
});

官方文档看不太明白，希望得到解答。

你的写法存在几个关键问题，直接运行会报错或者达不到预期效果：

1. 重复对象键会被覆盖
   JavaScript对象中重复定义的键只会保留最后一个，你写的三个UpdateExpression最终只会生效最后一个，age和country的更新逻辑完全丢失。

2. UpdateExpression不能直接引用Node.js变量
   DynamoDB无法识别req.body.age这类Node.js变量，直接写会被当作字符串字面量处理，导致更新失败。必须用占位符配合ExpressionAttributeValues传递实际值，同时避免注入风险。

3. SDK方法名错误
   AWS SDK v2中DocumentClient的更新方法是updateItem（首字母小写），不是UpdateItem，大写开头会触发"方法不存在"的错误。

正确实现方式 #

推荐动态生成表达式和参数，灵活处理任意数量的更新字段，无需硬编码：

app.patch("/profile/general", async function (req, res) {
  // 提取允许更新的字段（添加白名单防止恶意修改敏感字段）
  const allowedFields = ["age", "country", "skills"];
  const updateFields = Object.fromEntries(
    Object.entries(req.body).filter(([key]) => allowedFields.includes(key))
  );

  if (Object.keys(updateFields).length === 0) {
    return res.status(400).json({ error: "没有需要更新的字段" });
  }

  // 生成UpdateExpression、占位符参数和字段名映射
  const updateExpressions = [];
  const expressionAttributeValues = {};
  const expressionAttributeNames = {};

  Object.entries(updateFields).forEach(([key, value]) => {
    updateExpressions.push(`#${key} = :${key}`);
    expressionAttributeValues[`:${key}`] = value;
    expressionAttributeNames[`#${key}`] = key;
  });

  const params = {
    TableName: "users",
    Key: { id: `${req.user.sub}` },
    UpdateExpression: `set ${updateExpressions.join(", ")}`,
    ExpressionAttributeValues: expressionAttributeValues,
    ExpressionAttributeNames: expressionAttributeNames,
    ReturnValues: "ALL_NEW",
  };

  try {
    const result = await docClient.updateItem(params).promise();
    res.json({ newData: result.Attributes });
  } catch (err) {
    console.log("error: ", err);
    res.status(500).json({ error: err.message });
  }
});

核心说明 #

• 动态生成逻辑：根据请求体中的实际字段生成更新表达式，适配任意合法字段的部分更新。
• 占位符机制：用:key传递值、#key传递字段名，避免字段名是DynamoDB保留字导致的错误。
• 字段白名单：只允许更新指定字段，防止用户修改id、createdAt等敏感数据。
• 错误优化：返回对应HTTP状态码和可读错误信息，便于调试和前端处理。

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