com.amazonaws.AmazonServiceException.getHttpHeaders()方法的使用及代码示例

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

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

AmazonServiceException.getHttpHeaders介绍

暂无

代码示例

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

requestLatency = calculateRequestLatency(timingInfo);
} else if (context.getException() instanceof AmazonServiceException) {
  responseHeaders = ((AmazonServiceException) context.getException()).getHttpHeaders();
  statusCode = extractHttpStatusCode((AmazonServiceException) context.getException());
  requestLatency = calculateRequestLatency(timingInfo);

代码示例来源:origin: com.amazonaws/aws-java-sdk-core

requestLatency = calculateRequestLatency(timingInfo);
} else if (context.getException() instanceof AmazonServiceException) {
  responseHeaders = ((AmazonServiceException) context.getException()).getHttpHeaders();
  statusCode = extractHttpStatusCode((AmazonServiceException) context.getException());
  requestLatency = calculateRequestLatency(timingInfo);

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

private HashMap<String, Object> extractHttpResponseInformation(AmazonServiceException ase) {
  HashMap<String, Object> ret = new HashMap<>();
  HashMap<String, Object> response = new HashMap<>();
  response.put(EntityDataKeys.HTTP.STATUS_CODE_KEY, ase.getStatusCode());
  try {
    if (null != ase.getHttpHeaders() && null != ase.getHttpHeaders().get(EntityHeaderKeys.HTTP.CONTENT_LENGTH_HEADER)) {
      response.put(EntityDataKeys.HTTP.CONTENT_LENGTH_KEY, Long.parseLong(ase.getHttpHeaders().get(EntityHeaderKeys.HTTP.CONTENT_LENGTH_HEADER)));
    }
  } catch (NumberFormatException nfe) {
    logger.warn("Unable to parse Content-Length header.", nfe);
  }
  ret.put(EntityDataKeys.HTTP.RESPONSE_KEY, response);
  return ret;
}

代码示例来源:origin: com.netflix.spinnaker.kork/kork-core

static String[] buildExceptionTags(AmazonWebServiceRequest originalRequest, Exception exception) {
 final AmazonServiceException ase = amazonServiceException(exception);
 String targetAccountId = DEFAULT_UNKNOWN;
 if (ase.getHttpHeaders() != null) {
  targetAccountId = ase.getHttpHeaders().get("targetAccountId");
 }
 return new String[] {
  "requestType", originalRequest.getClass().getSimpleName(),
  "statusCode", Integer.toString(ase.getStatusCode()),
  "errorCode", Optional.ofNullable(ase.getErrorCode()).orElse(DEFAULT_UNKNOWN),
  "serviceName", Optional.ofNullable(ase.getServiceName()).orElse(DEFAULT_UNKNOWN),
  "errorType", Optional.ofNullable(ase.getErrorType()).orElse(AmazonServiceException.ErrorType.Unknown).name(),
  "accountId", Optional.ofNullable(targetAccountId).orElse(DEFAULT_UNKNOWN)
 };
}

代码示例来源:origin: org.seaborne.rdf-delta/rdf-delta-server-extra

/** Test whether the bucket exists and is accessible. */
public static boolean bucketExists(AmazonS3 client, String bucketName) {
  try {
    HeadBucketRequest request = new HeadBucketRequest(bucketName);
    HeadBucketResult result = client.headBucket(request);
    return true;
  }
  catch (AmazonServiceException awsEx) {
    switch (awsEx.getStatusCode()) {
      case HttpSC.NOT_FOUND_404 :
        return false;
      case HttpSC.FORBIDDEN_403 :
        break;
      case HttpSC.MOVED_PERMANENTLY_301 : { // Moved permanently.
        System.err.println("301 Location: " + awsEx.getHttpHeaders().get(HttpNames.hLocation));
        break;
      }
    }
    throw awsEx;
  }
}

代码示例来源:origin: org.seaborne.rdf-delta/rdf-delta-server-extra

@Override
public RDFPatch fetch(Id key) {
  String s3Key = idToKey(key);
  try {
    S3Object x = client.getObject(bucketName, s3Key);
    x.getObjectMetadata();
    S3ObjectInputStream input = x.getObjectContent();
    RDFPatch patch = RDFPatchOps.read(input);
    return patch;
  }
  catch (AmazonServiceException awsEx) {
    switch (awsEx.getStatusCode()) {
      case HttpSC.NOT_FOUND_404 :
      case HttpSC.FORBIDDEN_403 :
        return null;
      case HttpSC.MOVED_PERMANENTLY_301 : { // Moved permanently.
        System.err.println("301 Location: " + awsEx.getHttpHeaders().get(HttpNames.hLocation));
        return null;
      }
    }
    throw awsEx;
  }
}

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

private void populateAndEndSubsegment(Subsegment currentSubsegment, Request<?> request, Response<?> response, AmazonServiceException ase) {
  if (null != response) {
    populateAndEndSubsegment(currentSubsegment, request, response);
    return;
  } else if (null != ase) {
    if (null != ase.getRequestId()) {
      currentSubsegment.putAws(REQUEST_ID_SUBSEGMENT_KEY, ase.getRequestId());
    }
    if (null != ase.getHttpHeaders() && null != ase.getHttpHeaders().get(EntityHeaderKeys.AWS.EXTENDED_REQUEST_ID_HEADER)) {
      currentSubsegment.putAws(EntityDataKeys.AWS.EXTENDED_REQUEST_ID_KEY, ase.getHttpHeaders().get(EntityHeaderKeys.AWS.EXTENDED_REQUEST_ID_HEADER));
    }
    if (null != ase.getErrorMessage()) {
      currentSubsegment.getCause().setMessage(ase.getErrorMessage());
    }
    currentSubsegment.putAllHttp(extractHttpResponseInformation(ase));
  }
  finalizeSubsegment(request);
}

代码示例来源:origin: com.netflix.spinnaker.clouddriver/clouddriver-aws

private RetryPolicy getRetryPolicy(AmazonClientKey<?> key) {
  if (!(key.getAwsCredentialsProvider() instanceof NetflixSTSAssumeRoleSessionCredentialsProvider)) {
   return retryPolicy;
  }
  final RetryPolicy.RetryCondition delegatingRetryCondition = (originalRequest, exception, retriesAttempted) -> {
   NetflixSTSAssumeRoleSessionCredentialsProvider stsCredentialsProvider = (NetflixSTSAssumeRoleSessionCredentialsProvider) key.getAwsCredentialsProvider();
   if (exception instanceof AmazonServiceException) {
    ((AmazonServiceException) exception).getHttpHeaders().put("targetAccountId", stsCredentialsProvider.getAccountId());
   }
   return retryPolicy.getRetryCondition().shouldRetry(originalRequest, exception, retriesAttempted);
  };
  return new RetryPolicy(
   delegatingRetryCondition,
   retryPolicy.getBackoffStrategy(),
   retryPolicy.getMaxErrorRetry(),
   retryPolicy.isMaxErrorRetryInClientConfigHonored()
  );
 }
}

相关文章