本文详解为何连续调用 put_item 会导致 DynamoDB 记录被覆盖，并推荐使用 update_item 原子更新方式，配合 SET 操作一次性写入多个属性，确保数据完整性与并发安全性。
本文详解为何连续调用 `put_item` 会导致 dynamodb 记录被覆盖，并推荐使用 `update_item` 原子更新方式，配合 `set` 操作一次性写入多个属性，确保数据完整性与并发安全性。
在 DynamoDB 中，put_item 的语义是「全量写入」：只要指定相同的主键（如 pk = '787'），无论表中是否已存在该记录，DynamoDB 都会完全替换整条项（item）。这意味着你代码中循环执行两次 put_item：
# 第一次：写入 {"pk": "787", "orderId": "569782152"}
# 第二次：写入 {"pk": "787", "incBaseFx": "1.0"} → 覆盖前一条！最终只剩 pk + incBaseFx结果只有最后一次写入的字段保留，造成数据丢失。
✅ 正确做法：使用 update_item 实现增量更新。它支持原子性地向现有项添加、修改或删除属性，且不会影响未指定的字段。以下是优化后的实现：
import boto3
from boto3.dynamodb.types import TypeSerializer
# 解析原始字符串
record_data = "orderId:569782152,incBaseFx:1.0"
record_data_list = record_data.split(",")
# 构建 UpdateExpression 和 ExpressionAttributeNames/Values
update_expr_parts = []
expr_attr_names = {}
expr_attr_values = {}
for item in record_data_list:
key, value = item.split(":", 1) # 使用 1 分割，避免值中含冒号时出错
placeholder_name = f"#{key}"
placeholder_value = f":{key}"
update_expr_parts.append(f"{placeholder_name} = {placeholder_value}")
expr_attr_names[placeholder_name] = key
expr_attr_values[placeholder_value] = value
# 组装 UpdateExpression
update_expression = "SET " + ", ".join(update_expr_parts)
# 执行原子更新
table.update_item(
Key={"pk": "787"},
UpdateExpression=update_expression,
ExpressionAttributeNames=expr_attr_names,
ExpressionAttributeValues=expr_attr_values,
ReturnValues="ALL_NEW" # 可选：返回更新后的完整项
)? 关键注意事项：
- ✅ update_item 是幂等且原子的操作，适合多字段并发写入；
- ✅ 务必使用 ExpressionAttributeNames（防止关键字冲突，如字段名为 type 或 order）和 ExpressionAttributeValues（自动序列化，避免类型错误）；
- ⚠️ 若首次写入（即项不存在），update_item 会自动创建新项 —— 行为安全，无需预判；
- ❌ 避免在循环中反复 put_item 同一主键，这是典型的「覆盖陷阱」；
- ? 如需批量写入多条不同主键的记录，请改用 batch_writer()，而非循环 put_item。
总结：DynamoDB 的 put_item ≠ SQL 的 INSERT ... ON DUPLICATE KEY UPDATE；要实现“追加属性”，必须转向 update_item + SET 表达式。掌握这一区别，是写出健壮无竞态 DynamoDB 应用的关键基础。
