DynamoDB仅支持批量写入，能否实现仅写入主键不存在的条目？

绝对可以实现这个需求！DynamoDB的BatchWriteItem API虽然常被用来做批量写入，但它支持为每个写入请求添加条件判断，刚好能满足你“仅主键不存在时才执行写入”的要求。

核心实现思路 #

在每个PutRequest中，通过ConditionExpression参数搭配attribute_not_exists()函数，检查目标主键属性是否存在。如果主键已经存在，该条Put操作会直接失败，但不会影响批量中其他条目的执行——因为BatchWriteItem是按单个条目独立保证原子性的，某一条失败不波及全局。

代码示例（以Python boto3为例） #

import boto3

# 初始化DynamoDB客户端
dynamodb = boto3.client('dynamodb')

# 构造批量写入请求
response = dynamodb.batch_write_item(
    RequestItems={
        'YourTargetTableName': [
            {
                'PutRequest': {
                    'Item': {
                        'user_id': {'S': 'u_1001'},  # 主键字段
                        'username': {'S': 'johndoe'},
                        'email': {'S': 'john@example.com'}
                    },
                    # 核心条件：仅当user_id不存在时才写入
                    'ConditionExpression': 'attribute_not_exists(user_id)'
                }
            },
            {
                'PutRequest': {
                    'Item': {
                        'user_id': {'S': 'u_1002'},
                        'username': {'S': 'janedoe'},
                        'email': {'S': 'jane@example.com'}
                    },
                    'ConditionExpression': 'attribute_not_exists(user_id)'
                }
            }
        ]
    }
)

# 处理未成功的请求（可选）
if response.get('UnprocessedItems'):
    # 这里可以添加重试逻辑，比如循环处理UnprocessedItems
    print("存在未处理的条目，建议重试：", response['UnprocessedItems'])

关键注意事项 #

• 批量限制：每个BatchWriteItem请求最多包含25个写入操作，总数据大小不能超过16MB，超出的话需要拆分请求分批处理。
• 失败重试：如果某个条目因主键已存在写入失败，它会被放到返回结果的UnprocessedItems字段中，你需要根据业务需求自行处理重试逻辑（或直接忽略）。
• 条件灵活性：attribute_not_exists()不仅可用于主键，也能针对其他属性做判断，但这里我们只需要聚焦主键即可。

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