如何实现Lambda函数单实例运行以解决DynamoDB并发更新问题？

核心解决方案是利用DynamoDB的原子更新能力，无需先读取当前quantity值再计算，直接让DynamoDB在服务器端原子性完成增量操作，从根源避免并发读写冲突。

实现示例 #

Python Lambda 代码 #

import boto3

dynamodb = boto3.resource('dynamodb')
table = dynamodb.Table('你的表名')

def lambda_handler(event, context):
    # 从请求事件中获取主键和增量值
    item_id = event['item_id']
    increment = event['increment']  # 对应示例中的增量2
    
    response = table.update_item(
        Key={
            '主键字段名': item_id  # 替换为你的表主键
        },
        UpdateExpression='SET quantity = quantity + :val',
        ExpressionAttributeValues={
            ':val': increment
        },
        # 可选：仅当目标项存在时才更新，避免误创建空项
        ConditionExpression='attribute_exists(quantity)',
        # 可选：返回更新后的quantity值
        ReturnValues='UPDATED_NEW'
    )
    
    # 如果需要返回更新后的值
    updated_quantity = response['Attributes']['quantity']
    return {
        'statusCode': 200,
        'body': f'更新成功，当前quantity：{updated_quantity}'
    }

Node.js Lambda 代码 #

const AWS = require('aws-sdk');
const dynamodb = new AWS.DynamoDB.DocumentClient();

exports.handler = async (event) => {
    const itemId = event.item_id;
    const increment = event.increment; // 增量值，比如示例中的2
    
    const params = {
        TableName: '你的表名',
        Key: {
            '主键字段名': itemId // 替换为你的表主键
        },
        UpdateExpression: 'SET quantity = quantity + :val',
        ExpressionAttributeValues: {
            ':val': increment
        },
        // 可选：仅当目标项存在时更新
        ConditionExpression: 'attribute_exists(quantity)',
        // 可选：返回更新后的quantity值
        ReturnValues: 'UPDATED_NEW'
    };
    
    const response = await dynamodb.update(params).promise();
    const updatedQuantity = response.Attributes.quantity;
    
    return {
        statusCode: 200,
        body: `更新成功，当前quantity：${updatedQuantity}`
    };
};

原理说明 #

• 所有增量计算在DynamoDB服务器端完成，且操作是原子性的——即使有多个并发请求，每个请求的增量都会被依次正确累加，不会出现读取旧值后覆盖的问题。
• 可选的ConditionExpression用于限制更新范围，防止无意义地创建新项；如果允许自动创建新项（初始quantity为增量值），可直接移除该条件。
• 通过ReturnValues参数可以获取更新后的quantity值，方便后续业务逻辑使用。

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