DynamoDB更新记录遇保留关键字错误，求解决方法

问题背景 #

尝试用dictData更新DynamoDB记录，其中action.value和customer.value里的value是DynamoDB保留关键字，直接使用会触发以下报错：

CRITICAL Couldn't update record in table table. Here's why: ValidationException: Invalid UpdateExpression: Attribute name is a reserved keyword; reserved keyword: value

相关代码 #

待更新数据字典 #

dictData = {
    'line_items': [{
        'search_product': 'dd',
        'quantity': '10'
    }],
    'email': 'xyz@email',
    'poc_name': 'XYZ',
    'contact': '90912',
    'action': {
        'value': 'id1',
        'label': 'In Progress'
    },
    'terms': 'Cash',
    'customer': {
        'value': 'id1',
        'label': 'Customer'
    },
}

当前更新逻辑（存在问题） #

updateExpression = ["set "]
updateValues = dict()
expression_attributes_names = {}
for key, value in dictData.items():
    updateExpression.append(f" #{key}_alias = :{key.replace('.', '_')},")
    updateValues[f":{key.replace('.', '_')}"] = value
    expression_attributes_names[f"#{key}_alias"] = key
    response = table.update_item(
       Key={"_id": id},
       UpdateExpression="".join(updateExpression)[:-1],
       ExpressionAttributeValues=updateValues,
       ReturnValues="UPDATED_NEW",
       ExpressionAttributeNames=expression_attributes_names,
    )

当前生成的错误表达式参数 #

expression_attributes_names: {}    

updateExpression: ['set ', ' line_items = :line_items,', ' email = :email', ' poc_name = :poc_name,', ' contact = :contact,', ' action.value = :action_value,',
    ' action.label = :action_label,', ' terms = :terms,',
    ' customer.value = :customer_value,', ' customer.label = :customer_label,'
]

updateValues: {
    ':line_items': [{
        'search_product': 'dd',
        'quantity': '10'
    }],
    ':email': 'xyz@email',
    ':poc_name': 'Test',
    ':contact': '90912',
    ':action_value': 'id1',
    ':action_label': 'In Progress',
    ':terms': 'Cash',
    ':customer_value': 'id1',
    ':customer_label': 'Customer'
}

问题分析 #

当前代码仅处理了顶层属性的别名，完全没处理嵌套属性里的保留关键字value。DynamoDB要求所有保留关键字必须用#开头的别名替换，直接写action.value会被识别为保留关键字触发报错。

解决方案 #

递归遍历嵌套字典，对每个遇到的保留关键字创建别名，同时替换UpdateExpression中的属性路径。修改后的代码如下：

# 定义DynamoDB保留关键字集合
RESERVED_KEYWORDS = {'value'}  # 可根据实际需求补充其他保留字

def build_update_expressions(data, parent_key=''):
    update_expr_parts = []
    expr_attr_names = {}
    expr_attr_values = {}
    
    for key, value in data.items():
        # 为保留关键字创建别名
        if key in RESERVED_KEYWORDS:
            alias = f"#{key}_alias"
            expr_attr_names[alias] = key
            current_key = alias
        else:
            current_key = key
        
        # 构建完整属性路径
        full_path = f"{parent_key}.{current_key}" if parent_key else current_key
        
        if isinstance(value, dict):
            # 递归处理嵌套字典
            nested_parts, nested_names, nested_values = build_update_expressions(value, full_path)
            update_expr_parts.extend(nested_parts)
            expr_attr_names.update(nested_names)
            expr_attr_values.update(nested_values)
        else:
            # 生成值的占位符
            value_placeholder = f":{full_path.replace('.', '_')}"
            update_expr_parts.append(f"{full_path} = {value_placeholder}")
            expr_attr_values[value_placeholder] = value
    
    return update_expr_parts, expr_attr_names, expr_attr_values

# 生成更新表达式
update_parts, expr_names, expr_values = build_update_expressions(dictData)
update_expression = "set " + ", ".join(update_parts)

# 执行更新操作
response = table.update_item(
    Key={"_id": id},
    UpdateExpression=update_expression,
    ExpressionAttributeNames=expr_names,
    ExpressionAttributeValues=expr_values,
    ReturnValues="UPDATED_NEW"
)

关键修改点 #

1. 递归处理嵌套属性：自动遍历所有层级的属性，不会遗漏嵌套的保留关键字
2. 保留关键字别名替换：将value替换为#value_alias，并在ExpressionAttributeNames中映射真实名称
3. 正确构建属性路径：嵌套属性路径变为action.#value_alias，符合DynamoDB语法要求
4. 统一生成表达式：先构建完整的更新表达式，再执行一次update_item，避免循环内重复调用的错误

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