|
11 | 11 | import software.amazon.awssdk.services.s3.S3Client; |
12 | 12 | import software.amazon.awssdk.services.s3.presigner.S3Presigner; |
13 | 13 |
|
| 14 | +import java.net.URI; |
| 15 | + |
14 | 16 | @Configuration |
15 | 17 | public class S3Config { |
16 | 18 |
|
17 | | - @Value("${aws.s3.accessKeyId}") |
18 | | - private String accessKeyId; |
| 19 | + @Value("${cloud.r2.credentials.access-key}") |
| 20 | + private String r2AccessKey; |
| 21 | + |
| 22 | + @Value("${cloud.r2.credentials.secret-key}") |
| 23 | + private String r2SecretKey; |
| 24 | + |
| 25 | + @Value("${cloud.r2.endpoint}") |
| 26 | + private String endpoint; |
19 | 27 |
|
20 | | - @Value("${aws.s3.secretAccessKey}") |
21 | | - private String secretAccessKey; |
| 28 | + @Value("${aws.lambda.access-key}") |
| 29 | + private String lambdaAccessKey; |
| 30 | + |
| 31 | + @Value("${aws.lambda.scret-key}") |
| 32 | + private String lambdaSecretKey; |
22 | 33 |
|
23 | 34 | @Bean |
24 | 35 | public S3Client s3Client() { |
25 | | - AwsBasicCredentials credentials = AwsBasicCredentials.create(accessKeyId, secretAccessKey); |
| 36 | + AwsBasicCredentials credentials = AwsBasicCredentials.create(r2AccessKey, r2SecretKey); |
26 | 37 | AwsCredentialsProvider provider = StaticCredentialsProvider.create(credentials); |
27 | 38 |
|
28 | 39 | return S3Client.builder() |
29 | | - .region(Region.AP_NORTHEAST_2) |
| 40 | + .region(Region.of("auto")) |
| 41 | + .endpointOverride(URI.create(endpoint)) |
30 | 42 | .credentialsProvider(provider) |
31 | 43 | .build(); |
32 | 44 | } |
33 | 45 |
|
34 | 46 | @Bean |
35 | 47 | public S3Presigner s3Presigner() { |
36 | | - AwsBasicCredentials credentials = AwsBasicCredentials.create(accessKeyId, secretAccessKey); |
| 48 | + AwsBasicCredentials credentials = AwsBasicCredentials.create(r2AccessKey, r2SecretKey); |
37 | 49 | AwsCredentialsProvider provider = StaticCredentialsProvider.create(credentials); |
38 | 50 |
|
39 | 51 | return S3Presigner.builder() |
40 | | - .region(Region.AP_NORTHEAST_2) |
| 52 | + .region(Region.of("auto")) |
| 53 | + .endpointOverride(URI.create(endpoint)) |
41 | 54 | .credentialsProvider(provider) |
42 | 55 | .build(); |
43 | 56 | } |
44 | 57 |
|
45 | 58 | @Bean |
46 | 59 | public LambdaClient lambdaClient() { |
47 | | - AwsBasicCredentials credentials = AwsBasicCredentials.create(accessKeyId, secretAccessKey); |
| 60 | + AwsBasicCredentials credentials = AwsBasicCredentials.create(lambdaAccessKey, lambdaSecretKey); |
48 | 61 | AwsCredentialsProvider provider = StaticCredentialsProvider.create(credentials); |
49 | 62 |
|
50 | 63 | return LambdaClient.builder() |
|
0 commit comments