Skip to content

Instantly share code, notes, and snippets.

@ualter
Created June 5, 2020 10:38
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save ualter/360422f99503c9aecca93edd1fa7a641 to your computer and use it in GitHub Desktop.
Save ualter/360422f99503c9aecca93edd1fa7a641 to your computer and use it in GitHub Desktop.
package com.amazonaws.sandbox.s3.multipart.lowlevel;
import java.io.File;
import java.util.List;
import com.amazonaws.ClientConfiguration;
import com.amazonaws.Protocol;
import com.amazonaws.auth.PropertiesFileCredentialsProvider;
import com.amazonaws.client.builder.AwsClientBuilder;
import com.amazonaws.client.builder.AwsClientBuilder.EndpointConfiguration;
import com.amazonaws.regions.Regions;
import com.amazonaws.retry.PredefinedRetryPolicies;
import com.amazonaws.sandbox.iam.IAMSandbox;
import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3ClientBuilder;
import com.amazonaws.services.s3.model.ListMultipartUploadsRequest;
import com.amazonaws.services.s3.model.MultipartUpload;
import com.amazonaws.services.s3.model.MultipartUploadListing;
public class S3ListMultiPartUploads {
public static void main(String[] args) {
S3ListMultiPartUploads listUploads = new S3ListMultiPartUploads("tasadoratest", false);
listUploads.startListening();
}
private String bucket;
private AmazonS3 s3;
private boolean endListening = false;
private boolean listWhileInProcess = false;
public S3ListMultiPartUploads(String bucket, boolean listWhileInProcess) {
this.bucket = bucket;
this.listWhileInProcess = listWhileInProcess;
}
public void startListening() {
AmazonS3 s3 = S3ClientConnection.S3Client("tasadora-test");
// Retrieve a list of all in-progress multipart uploads.
ListMultipartUploadsRequest allMultipartUploadsRequest = new ListMultipartUploadsRequest(this.bucket);
MultipartUploadListing multipartUploadListing = s3.listMultipartUploads(allMultipartUploadsRequest);
List<MultipartUpload> uploads = multipartUploadListing.getMultipartUploads();
// Display information about all in-progress multipart uploads.
System.out.println(uploads.size() + " multipart upload(s) in progress.");
while( uploads.size() > 0 && !endListening) {
for (MultipartUpload u : uploads) {
System.out.println("Upload in progress: Key = \"" + u.getKey() + "\"" + ", UploadId:" + u.getUploadId());
}
if ( !this.listWhileInProcess ) {
break;
}
multipartUploadListing = s3.listMultipartUploads(allMultipartUploadsRequest);
uploads = multipartUploadListing.getMultipartUploads();
}
}
}conn
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment