如何在DynamoDB中原子条件删除父项（无特定子项时）

我有一个DynamoDB表，项结构如下：

PK: PARENT#<ID>, SK: PARENT#<ID>
PK: PARENT#<ID>, SK: CHILD_A#<ID>
PK: PARENT#<ID>, SK: CHILD_B#<ID>
PK: PARENT#<ID>, SK: CHILD_C#<ID>

需求是删除父项，但仅当不存在CHILD_A#或CHILD_B#类型的子项时执行（不关心CHILD_C#）。但直接先查询子项再删除父项会有竞态条件——检查和删除的间隙，其他进程可能创建CHILD_A#或CHILD_B#子项。需要实现原子性操作：

1. 检查是否存在CHILD_A#或CHILD_B#子项
2. 仅当不存在时删除父项
3. 确保操作原子执行，无竞态条件

曾考虑的方案：

• 使用带条件表达式的事务？
• 添加计数属性并基于它使用条件表达式？

想知道DynamoDB中实现这种原子条件删除的最佳方案。

直接用DynamoDB的TransactWriteItems操作，将「检查子项是否存在」和「删除父项」打包成一个原子事务，完全避免竞态条件。

具体实现逻辑 #

事务包含两个步骤，必须同时成功或失败：

1. ConditionCheck操作：针对目标父项的分区键，检查是否存在任何SK以CHILD_A#或CHILD_B#开头的子项。如果存在，ConditionCheck失败，整个事务终止；如果不存在，进入下一步。
2. Delete操作：删除父项（PK=PARENT#<ID>, SK=PARENT#<ID>）。

关键条件表达式写法 #

ConditionCheck的核心是用begins_with函数匹配SK前缀，并通过条件判断确保没有匹配项：

# 以boto3为例的ConditionCheck参数
{
    "ConditionCheck": {
        "TableName": "你的表名",
        "Key": {"PK": {"S": "PARENT#<ID>"}},
        "ConditionExpression": "NOT (begins_with(SK, :child_a) OR begins_with(SK, :child_b))",
        "ExpressionAttributeValues": {
            ":child_a": {"S": "CHILD_A#"},
            ":child_b": {"S": "CHILD_B#"}
        }
    }
}

注：如果表有专门用于子项查询的全局二级索引（GSI），可以指定IndexName参数优化检查效率。

为什么这比计数属性更可靠 #

添加计数属性（比如在父项里维护child_a_b_count）的方案需要额外维护计数：每次创建/删除CHILD_A#或CHILD_B#子项时，都要同步更新父项的计数。这会引入更多写操作，且如果出现漏更（比如其他进程操作子项时未更新计数），会导致删除条件判断错误。而直接检查子项存在性的方案，完全依赖DynamoDB的原子事务，无需额外维护状态，更可靠。

完整事务示例（Python boto3） #

import boto3

dynamodb = boto3.client('dynamodb')

parent_id = "123"
table_name = "your-table-name"

try:
    response = dynamodb.transact_write_items(
        TransactItems=[
            {
                "ConditionCheck": {
                    "TableName": table_name,
                    "Key": {"PK": {"S": f"PARENT#{parent_id}"}},
                    "ConditionExpression": "NOT (begins_with(SK, :child_a) OR begins_with(SK, :child_b))",
                    "ExpressionAttributeValues": {
                        ":child_a": {"S": "CHILD_A#"},
                        ":child_b": {"S": "CHILD_B#"}
                    }
                }
            },
            {
                "Delete": {
                    "TableName": table_name,
                    "Key": {
                        "PK": {"S": f"PARENT#{parent_id}"},
                        "SK": {"S": f"PARENT#{parent_id}"}
                    }
                }
            }
        ]
    )
    print("父项删除成功")
except dynamodb.exceptions.TransactionCanceledException as e:
    print("删除失败：存在CHILD_A#或CHILD_B#子项，或其他事务冲突")
except Exception as e:
    print(f"操作出错：{str(e)}")

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