用Apache Camel测试Localstack AWS

Question

我正在尝试利用localstack来进行本地AWS模拟测试。具体地说，我希望使用Apache CamelS3路由从LocalStackS3桶下载一个文件。然而，我遇到了错误。以下是我采取的步骤...

aws --endpoint-url=http://localhost:4572 s3 mb s3://mytestbucket

然后，我上传了一个测试文件到这个桶里...

aws --endpoint-url=http://localhost:4572 s3 cp docker-compose.yml s3://mytestbucket

两个操作都成功完成。在我的Java代码中，我创建了一个CDI生成器来生成com.amazonaws.services.s3.amazons3客户端对象...

AWSCredentials credentials = new BasicAWSCredentials("XXXXX", "XXXXX");
AWSCredentialsProvider credentialsProvider = new AWSStaticCredentialsProvider(credentials);
AmazonS3ClientBuilder clientBuilder = AmazonS3ClientBuilder.standard()
                .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration("http://localhost:4572", "us-east-1"))
                .withCredentials(credentialsProvider);

AmazonS3 s3Client = clientBuilder.build();  

最后，我创建了一个骆驼路由，旨在将mytestbucket的内容下载到一个本地目录中...

<route id="s3test">
        <from
            uri="aws-s3://arn:aws:s3:::mytestbucket?amazonS3Client=#s3Client&amp;deleteAfterRead=false&amp;maxMessagesPerPoll=25&amp;delay=5000" />
        <log message="S3 consumer fired" loggingLevel="DEBUG" />
        <log message="Sending S3 file to ${in.header.CamelAwsS3Key}..." />
        <to
            uri="file://tmp/camel?fileName=${in.header.CamelAwsS3Key}" />
    </route>

我认为，由于我的AmazonS3客户机特别指出http://localhost:4572是我的endpoint，所以它不应该访问实际的S3服务。情况似乎是这样的，但由于某种原因，它试图访问myTestBucket.localhost就好像它是一个网络主机一样。知道我在这里做错了什么吗，或者为什么这个路由/配置不起作用吗？

Answer 1

对于遇到此问题的其他任何人来说,答案在于创建如下所示的客户端：

AWSCredentials credentials = new BasicAWSCredentials("XXXXX", "YYYYY");
AWSCredentialsProvider credentialsProvider = new AWSStaticCredentialsProvider(credentials);
AmazonS3ClientBuilder clientBuilder = AmazonS3ClientBuilder.standard().withPathStyleAccessEnabled(true)
                    .disableChunkedEncoding()
                    .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(S3_ENDPOINT, "us-east-1"))
                    .withCredentials(credentialsProvider);

关键字是.WithPathStyledAccessEnabled(true)。添加它将正确生成endpointURL。