DynamoDB条件删除问题：项不存在时如何让删除操作成功

问题 #

需要在DynamoDB中执行DeleteItem操作，满足以下要求：

• 指定主键（PK）的项不存在时，删除操作需返回成功
• 项存在时，仅当属性Status等于指定值（如Completed）才执行删除
• 必须通过单个请求完成，禁止额外查询或使用事务

原Go代码如下：

deleteInput := &dynamodb.DeleteItemInput{
    TableName: aws.String("YourTableName"),
    Key: map[string]*dynamodb.AttributeValue{
        "PK": {S: aws.String("PrimaryKeyValue")},
    },
    ConditionExpression: aws.String("attribute_not_exists(PK) OR #status = :statusValue"),
    ExpressionAttributeNames: map[string]*string{
        "#status": aws.String("Status"),
    },
    ExpressionAttributeValues: map[string]*dynamodb.AttributeValue{
        ":statusValue": {S: aws.String("Completed")},
    },
}

_, err := dynamodbSvc.DeleteItem(deleteInput)
if err != nil {
    if _, ok := err.(*dynamodb.ConditionalCheckFailedException); ok {
        fmt.Println("Condition check failed: PK exists but Status is not Completed.")
    } else {
        fmt.Printf("Delete failed: %v\n", err)
    }
} else {
    fmt.Println("Delete succeeded.")
}

实际运行时，项不存在时会触发ConditionalCheckFailedException，而非返回成功。原以为attribute_not_exists(PK)在项不存在时会判定为true，但不符合预期，需解决该问题并保留存在时的条件检查。

解决方案 #

核心原因 #

DynamoDB的DeleteItem条件表达式评估规则：

• 若指定主键的项不存在，无论条件表达式内容是什么，都会直接判定条件不满足，触发ConditionalCheckFailedException
• attribute_not_exists(PK)仅针对「已存在的项中是否缺少PK属性」，而PK是主键，所有存在的项必然包含PK，因此该表达式永远不会为true

正确实现方式 #

要满足需求，需调整条件表达式和错误处理逻辑：

1. 条件表达式仅约束存在的项必须满足Status条件：attribute_exists(PK) AND #status = :statusValue
2. 在错误处理中，捕获ConditionalCheckFailedException，区分「项不存在」和「项存在但Status不符合」两种情况，将前者视为操作成功

修改后的Go代码 #

import (
    "fmt"
    "strings"

    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/service/dynamodb"
)

func deleteItemWithCondition(dynamodbSvc *dynamodb.DynamoDB) {
    deleteInput := &dynamodb.DeleteItemInput{
        TableName: aws.String("YourTableName"),
        Key: map[string]*dynamodb.AttributeValue{
            "PK": {S: aws.String("PrimaryKeyValue")},
        },
        // 仅当项存在时，要求Status等于指定值
        ConditionExpression: aws.String("attribute_exists(PK) AND #status = :statusValue"),
        ExpressionAttributeNames: map[string]*string{
            "#status": aws.String("Status"),
        },
        ExpressionAttributeValues: map[string]*dynamodb.AttributeValue{
            ":statusValue": {S: aws.String("Completed")},
        },
    }

    _, err := dynamodbSvc.DeleteItem(deleteInput)
    if err != nil {
        if condErr, ok := err.(*dynamodb.ConditionalCheckFailedException); ok {
            // 通过错误信息区分两种失败场景
            errMsg := condErr.Error()
            if strings.Contains(errMsg, "#status") {
                fmt.Println("Condition check failed: Item exists but Status is not Completed.")
            } else {
                fmt.Println("Item does not exist, delete operation considered successful.")
            }
        } else {
            fmt.Printf("Delete failed: %v\n", err)
        }
        return
    }

    fmt.Println("Delete succeeded: Item existed and Status was Completed.")
}

补充说明 #

• 若需要更精准的错误区分，可结合ReturnValues: aws.String("ALL_OLD")参数：当操作成功且项存在时，result.Attributes会返回被删除项的属性；若项不存在，即使触发异常，也可通过逻辑推断处理
• 该方案严格符合「单个请求完成」的要求，无需额外查询或事务

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