Spring Boot 2连接多AWS账户DynamoDB的配置问题求助

1. 核心思路 #

多账户DynamoDB连接的关键是为不同账户的连接Bean分配唯一名称，避免与默认Bean冲突，同时在使用时明确指定要注入的Bean标识。

2. 新增第二个账户的配置类 #

不要复用默认的amazonDynamoDB、dynamoDBMapper Bean名称，给新Bean起专属命名，比如secondaryAmazonDynamoDB、secondaryDynamoDBMapper：

import com.amazonaws.auth.AWSStaticCredentialsProvider;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDB;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClientBuilder;
import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapper;
import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapperConfig;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class SecondaryDynamoDBConfig {

    @Value("${aws.secondary.access-key}")
    private String secondaryAccessKey;
    @Value("${aws.secondary.secret-key}")
    private String secondarySecretKey;
    @Value("${aws.secondary.region}")
    private String secondaryRegion;
    @Value("${aws.secondary.dynamodb-endpoint:#{null}}")
    private String secondaryEndpoint;

    @Bean(name = "secondaryAmazonDynamoDB")
    public AmazonDynamoDB secondaryAmazonDynamoDB() {
        BasicAWSCredentials credentials = new BasicAWSCredentials(secondaryAccessKey, secondarySecretKey);
        AmazonDynamoDBClientBuilder builder = AmazonDynamoDBClientBuilder.standard()
                .withCredentials(new AWSStaticCredentialsProvider(credentials))
                .withRegion(secondaryRegion);

        // 若使用自定义端点（如本地测试），添加以下配置
        if (secondaryEndpoint != null) {
            builder.withEndpointConfiguration(
                    new com.amazonaws.client.builder.AwsClientBuilder.EndpointConfiguration(
                            secondaryEndpoint, secondaryRegion));
        }

        return builder.build();
    }

    @Bean(name = "secondaryDynamoDBMapper")
    public DynamoDBMapper secondaryDynamoDBMapper() {
        // 若第二个账户的表有特殊配置（如前缀），可自定义DynamoDBMapperConfig
        DynamoDBMapperConfig config = DynamoDBMapperConfig.DEFAULT;
        return new DynamoDBMapper(secondaryAmazonDynamoDB(), config);
    }
}

3. 自定义仓库时指定注入的Bean #

在仓库类中，通过@Qualifier注解明确指定要注入的第二个账户的Bean，避免和默认Bean混淆：

import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapper;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Repository;

@Repository
public class SecondaryDynamoDBRepository {

    private final DynamoDBMapper dynamoDBMapper;

    // 用@Qualifier指定注入第二个账户的Mapper
    public SecondaryDynamoDBRepository(@Qualifier("secondaryDynamoDBMapper") DynamoDBMapper dynamoDBMapper) {
        this.dynamoDBMapper = dynamoDBMapper;
    }

    // 示例查询方法
    public <T> T getTableItem(Class<T> clazz, Object primaryKey) {
        return dynamoDBMapper.load(clazz, primaryKey);
    }
}

4. 配置文件补充 #

在application.yml（或application.properties）中添加第二个账户的配置项：

aws:
  secondary:
    access-key: 你的第二个账户AccessKey
    secret-key: 你的第二个账户SecretKey
    region: us-east-1
    # dynamodb-endpoint: https://dynamodb.us-east-1.amazonaws.com  # 可选，默认按region自动生成

错误原因说明 #

• 第一个错误：你尝试注册与默认同名的dynamoDB-DynamoDBMapper Bean，Spring默认禁止覆盖已有Bean，给新Bean起唯一名称即可解决。
• 第二个错误：自定义仓库默认尝试注入名为amazonDynamoDB的默认Bean，但你的配置未明确指定要注入的目标Bean，通过@Qualifier指定专属Bean名称即可修复。

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