如何在Lambda函数中无冲突修改DynamoDB中的对象？

问题场景 #

要将以下TypeScript定义的Car对象存储在DynamoDB中，通过Lambda+API Gateway支持多用户并行操作（添加/修改车辆、添加/修改车轮），但直接读写全量对象会导致并发修改时的覆盖丢失问题：

interface Car{
  id: Number;
  name: String;
  tires: Wheel[]
}

interface Wheel{
  id: Number;
  name: String;
  radius: Number;
}

具体解决方案 #

1. 乐观锁机制 #

给Car对象新增version: number版本号字段，每次操作遵循以下流程：

• 读取Car对象时，同步获取当前version值
• 修改对象后，执行更新操作时，通过条件表达式限定version = 读取到的旧版本号
• 若更新抛出ConditionalCheckFailedException，说明已有其他用户修改过该对象，需重新读取最新版本，合并修改后再次尝试更新

示例TypeScript代码片段：

// 读取目标Car对象
const getCarResult = await dynamoDbClient.get({
  TableName: 'Cars',
  Key: { id: carId }
}).promise();
const currentCar = getCarResult.Item;
const oldVersion = currentCar.version;

// 执行修改（示例：添加新车轮）
currentCar.tires.push(newWheel);
currentCar.version = oldVersion + 1;

// 带条件的原子更新
try {
  await dynamoDbClient.put({
    TableName: 'Cars',
    Item: currentCar,
    ConditionExpression: 'version = :oldVersion',
    ExpressionAttributeValues: { ':oldVersion': oldVersion }
  }).promise();
} catch (error) {
  if (error.name === 'ConditionalCheckFailedException') {
    // 冲突触发，可实现重试逻辑或返回前端提示重试
  }
}

2. 拆分对象为独立记录 #

若车轮的修改频率较高，可将Wheel作为单独记录存储：

• 表结构设计：以carId为分区键，wheelId为排序键，存储单个Wheel的所有字段
• 获取完整Car对象时，通过查询carId对应的所有Wheel记录，再与Car基础信息合并

这种方式从根源上减少全量对象读写的冲突，但需要额外处理对象组装逻辑。

3. 原子局部更新操作 #

针对数组或字段的简单修改，使用DynamoDB的UpdateExpression执行原子操作，无需读取整个对象：

• 添加车轮：用LIST_APPEND将新车轮追加到tires数组
• 修改指定车轮：结合表达式定位目标车轮后执行更新（复杂场景仍需搭配乐观锁）

示例：原子添加车轮

await dynamoDbClient.update({
  TableName: 'Cars',
  Key: { id: carId },
  UpdateExpression: 'SET tires = list_append(tires, :newWheel)',
  ExpressionAttributeValues: { ':newWheel': [newWheel] },
  ReturnValues: 'ALL_NEW'
}).promise();

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