Lambda首次运行无法更新DynamoDB数据、二次运行生效且交替工作的原因排查

这种交替生效的问题在DynamoDB和Lambda的组合场景里并不少见，我结合实际排查经验，整理几个最可能的原因：

1. Lambda执行环境复用导致的变量缓存问题 #

Lambda的热启动机制会保留之前执行的环境状态，如果你的代码里把需要实时获取的变量（比如DynamoDB的版本号、用户属性）定义在了函数外部，就会出现缓存旧值的情况，导致交替失败。

举个典型的错误示例：

# 错误：变量定义在函数外，热启动时会复用上次的值
cached_user_version = None

def lambda_handler(event, context):
    global cached_user_version
    user_id = event['user_id']
    
    # 第一次冷启动时会获取最新版本号，热启动时直接用缓存的旧值
    if not cached_user_version:
        cached_user_version = get_user_version_from_db(user_id)
    
    # 用旧版本号做乐观锁条件，第二次热启动时会因为版本不匹配失败
    response = dynamodb.update_item(
        TableName='user_table',
        Key={'user_id': user_id},
        UpdateExpression='SET target_field = :val, version = :new_v',
        ConditionExpression='version = :current_v',
        ExpressionAttributeValues={
            ':val': event['new_value'],
            ':current_v': cached_user_version,
            ':new_v': cached_user_version + 1
        }
    )

排查方式：查看CloudWatch日志，对比每次执行时使用的版本号/属性值是否和数据库中的实际值一致；或者在函数开头强制重置缓存变量。

2. 最终一致性读取引发的条件不匹配 #

DynamoDB的默认读取模式是最终一致性，也就是说写入后，短时间内读取可能返回旧数据。如果你的Lambda在更新前需要先读取用户属性来生成条件表达式或更新值，就可能出现：

• 第一次执行：读取最新数据 → 更新成功
• 第二次执行：读取到旧数据 → 条件表达式不匹配（比如乐观锁版本号不对）→ 更新失败
• 第三次执行：数据已经同步完成 → 读取到新数据 → 更新成功

解决思路：在读取用户数据时，开启强一致性读（设置ConsistentRead=True），确保每次都拿到最新的状态。

3. 乐观锁逻辑错误 #

如果你的更新依赖乐观锁（比如用version字段做条件），但代码中没有正确处理版本号的递增或传递，也会导致交替失败。比如：

• 第一次执行：读取版本v1 → 更新为v2，成功
• 第二次执行：错误地再次使用v1作为条件 → 数据库中已经是v2，条件检查失败
• 第三次执行：重新读取v2 → 更新为v3，成功

排查方式：检查每次更新请求的ConditionExpression参数，确认使用的版本号是实时从数据库读取的，而不是复用旧值。

4. 条件表达式存在交替触发的逻辑 #

如果你的更新条件是基于用户属性的切换状态（比如status在active和inactive之间切换），但代码中没有实时读取最新状态，而是依赖上次执行的结果，就会出现交替失败。比如：

# 错误：依赖上次执行的状态判断，而非实时读取
last_status = None

def lambda_handler(event, context):
    global last_status
    user_id = event['user_id']
    
    if not last_status:
        last_status = get_user_status(user_id)
    
    # 基于缓存的旧状态设置条件，导致下一次执行条件不匹配
    condition = f"status = :{last_status}"
    new_status = 'inactive' if last_status == 'active' else 'active'
    
    dynamodb.update_item(
        TableName='user_table',
        Key={'user_id': user_id},
        UpdateExpression='SET status = :new_s',
        ConditionExpression=condition,
        ExpressionAttributeValues={
            ':active': 'active',
            ':inactive': 'inactive',
            ':new_s': new_status
        }
    )
    last_status = new_status

这种情况下，第一次执行成功切换状态，但第二次执行时用的是缓存的旧状态作为条件，自然会失败。

快速排查步骤 #

1. 查看CloudWatch中的Lambda日志，重点关注ConditionCheckFailedException这类错误，它直接说明更新的条件不满足。
2. 在每次更新前，打印出读取到的用户属性值和使用的条件表达式，对比数据库中的实际数据。
3. 临时开启DynamoDB的强一致性读，看问题是否消失，以此验证是否是最终一致性导致的。

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