本文整理了Java中com.amazonaws.AmazonServiceException.getHttpHeaders()
方法的一些代码示例,展示了AmazonServiceException.getHttpHeaders()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AmazonServiceException.getHttpHeaders()
方法的具体详情如下:
包路径:com.amazonaws.AmazonServiceException
类名称: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()
);
}
}
内容来源于网络,如有侵权,请联系作者删除!