DynamoDB多排序键场景下Map属性转换器异常排查求助

操作单分区键对应多排序键的DynamoDB表，需查询同一分区键下的所有条目。定义了包含分区键pk、排序键sk，以及存储各类属性的Map<String, AttributeValue>的ProfileModel，但应用启动时抛出IllegalStateException，提示找不到EnhancedType<Map<String, AttributeValue>>对应的转换器。

ProfileDynamoDb.java #

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import software.amazon.awssdk.core.pagination.sync.SdkIterable;
import software.amazon.awssdk.enhanced.dynamodb.*;
import software.amazon.awssdk.enhanced.dynamodb.model.*;
import software.amazon.awssdk.services.dynamodb.model.AttributeValue;
import software.amazon.awssdk.services.dynamodb.model.DynamoDbException;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Slf4j
@Repository
public class ProfileDynamoDb {

    private final DynamoDbTable<ProfileModel> table;
    private final DynamoDbEnhancedClient enhancedClient;

    @Autowired
    public ProfileDynamoDb(DynamoDbEnhancedClient enhancedClient) {
        this.enhancedClient = enhancedClient;
        table = enhancedClient.table("profiles", TableSchema.fromBean(ProfileModel.class));
    }
    public List<ProfileModel> fetchByPartitionKey(String profileName) {
        try {
            QueryConditional queryConditional = QueryConditional.keyEqualTo(k -> k.partitionValue("PROFILE#" + profileName));
            SdkIterable<ProfileModel> results = table.query(r -> r.queryConditional(queryConditional)).items();
            return results.stream().toList();
        } catch (DynamoDbException e) {
            log.error("Error while getting profile by name: {}", profileName, e);
            throw e;
        }
    }

}

ProfileModel.java #

import lombok.Data;
import software.amazon.awssdk.enhanced.dynamodb.internal.converter.attribute.MapAttributeConverter;
import software.amazon.awssdk.enhanced.dynamodb.mapper.annotations.*;
import software.amazon.awssdk.services.dynamodb.model.AttributeValue;

import java.util.HashMap;
import java.util.Map;

@Data
@DynamoDbBean
public class ProfileModel {
    private String pk;
    private String sk;
    private Map<String, AttributeValue> attributes = new HashMap<>();

    public void addAttribute(String key, AttributeValue value) {
        attributes.put(key, value);
    }

    @DynamoDbAttribute("Attributes")
    @DynamoDbConvertedBy(MapAttributeConverter.class)
    public Object getAttribute(String key) {
        return attributes.get(key);
    }

    @DynamoDbPartitionKey
    public String getPk() {
        return pk;
    }

    @DynamoDbSortKey
    public String getSk() {
        return sk;
    }
}

错误信息 #

Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [com.booking.profile.infrastructure.dynamodb.ProfileDynamoDb]: Constructor threw exception
Caused by: java.lang.IllegalStateException: Converter not found for EnhancedType(java.util.Map<java.lang.String, software.amazon.awssdk.services.dynamodb.model.AttributeValue>)

1. 错误原因 #

• ProfileModel中attributes字段的映射逻辑错误：定义了Map<String, AttributeValue>类型的成员变量，但提供的getAttribute方法仅返回单个key对应的值，而非整个Map，导致增强客户端无法识别该字段的完整类型。
• 使用的MapAttributeConverter是AWS SDK内部实现类，且默认不支持Map<String, AttributeValue>这种直接映射原生DynamoDB属性值的类型转换——增强客户端设计初衷是自动完成Java对象与DynamoDB属性的映射，而非直接暴露AttributeValue。

2. 修复方案 #

修改ProfileModel，正确映射整个attributes Map，并移除错误的转换器配置：

import lombok.Data;
import software.amazon.awssdk.enhanced.dynamodb.mapper.annotations.*;
import software.amazon.awssdk.services.dynamodb.model.AttributeValue;

import java.util.HashMap;
import java.util.Map;

@Data
@DynamoDbBean
public class ProfileModel {
    private String pk;
    private String sk;
    private Map<String, AttributeValue> attributes = new HashMap<>();

    public void addAttribute(String key, AttributeValue value) {
        attributes.put(key, value);
    }

    // 正确返回整个Map字段，指定DynamoDB列名
    @DynamoDbAttribute("Attributes")
    public Map<String, AttributeValue> getAttributes() {
        return attributes;
    }

    @DynamoDbPartitionKey
    public String getPk() {
        return pk;
    }

    @DynamoDbSortKey
    public String getSk() {
        return sk;
    }
}

若追求类型安全（避免直接操作AttributeValue），可将attributes改为Map<String, Object>，增强客户端会自动完成Java类型与DynamoDB属性类型的双向转换：

// 替换属性定义
private Map<String, Object> attributes = new HashMap<>();

// 对应的getter
@DynamoDbAttribute("Attributes")
public Map<String, Object> getAttributes() {
    return attributes;
}

3. Spring Boot + AWS Java SDK定义Map属性的正确方式 #

• 若需直接操作DynamoDB原生AttributeValue，使用Map<String, AttributeValue>类型，确保提供返回整个Map的getter/setter，增强客户端会自动适配，无需额外转换器。
• 优先使用Map<String, Object>实现类型安全，AWS增强客户端会自动处理Java类型与DynamoDB属性的双向转换，无需手动指定转换器。
• 禁止使用SDK内部转换器类（如MapAttributeConverter），这类属于内部实现，无对外兼容性保障。

4. 同分区多排序键场景的处理方法 #

• 查询全部分区条目：使用QueryConditional.keyEqualTo()指定分区键值，query操作会自动返回该分区下所有排序键对应的条目，即你现有代码的实现逻辑。
• 分页查询：若条目数量大，通过query()的limit()和exclusiveStartKey()实现分页，避免一次性加载大量数据。
• 排序与范围过滤：通过sort()指定排序方向，或用sortBetween/sortLessThan等条件过滤特定排序键范围的条目，示例：

  QueryConditional conditional = QueryConditional.sortBetween(
      k -> k.partitionValue("PROFILE#" + profileName).sortValue("SK_001"),
      k -> k.partitionValue("PROFILE#" + profileName).sortValue("SK_009")
  );
  SdkIterable<ProfileModel> results = table.query(r -> r.queryConditional(conditional)
          .sort(SortOrder.ASCENDING)).items();
  

• 全局二级索引（GSI）：若需按其他维度查询，可创建GSI，将目标字段设为GSI的分区键或排序键。

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