Guest User

Untitled

a guest
Dec 10th, 2017
87
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.07 KB | None | 0 0
  1. S3AsyncClient client = S3AsyncClient.create();
  2. final CompletableFuture<GetObjectResponse> futureGet =
  3. client.getObject(
  4. GetObjectRequest.builder()
  5. .bucket(awsS3Config.getBucketName())
  6. .key(finalKeyName)
  7. .build(),
  8.  
  9. AsyncResponseHandler.toFile(Paths.get(s3TmpFile.getAbsolutePath())));
  10. futureGet.whenComplete((resp, err) -> {
  11. try {
  12. if (resp != null) {
  13. System.out.println(resp);
  14. } else {
  15. // Handle error
  16. err.printStackTrace();
  17. }
  18. } finally {
  19. // Lets the application shut down. Only close the client when you are completely done with it
  20. FunctionalUtils.invokeSafely(client::close);
  21. }
  22. });
  23.  
  24. if (ENVIRONMENT_LOCAL)
  25. {
  26. ClientConfiguration clientConfig = new ClientConfiguration();
  27. clientConfig.setProtocol(Protocol.HTTP);
  28. clientConfig.setProxyHost(8888);
  29.  
  30. //Attempt to connect using Access Key and SecretKey
  31. BasicAWSCredentials basicAWSCredentials = new BasicAWSCredentials(awsS3Config.getIamKey(), awsS3Config.getIamSecretKey());
  32.  
  33. clientConfig.setProxyHost("myproxyhost.bla");
  34. clientConfig.setProxyPort(8888);
  35. AWSStaticCredentialsProvider
  36. awsStaticCredentialsProvider =
  37. new AWSStaticCredentialsProvider(basicAWSCredentials);
  38.  
  39. this.amazonS3 = AmazonS3ClientBuilder.standard()
  40. .withRegion(awsS3Config.getRegion())
  41. .withClientConfiguration(clientConfig)
  42. .withCredentials(awsStaticCredentialsProvider)
  43. .build();
  44. }
  45. else //not local env, use EC2 instance authentication
  46. {
  47. this.amazonS3 = AmazonS3ClientBuilder.standard()
  48. .withRegion(awsS3Config.getRegion())
  49. .withCredentials(new
  50. InstanceProfileCredentialsProvider(false))
  51. .build();
  52. }
Add Comment
Please, Sign In to add comment