Created
June 5, 2020 10:38
-
-
Save ualter/360422f99503c9aecca93edd1fa7a641 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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