类com.amazonaws.services.s3.model.DeleteBucketRequest源码实例Demo

下面列出了怎么用com.amazonaws.services.s3.model.DeleteBucketRequest的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: localization_nifi   文件: AbstractS3IT.java
@AfterClass
public static void oneTimeTearDown() {
    // Empty the bucket before deleting it.
    try {
        ObjectListing objectListing = client.listObjects(BUCKET_NAME);

        while (true) {
            for (S3ObjectSummary objectSummary : objectListing.getObjectSummaries()) {
                client.deleteObject(BUCKET_NAME, objectSummary.getKey());
            }

            if (objectListing.isTruncated()) {
                objectListing = client.listNextBatchOfObjects(objectListing);
            } else {
                break;
            }
        }

        DeleteBucketRequest dbr = new DeleteBucketRequest(BUCKET_NAME);
        client.deleteBucket(dbr);
    } catch (final AmazonS3Exception e) {
        System.err.println("Unable to delete bucket " + BUCKET_NAME + e.toString());
    }

    if (client.doesBucketExist(BUCKET_NAME)) {
        Assert.fail("Incomplete teardown, subsequent tests might fail");
    }

}
 
源代码2 项目: nifi   文件: AbstractS3IT.java
@AfterClass
public static void oneTimeTearDown() {
    // Empty the bucket before deleting it.
    try {
        ObjectListing objectListing = client.listObjects(BUCKET_NAME);

        while (true) {
            for (S3ObjectSummary objectSummary : objectListing.getObjectSummaries()) {
                client.deleteObject(BUCKET_NAME, objectSummary.getKey());
            }

            if (objectListing.isTruncated()) {
                objectListing = client.listNextBatchOfObjects(objectListing);
            } else {
                break;
            }
        }

        DeleteBucketRequest dbr = new DeleteBucketRequest(BUCKET_NAME);
        client.deleteBucket(dbr);
    } catch (final AmazonS3Exception e) {
        System.err.println("Unable to delete bucket " + BUCKET_NAME + e.toString());
    }

    if (client.doesBucketExist(BUCKET_NAME)) {
        Assert.fail("Incomplete teardown, subsequent tests might fail");
    }

}
 
源代码3 项目: iaf   文件: AmazonS3FileSystem.java
/**
 * Deletes a bucket on Amazon S3.
 */
public String deleteBucket() throws SenderException {
	try {
		bucketDoesNotExist(bucketName);
		DeleteBucketRequest deleteBucketRequest = new DeleteBucketRequest(bucketName);
		s3Client.deleteBucket(deleteBucketRequest);
		log.debug("Bucket with bucketName [" + bucketName + "] is deleted.");
	} catch (AmazonServiceException e) {
		log.warn("Failed to delete bucket with bucketName [" + bucketName + "].");
		throw new SenderException("Failed to delete bucket with bucketName [" + bucketName + "].");
	}

	return bucketName;
}
 
源代码4 项目: Scribengin   文件: S3Client.java
public void deleteBucket(String bucketName, boolean recursive) throws AmazonClientException, AmazonServiceException {
  if(recursive) {
    deleteKeyWithPrefix(bucketName, "");
  }
  DeleteBucketRequest request = new DeleteBucketRequest(bucketName) ;
  s3Client.deleteBucket(request);
}
 
源代码5 项目: amazon-kinesis-connectors   文件: S3Utils.java
/**
 * Deletes an Amazon S3 bucket if it exists.
 * 
 * @param client The {@link AmazonS3Client} with read and write permissions
 * @param bucketName The Amazon S3 bucket to delete
 */
public static void deleteBucket(AmazonS3Client client, String bucketName) {
    if (bucketExists(client, bucketName)) {
        DeleteBucketRequest deleteBucketRequest = new DeleteBucketRequest(bucketName);
        client.deleteBucket(deleteBucketRequest);
        LOG.info("Deleted bucket " + bucketName);
    } else {
        LOG.warn("Bucket " + bucketName + " does not exist");
    }
}
 
@AfterClass
private void cleanUp() throws Exception {
    DeleteBucketRequest deleteBucketRequest = new DeleteBucketRequest(bucketName);

    s3Client.deleteBucket(deleteBucketRequest);
}
 
源代码7 项目: ignite   文件: DummyS3Client.java
/** Unsupported Operation. */
@Override public void deleteBucket(DeleteBucketRequest delBucketReq) throws SdkClientException {
    throw new UnsupportedOperationException("Operation not supported");
}
 
源代码8 项目: cloudExplorer   文件: BucketClass.java
String deleteBucket(String access_key, String secret_key,
        String bucket, String endpoint
) {
    String message = null;
    AWSCredentials credentials = new BasicAWSCredentials(access_key, secret_key);
    AmazonS3 s3Client = new AmazonS3Client(credentials,
            new ClientConfiguration());
    if (endpoint.contains("amazonaws.com")) {
        String aws_endpoint = s3Client.getBucketLocation(new GetBucketLocationRequest(bucket));
        if (aws_endpoint.contains("US")) {
            s3Client.setEndpoint("https://s3.amazonaws.com");
        } else if (aws_endpoint.contains("us-west")) {
            s3Client.setEndpoint("https://s3-" + aws_endpoint + ".amazonaws.com");
        } else if (aws_endpoint.contains("eu-west")) {
            s3Client.setEndpoint("https://s3-" + aws_endpoint + ".amazonaws.com");
        } else if (aws_endpoint.contains("ap-")) {
            s3Client.setEndpoint("https://s3-" + aws_endpoint + ".amazonaws.com");
        } else if (aws_endpoint.contains("sa-east-1")) {
            s3Client.setEndpoint("https://s3-" + aws_endpoint + ".amazonaws.com");
        } else {
            s3Client.setEndpoint("https://s3." + aws_endpoint + ".amazonaws.com");
        }
    } else {
        s3Client.setS3ClientOptions(S3ClientOptions.builder().setPathStyleAccess(true).build());
        s3Client.setEndpoint(endpoint);
    }
    message = ("\nDeleting bucket: " + bucket);
    try {
        s3Client.deleteBucket(new DeleteBucketRequest(bucket));
    } catch (Exception Delete) {
        if (terminal) {
            System.out.print("\n\n\n" + Delete.getMessage() + "\n\n\n");
        } else {
            message = message + "\n" + Delete.getMessage();
        }
    }

    if (message == null) {
        message = "\nDelete operation failed.";
    }

    return message;
}
 
源代码9 项目: Scribengin   文件: AmazonS3Mock.java
@Override
public void deleteBucket(DeleteBucketRequest deleteBucketRequest) throws AmazonClientException,
    AmazonServiceException {
  // TODO Auto-generated method stub

}
 
 同包方法