Golang调用DynamoDB.DeleteItem删除不存在条目无报错问题

DynamoDB的DeleteItem接口默认是幂等设计：无论传入的主键对应的条目是否存在，接口都会返回成功响应，不会主动抛出错误，这是服务端的预设行为，和Golang SDK版本、调用方式无关。

不要采用「先查询条目是否存在、再执行删除」的分步逻辑，该逻辑存在竞态风险：查询完成到删除执行的间隙如果条目被其他请求删除，依然会触发无提示删空的问题。

最稳妥的方案是在删除请求中内置存在性条件，让DynamoDB在原子操作内完成存在性校验+删除，条目不存在时直接返回明确错误：

• 给DeleteItem请求添加ConditionExpression参数，声明仅当主键属性存在时才执行删除
• 捕获请求返回的ConditionalCheckFailedException类型错误，即可精准识别「待删除实体不存在」的场景

Golang 代码实现（基于aws-sdk-go-v2） #

import (
	"context"
	"errors"
	"github.com/aws/aws-sdk-go-v2/aws"
	"github.com/aws/aws-sdk-go-v2/service/dynamodb"
	"github.com/aws/aws-sdk-go-v2/service/dynamodb/types"
)

// DeleteExistedItem 删除指定主键的条目，条目不存在时返回明确错误
func DeleteExistedItem(ctx context.Context, ddbClient *dynamodb.Client, tableName, partitionKeyName, partitionKeyValue string) error {
	_, err := ddbClient.DeleteItem(ctx, &dynamodb.DeleteItemInput{
		TableName: aws.String(tableName),
		Key: map[string]types.AttributeValue{
			partitionKeyName: &types.AttributeValueMemberS{Value: partitionKeyValue},
		},
		// 核心：配置删除条件，仅当主键存在时才执行删除操作
		ConditionExpression: aws.String("attribute_exists(#pk)"),
		ExpressionAttributeNames: map[string]string{
			"#pk": partitionKeyName,
		},
	})
	if err != nil {
		// 匹配条件校验失败错误，即为条目不存在场景
		var checkFailedErr *types.ConditionalCheckFailedException
		if errors.As(err, &checkFailedErr) {
			return errors.New("target entity does not exist")
		}
		return err
	}
	return nil
}

方案说明 #

• 条件校验是DynamoDB原子操作的一部分，不存在竞态风险
• 带条件的删除请求和普通删除请求的计费标准完全一致，不会产生额外的读写容量消耗
• 如果使用v1版本的AWS Golang SDK，逻辑完全一致，仅需将错误类型替换为v1版本对应的dynamodb.ConditionalCheckFailedException做匹配即可

如果你需要在删除的同时获取被删除条目的原有属性，可以将请求的ReturnValues参数设置为ALL_OLD，删除完成后判断返回的Attributes字段长度：如果为空则说明待删除的条目原本不存在，示例代码片段如下：

resp, err := ddbClient.DeleteItem(ctx, &dynamodb.DeleteItemInput{
	TableName: aws.String(tableName),
	Key: map[string]types.AttributeValue{
		partitionKeyName: &types.AttributeValueMemberS{Value: partitionKeyValue},
	},
	ReturnValues: types.ReturnValueAllOld,
})
if err != nil {
	return err
}
if len(resp.Attributes) == 0 {
	return errors.New("target entity does not exist")
}
// 此处可通过resp.Attributes获取被删除条目的全量旧属性

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