com.amazonaws.services.s3.model.AmazonS3Exception类的使用及代码示例

x33g5p2x  于2022-01-15 转载在 其他  
字(12.9k)|赞(0)|评价(0)|浏览(1418)

本文整理了Java中com.amazonaws.services.s3.model.AmazonS3Exception类的一些代码示例，展示了AmazonS3Exception类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。AmazonS3Exception类的具体详情如下：
包路径：com.amazonaws.services.s3.model.AmazonS3Exception
类名称：AmazonS3Exception

AmazonS3Exception介绍

[英]Provides an extension of the AmazonServiceException for errors reported by Amazon S3 while processing a request. In particular, this class provides access to Amazon S3's extended request ID. This ID is required debugging information in the case the user needs to contact Amazon about an issue where Amazon S3 is incorrectly handling a request.
[中]为AmazonS3在处理请求时报告的错误提供AmazonServiceException的扩展。特别是，此类提供了对Amazon S3的扩展请求ID的访问。如果用户需要就Amazon S3错误处理请求的问题联系Amazon，则需要使用此ID来调试信息。

代码示例

代码示例来源：origin: aws/aws-sdk-java

String bucket, String key, boolean isAdditionalHeadRequestToFindRegion) {
AmazonWebServiceRequest originalRequest = request.getOriginalRequest();
checkHttps(originalRequest);
S3SignerProvider signerProvider = new S3SignerProvider(this, getSigner());
ExecutionContext executionContext = createExecutionContext(originalRequest, signerProvider);
AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
request.setAWSRequestMetrics(awsRequestMetrics);
Response<X> response = null;
try {
  request.setTimeOffset(timeOffset);
  if (ase.getStatusCode() == 301) {
    if (ase.getAdditionalDetails() != null) {
      String region = ase.getAdditionalDetails().get(Headers.S3_BUCKET_REGION);
      bucketRegionCache.put(bucket, region);
      ase.setErrorMessage("The bucket is in this region: " + region +
                ". Please use this region to retry the request");

代码示例来源：origin: apache/incubator-druid

if (404 == e.getStatusCode()
  || "NoSuchKey".equals(e.getErrorCode())
  || "NoSuchBucket".equals(e.getErrorCode())) {
 return Optional.absent();
} else {

代码示例来源：origin: aws/aws-sdk-java

Request<CopyPartRequest> request = createRequest(destinationBucketName, destinationKey, copyPartRequest,
    HttpMethodName.PUT);
request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "UploadPartCopy");
populateRequestWithCopyPartParameters(request, copyPartRequest);
request.addParameter("uploadId", copyPartRequest.getUploadId());
request.addParameter("partNumber", Integer.toString(copyPartRequest.getPartNumber()));
populateRequesterPaysHeader(request, copyPartRequest.isRequesterPays());
  if ( ase.getStatusCode() == Constants.FAILED_PRECONDITION_STATUS_CODE ) {
    return null;
  String hostId = copyObjectResultHandler.getErrorHostId();
  AmazonS3Exception ase = new AmazonS3Exception(errorMessage);
  ase.setErrorCode(errorCode);
  ase.setErrorType(ErrorType.Service);
  ase.setRequestId(requestId);
  ase.setExtendedRequestId(hostId);
  ase.setServiceName(request.getServiceName());
  ase.setStatusCode(200);

代码示例来源：origin: aws/aws-sdk-java

@Override
public String getMessage() {
  return getErrorMessage()
      + " (Service: " + getServiceName()
      + "; Status Code: " + getStatusCode()
      + "; Error Code: " + getErrorCode()
      + "; Request ID: " + getRequestId()
      + "; S3 Extended Request ID: " + getExtendedRequestId() + ")";
}

代码示例来源：origin: aws/aws-sdk-java

@Override
  public boolean test(AmazonS3Exception exception) {

    if (exception == null || exception.getErrorCode() == null ||
        exception.getErrorMessage() == null) {
      return false;
    }

    return exception.getErrorCode().contains(ERROR_CODE) &&
        exception.getErrorMessage().contains(RETYABLE_ERROR_MESSAGE);
  }
}

代码示例来源：origin: aws/aws-sdk-java

/**
 * Creates a new AmazonS3Exception object with the values set.
 */
public AmazonS3Exception build() {
  AmazonS3Exception s3Exception = errorResponseXml == null ? new AmazonS3Exception(
      errorMessage) : new AmazonS3Exception(errorMessage,
      errorResponseXml);
  s3Exception.setErrorCode(errorCode);
  s3Exception.setExtendedRequestId(extendedRequestId);
  s3Exception.setStatusCode(statusCode);
  s3Exception.setRequestId(requestId);
  s3Exception.setCloudFrontId(cloudFrontId);
  s3Exception.setAdditionalDetails(additionalDetails);
  s3Exception.setErrorType(errorTypeOf(statusCode));
  return s3Exception;
}

代码示例来源：origin: aws-amplify/aws-sdk-android

private <X, Y extends AmazonWebServiceRequest> X invoke(Request<Y> request,
                            HttpResponseHandler<AmazonWebServiceResponse<X>> responseHandler,
                            String bucket, String key) {
  final AmazonWebServiceRequest originalRequest = request.getOriginalRequest();
  final ExecutionContext executionContext = createExecutionContext(originalRequest);
  final AWSRequestMetrics awsRequestMetrics = executionContext.getAwsRequestMetrics();
  request.setAWSRequestMetrics(awsRequestMetrics);
  Response<X> response = null;
  try {
    request.setTimeOffset(timeOffset);
        && !(request.getOriginalRequest() instanceof CreateBucketRequest)
        && noExplicitRegionProvided(request)) {
      fetchRegionFromCache(bucket);
    if (ase.getStatusCode() == 301) {
      if (ase.getAdditionalDetails() != null) {
        final String region = ase.getAdditionalDetails().get(Headers.S3_BUCKET_REGION);
        bucketRegionCache.put(bucket, region);
        ase.setErrorMessage("The bucket is in this region: " + region +
            ". Please use this region to retry the request");

代码示例来源：origin: aws/aws-sdk-java

@Override
public CopyObjectResult copyObject(CopyObjectRequest copyObjectRequest)
    throws SdkClientException, AmazonServiceException {
  copyObjectRequest = beforeClientExecution(copyObjectRequest);
  rejectNull(copyObjectRequest.getSourceBucketName(),
      "The source bucket name must be specified when copying an object");
  rejectNull(copyObjectRequest.getSourceKey(),
      "The source object key must be specified when copying an object");
  rejectNull(copyObjectRequest.getDestinationBucketName(),
  Request<CopyObjectRequest> request = createRequest(destinationBucketName, destinationKey, copyObjectRequest, HttpMethodName.PUT);
  request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "CopyObject");
  populateRequestWithCopyObjectParameters(request, copyObjectRequest);
    if (ase.getStatusCode() == Constants.FAILED_PRECONDITION_STATUS_CODE) {
      return null;
    String hostId = copyObjectResultHandler.getErrorHostId();
    AmazonS3Exception ase = new AmazonS3Exception(errorMessage);
    ase.setErrorCode(errorCode);
    ase.setErrorType(ErrorType.Service);
    ase.setRequestId(requestId);
    ase.setExtendedRequestId(hostId);
    ase.setServiceName(request.getServiceName());
    ase.setStatusCode(200);

代码示例来源：origin: aws/aws-sdk-java

@Override
public S3Object getObject(GetObjectRequest getObjectRequest)
    throws SdkClientException, AmazonServiceException {
  getObjectRequest = beforeClientExecution(getObjectRequest);
  assertNotNull(getObjectRequest, "GetObjectRequest");
  assertStringNotEmpty(getObjectRequest.getBucketName(), "BucketName");
  assertStringNotEmpty(getObjectRequest.getKey(), "Key");
  Request<GetObjectRequest> request = createRequest(getObjectRequest.getBucketName(), getObjectRequest.getKey(), getObjectRequest, HttpMethodName.GET);
  request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "GetObject");
    request.addParameter("versionId", getObjectRequest.getVersionId());
  addPartNumberIfNotNull(request, getObjectRequest.getPartNumber());
    request.addHeader(Headers.RANGE, "bytes=" + Long.toString(range[0]) + "-" + Long.toString(range[1]));
    if (ase.getStatusCode() == 412 || ase.getStatusCode() == 304) {
      publishProgress(listener, ProgressEventType.TRANSFER_CANCELED_EVENT);
      return null;

代码示例来源：origin: aws/aws-sdk-java

/**
 * Retrieves the region of the bucket by making a HeadBucket request to us-west-1 region.
 *
 * Currently S3 doesn't return region in a HEAD Bucket request if the bucket
 * owner has enabled bucket to accept only SigV4 requests via bucket
 * policies.
 */
private String getBucketRegionViaHeadRequest(String bucketName) {
  String bucketRegion = null;
  try {
    Request<HeadBucketRequest> request = createRequest(bucketName, null,
        new HeadBucketRequest(bucketName), HttpMethodName.HEAD);
    request.addHandlerContext(HandlerContextKey.OPERATION_NAME, "HeadBucket");
    HeadBucketResult result = invoke(request, new HeadBucketResultHandler(), bucketName, null, true);
    bucketRegion = result.getBucketRegion();
  } catch (AmazonS3Exception exception) {
    if (exception.getAdditionalDetails() != null) {
      bucketRegion = exception.getAdditionalDetails().get(
        Headers.S3_BUCKET_REGION);
    }
  }
  if (bucketRegion == null && log.isDebugEnabled()) {
    log.debug("Not able to derive region of the " + bucketName + " from the HEAD Bucket requests.");
  }
  return bucketRegion;
}

代码示例来源：origin: aws-amplify/aws-sdk-android

"The key parameter must be specified when requesting an object");
final Request<GetObjectRequest> request = createRequest(getObjectRequest.getBucketName(),
    getObjectRequest.getKey(), getObjectRequest, HttpMethodName.GET);
  request.addParameter("versionId", getObjectRequest.getVersionId());
  request.addHeader(Headers.RANGE, rangeHeader);
populateRequesterPaysHeader(request, getObjectRequest.isRequesterPays());
addResponseHeaderParameters(request, getObjectRequest.getResponseHeaders());
addDateHeader(request, Headers.GET_OBJECT_IF_MODIFIED_SINCE,
  if (ase.getStatusCode() == 412 || ase.getStatusCode() == 304) {
    fireProgressEvent(progressListenerCallbackExecutor,
        ProgressEvent.CANCELED_EVENT_CODE);

代码示例来源：origin: stackoverflow.com

import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.model.AmazonS3Exception;
import org.apache.http.HttpStatus;

try {
  AmazonS3 s3 = new AmazonS3Client();
  S3Object object = s3.getObjectMetadata("my-bucket", "my-client");
} catch (AmazonS3Exception e) {
  if (e.getStatusCode() == HttpStatus.SC_NOT_FOUND) {
    // bucket/key does not exist 
  } else {
    throw e;
  }
}

代码示例来源：origin: aws/aws-sdk-java

@Override
public boolean doesObjectExist(String bucketName, String objectName)
    throws AmazonServiceException, SdkClientException {
  try {
    getObjectMetadata(bucketName, objectName);
    return true;
  } catch (AmazonS3Exception e) {
    if (e.getStatusCode() == 404) {
      return false;
    }
    throw e;
  }
}

代码示例来源：origin: org.geowebcache/gwc-aws-s3

@Nullable
public S3Object getObject(String key) throws StorageException {
  final S3Object object;
  try {
    object = conn.getObject(bucketName, key);
  } catch (AmazonS3Exception e) {
    if (404 == e.getStatusCode()) { // 404 == not found
      return null;
    }
    throw new StorageException("Error fetching " + key + ": " + e.getMessage(), e);
  }
  if (isPendingDelete(object)) {
    closeObject(object);
    return null;
  }
  return object;
}

代码示例来源：origin: soabase/exhibitor

private boolean isNotFoundError(AmazonS3Exception e)
  {
    return (e.getStatusCode() == 404) || (e.getStatusCode() == 403);
  }
}

代码示例来源：origin: aws-amplify/aws-sdk-android

@Test
public void testHandleErrorResponse() throws IOException {
  String response = "<Error>"
      + "<Message>testError</Message>"
      + "<Code>testCode</Code>"
      + "<RequestId>testId</RequestId>"
      + "<HostId>testHost</HostId>"
      + "</Error>";
  ByteArrayInputStream content = new ByteArrayInputStream(response.getBytes(StringUtils.UTF8));
  HttpResponse errorResponse = new HttpResponse.Builder()
      .statusCode(200)
      .content(content)
      .statusText("testError").build();
  S3ErrorResponseHandler handler = new S3ErrorResponseHandler();
  AmazonS3Exception ase = (AmazonS3Exception) handler.handle(errorResponse);
  assertEquals(ase.getErrorMessage(), "testError");
  assertEquals(ase.getErrorType(), ErrorType.Client);
  assertEquals(ase.getRequestId(), "testId");
  assertEquals(ase.getExtendedRequestId(), "testHost");
  assertEquals(ase.getStatusCode(), 200);
  assertEquals(ase.getErrorCode(), "testCode");
}

代码示例来源：origin: org.geowebcache/gwc-aws-s3

@Nullable
public ObjectMetadata getObjectMetadata(String key) throws StorageException {
  ObjectMetadata obj = null;
  try {
    obj = conn.getObjectMetadata(bucketName, key);
  } catch (AmazonS3Exception e) {
    if (404 != e.getStatusCode()) { // 404 == not found
      throw new StorageException(
          "Error checking existence of " + key + ": " + e.getMessage(), e);
    }
  }
  return obj;
}

代码示例来源：origin: prestodb/presto

@Override
public S3Object getObject(GetObjectRequest getObjectRequest)
{
  if (getObjectHttpCode != SC_OK) {
    AmazonS3Exception exception = new AmazonS3Exception("Failing getObject call with " + getObjectHttpCode);
    exception.setStatusCode(getObjectHttpCode);
    throw exception;
  }
  return null;
}

代码示例来源：origin: stackoverflow.com

class CloudFrontRetryCondition implements RetryCondition {
  @Override
  public boolean shouldRetry(AmazonWebServiceRequest originalRequest, AmazonClientException exception, int retriesAttempted) {
    if(exception instanceof AmazonS3Exception) {
      final AmazonS3Exception s3Exception = (AmazonS3Exception) exception;
      return  s3Exception.getStatusCode() == 400 &&
          s3Exception.getErrorCode().equals("MalformedPolicy") &&
          s3Exception.getErrorMessage().equals("Invalid principal in policy") &&
        s3Exception.getAdditionalDetails().get("Detail").contains("arn:aws:iam::cloudfront:user/CloudFront Origin Access Identity");
    } else {
      return false;
    }
  }
}

代码示例来源：origin: apache/nifi

MultipartUploadListing listing = s3.listMultipartUploads(listRequest);
  for (MultipartUpload upload : listing.getMultipartUploads()) {
    long uploadTime = upload.getInitiated().getTime();
} catch(AmazonClientException e) {
  if (e instanceof AmazonS3Exception
      && ((AmazonS3Exception)e).getStatusCode() == 403
      && ((AmazonS3Exception) e).getErrorCode().equals("AccessDenied")) {
    getLogger().warn("AccessDenied checking S3 Multipart Upload list for {}: {} " +
        "** The configured user does not have the s3:ListBucketMultipartUploads permission " +

内容来源于网络，如有侵权，请联系作者删除！

AmazonS3Exception

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com