Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <dependency>
- <groupId>commons-io</groupId>
- <artifactId>commons-io</artifactId>
- <version>2.5</version>
- </dependency>
- private static final String PATH_BASE = "//Users/farithjhg/Desktop/";
- private static final String MINIO_SECRETACCESSKEY = "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY";
- private static final String MINIO_ACCESSKEYID = "AKIAIOSFODNN7EXAMPLE";
- private static final String AWS_SECRET_KEY = "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";
- private static final String AWS_ACCESS_KEY = "AKIA4WLFPEEI2YBY5IMW";
- private static AmazonS3 accesingMyS3() {
- AWSCredentials credentials = new BasicAWSCredentials(MINIO_ACCESSKEYID, MINIO_SECRETACCESSKEY);
- ClientConfiguration clientConfiguration = new ClientConfiguration();
- clientConfiguration.setSignerOverride("AWSS3V4SignerType");
- AmazonS3 s3Client = AmazonS3ClientBuilder.standard()
- .withEndpointConfiguration(
- new AwsClientBuilder.EndpointConfiguration("http://localhost:9001", Regions.US_EAST_1.name()))
- .withPathStyleAccessEnabled(true).withClientConfiguration(clientConfiguration)
- .withCredentials(new AWSStaticCredentialsProvider(credentials)).build();
- log.info("Listing Buckets from MinIO");
- listBuckets(s3Client);
- String bucketName = "aml-s3-b1";
- // createBucket(s3Client, bucketName );
- // listBuckets(s3Client);
- listingObjects(s3Client, bucketName);
- String keyName = "openapi.yaml";
- try {
- downloadingObjects(s3Client, bucketName, keyName);
- } catch (IOException e) {
- e.printStackTrace();
- }
- String keyName2 = "newswagger.yaml";
- File fileName = new File(PATH_BASE + keyName2);
- uploadingFile(s3Client, bucketName, fileName);
- listingObjects(s3Client, bucketName);
- log.info("getObjectAsString::"+keyName);
- log.info(getObjectAsString(s3Client, bucketName, keyName));
- return s3Client;
- }
- private static void accessingS3() {
- AWSCredentials credentials = new BasicAWSCredentials(AWS_ACCESS_KEY, AWS_SECRET_KEY);
- AmazonS3 s3client = AmazonS3ClientBuilder.standard()
- .withCredentials(new AWSStaticCredentialsProvider(credentials)).withRegion(Regions.US_EAST_2).build();
- log.info("Listing Buckets from AWS");
- listBuckets(s3client);
- }
- private static void listBuckets(AmazonS3 s3client) {
- List<Bucket> buckets = s3client.listBuckets();
- for (Bucket bucket : buckets) {
- log.info(bucket.getName());
- }
- }
- private static void createBucket(AmazonS3 s3client, String bucketName) {
- if (s3client.doesBucketExistV2(bucketName)) {
- log.info("Bucket name is not available." + " Try again with a different Bucket name.");
- return;
- }
- s3client.createBucket(bucketName);
- }
- private static void deletingBuckets(AmazonS3 s3client, String bucketName) {
- try {
- s3client.deleteBucket(bucketName);
- } catch (AmazonServiceException e) {
- log.error(e.getErrorMessage());
- return;
- }
- }
- private static void uploadingFile(AmazonS3 s3client, String bucketName, File fileName) {
- s3client.putObject(bucketName, fileName.getName(), fileName);
- }
- private static String getObjectAsString(AmazonS3 s3client, String bucketName, String keyName) {
- return s3client.getObjectAsString(bucketName,keyName);
- }
- private static void listingObjects(AmazonS3 s3client, String bucketName) {
- ObjectListing objectListing = s3client.listObjects(bucketName);
- for (S3ObjectSummary os : objectListing.getObjectSummaries()) {
- log.info(os.getKey() + "::Size:" + os.getSize());
- }
- }
- private static void downloadingObjects(AmazonS3 s3client, String bucketName, String keyName) throws IOException {
- S3Object s3object = s3client.getObject(bucketName, keyName);
- S3ObjectInputStream inputStream = s3object.getObjectContent();
- FileUtils.copyInputStreamToFile(inputStream, new File(PATH_BASE + keyName));
- }
- private static void copyingFromBucket1ToBucket2(AmazonS3 s3client, String bucketName1, String keyName1,
- String bucketName2, String keyName2) {
- s3client.copyObject(bucketName1, keyName1, bucketName2, keyName2);
- }
- private static void deletingObjectFromBucket(AmazonS3 s3client, String bucketName, String keyName) {
- s3client.deleteObject(bucketName, keyName);
- }
- private static void deletingMultipleObjects(AmazonS3 s3client, String bucketName, String[] objkeyArr) {
- DeleteObjectsRequest delObjReq = new DeleteObjectsRequest(bucketName).withKeys(objkeyArr);
- s3client.deleteObjects(delObjReq);
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement