java - 如何设置不需要凭据的 Localstack 容器?

我有以下代码片段,应该在 AWS Lambda 函数中运行:

AWSSecretsManager client = AWSSecretsManagerClientBuilder.standard().withRegion(AWS_REGION).build();
GetSecretValueRequest getSecretValueRequest = new GetSecretValueRequest().withSecretId(SECRET_NAME);
GetSecretValueResult secretValue = client.getSecretValue(getSecretValueRequest);

由于 lambda 函数将在与 secret 管理器相同的 VPC 中运行,因此我不必为其提供凭证(AWS_ACCESS_KEY_IDAWS_SECRET_ACCESS_KEY)。

我将 Localstack 与 Testcontainers 一起用于集成测试,并在测试设置中设置 secret ,如下所示:

AWSSecretsManager secretsManager = AWSSecretsManagerClientBuilder.standard()
        .withEndpointConfiguration(secretsmanager.getEndpointConfiguration(SECRETSMANAGER))
        .withCredentials(secretsmanager.getDefaultCredentialsProvider())
        .build();
String secretString = "{'engine':'mysql','port':" + mysql.getMappedPort(3306) + ",'host':'" + mysql.getContainerIpAddress() + "'}";
CreateSecretRequest request = new CreateSecretRequest().withName("aurora")
        .withSecretString(secretString)
        .withRequestCredentialsProvider(secretsmanager.getDefaultCredentialsProvider());
secretsManager.createSecret(request);

现在测试崩溃并报错:

com.amazonaws.services.secretsmanager.model.AWSSecretsManagerException: 
The security token included in the request is invalid. 
(Service: AWSSecretsManager; 
Status Code: 400; Error Code: 
UnrecognizedClientException; 
Request ID: ...

这里也是测试中使用的localstack容器的定义:

@ClassRule
public static LocalStackContainer secretsmanager = new LocalStackContainer("0.10.4")
    .withServices(LocalStackContainer.Service.SECRETSMANAGER)
    .withEnv("DEFAULT_REGION", "eu-west-1")
    .withExposedPorts(4584);

我如何配置 LocalStackContainer 以在不进行任何凭据验证的情况下接受请求?

最佳答案

假设您是一个合理的 java 开发人员,更喜欢 spring boot 测试和 junit5 而不是替代品,@DynamicPropertySource 在这里会非常方便

private static final LocalStackContainer LOCALSTACK = ...;

@DynamicPropertySource
static void setCredentials(DynamicPropertyRegistry registry) {
    var credentials = LOCALSTACK.getDefaultCredentialsProvider().getCredentials();
    registry.add("cloud.aws.region.static", () -> "eu-central-1");
    registry.add("cloud.aws.credentials.access-key", () -> credentials.getAWSAccessKeyId());
    registry.add("cloud.aws.credentials.secret-key", () -> credentials.getAWSSecretKey());
    registry.add("cloud.aws.s3.endpoint", () -> LOCALSTACK.getEndpointOverride(S3));
}

另外请仔细检查您是否覆盖了您所依赖的端点(在我的示例中为 s3),否则您可能会请求真正的 AWS API 而不是容器化的 API

https://stackoverflow.com/questions/58914341/

相关文章:

matplotlib - 如何在 seaborn 中有一个带有暗网格背景的透明图形?

azure - 从 Azure 部署中排除 Azure Function 中的文件

gradle - pivotal/LicenseFinder 为 Gradle 项目返回 "No d

android-studio - 为什么我只看到官方 android 类的反编译源代码?

amazon-web-services - 状态机忽略阶跃函数错误

python - 如何使用需要使用 MLflow 的二维以上输入形状的模型进行预测?

javascript - 单击通知打开已安装的 PWA

react-native - 从选项卡导航选项卡打开抽屉导航

pycharm - 文件级无检查 PyCharm

python - 鼠兔连接丢失 Error : pika. exceptions.StreamLos