如何通过SDK在DynamoDB中正确存储复杂对象适配Java POJO映射？

你的核心问题是插入时未正确配置嵌套对象的映射规则，导致Address被序列化为JSON字符串而非DynamoDB标准的嵌套文档类型。以下是具体解决方案：

方案1：使用DynamoDBMapper（推荐） #

通过AWS SDK的DynamoDBMapper配合注解，自动将嵌套POJO映射为DynamoDB的嵌套文档：

修改POJO注解 #

给实体类添加DynamoDB映射注解，标记嵌套对象为文档类型：

import com.amazonaws.services.dynamodbv2.datamodeling.*;

@DynamoDBTable(tableName = "PersonTable")
public class Person {
    private int age;
    private String name;
    private Address address;

    @DynamoDBAttribute
    public int getAge() { return age; }
    public void setAge(int age) { this.age = age; }

    @DynamoDBAttribute
    public String getName() { return name; }
    public void setName(String name) { this.name = name; }

    @DynamoDBAttribute
    public Address getAddress() { return address; }
    public void setAddress(Address address) { this.address = address; }
}

// 标记该类为可嵌套的DynamoDB文档
@DynamoDBDocument
public class Address {
    private String street;
    private String country;

    @DynamoDBAttribute
    public String getStreet() { return street; }
    public void setStreet(String street) { this.street = street; }

    @DynamoDBAttribute
    public String getCountry() { return country; }
    public void setCountry(String country) { this.country = country; }
}

插入数据 #

使用DynamoDBMapper的save方法插入，自动处理嵌套对象映射：

AmazonDynamoDB client = AmazonDynamoDBClientBuilder.standard().build();
DynamoDBMapper mapper = new DynamoDBMapper(client);

Address addr = new Address();
addr.setStreet("1");
addr.setCountry("IN");

Person person = new Person();
person.setAge(30);
person.setName("张三");
person.setAddress(addr);

mapper.save(person);

方案2：手动构造Item（无注解方式） #

若不使用DynamoDBMapper，手动构造Item时需将Address转为Map<String, AttributeValue>而非字符串：

AmazonDynamoDB client = AmazonDynamoDBClientBuilder.standard().build();

// 构造Address的嵌套属性Map
Map<String, AttributeValue> addressAttrs = new HashMap<>();
addressAttrs.put("street", new AttributeValue().withS("1"));
addressAttrs.put("country", new AttributeValue().withS("IN"));

// 构造完整Item
Map<String, AttributeValue> item = new HashMap<>();
item.put("age", new AttributeValue().withN("30"));
item.put("name", new AttributeValue().withS("张三"));
// 用withM标记为嵌套Map类型
item.put("Address", new AttributeValue().withM(addressAttrs));

PutItemRequest request = new PutItemRequest()
        .withTableName("PersonTable")
        .withItem(item);

client.putItem(request);

Lambda端读取处理 #

Lambda读取DynamoDB记录时，直接用DynamoDBMapper或Jackson即可完成POJO映射：

• 用DynamoDBMapper：调用mapper.load(Person.class, 分区键值)直接获取实体对象
• 用Jackson：确保POJO结构与DynamoDB存储的嵌套结构一致，通过ObjectMapper解析即可

补充说明 #

• 已存储为字符串的旧数据需批量更新：读取字符串后解析为Address对象，再重新存储为嵌套文档
• 确保插入端与Lambda端使用的AWS SDK版本一致，避免序列化兼容性问题

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