software.amazon.awssdk.utils.Logger.trace()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(12.1k)|赞(0)|评价(0)|浏览(223)

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

Logger.trace介绍

[英]Checks if trace is enabled and if so logs the supplied message
[中]检查跟踪是否启用，如果启用，则记录提供的消息

代码示例

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

  1. @Override
  2. public void connect(SocketAddress endpoint) throws IOException {
  3.   log.trace(() -> "connecting to: " + endpoint);
  4.   sock.connect(endpoint);
  5.   log.debug(() -> "connected to: " + endpoint);
  6. }

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

  1. @Override
  2. public void connect(SocketAddress endpoint, int timeout) throws IOException {
  3.   log.trace(() -> "connecting to: " + endpoint);
  4.   sock.connect(endpoint, timeout);
  5.   log.debug(() -> "connected to: " + endpoint);
  6. }

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

  1. @Override
  2. public void connect(SocketAddress endpoint, int timeout) throws IOException {
  3.   log.trace(() -> "connecting to: " + endpoint);
  4.   sock.connect(endpoint, timeout);
  5.   log.debug(() -> "connected to: " + endpoint);
  6. }

代码示例来源：origin: software.amazon.awssdk/sdk-core

  1. /**
  2.  * Validate the result of calling an interceptor method that is attempting to modify the message to make sure its result is
  3.  * valid.
  4.  */
  5. private void validateInterceptorResult(Object originalMessage, Object newMessage,
  6.                     ExecutionInterceptor interceptor, String methodName) {
  7.   if (!Objects.equals(originalMessage, newMessage)) {
  8.     LOG.debug(() -> "Interceptor '" + interceptor + "' modified the message with its " + methodName + " method.");
  9.     LOG.trace(() -> "Old: " + originalMessage + "\nNew: " + newMessage);
  10.   }
  11.   Validate.validState(newMessage != null,
  12.             "Request interceptor '%s' returned null from its %s interceptor.",
  13.             interceptor, methodName);
  14.   Validate.isInstanceOf(originalMessage.getClass(), newMessage,
  15.              "Request interceptor '%s' returned '%s' from its %s method, but '%s' was expected.",
  16.              interceptor, newMessage.getClass(), methodName, originalMessage.getClass());
  17. }

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

  1. @Override
  2. public void connect(SocketAddress endpoint) throws IOException {
  3.   log.trace(() -> "connecting to: " + endpoint);
  4.   sock.connect(endpoint);
  5.   log.debug(() -> "connected to: " + endpoint);
  6. }

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

  1. @SuppressWarnings("unchecked")
  2. private T unmarshallResponse(SdkHttpFullResponse response) throws Exception {
  3.   SdkStandardLogger.REQUEST_LOGGER.trace(() -> "Parsing service response XML.");
  4.   T result = unmarshaller.unmarshall(pojoSupplier.apply(response), response);
  5.   SdkStandardLogger.REQUEST_LOGGER.trace(() -> "Done parsing service response.");
  6.   AwsResponseMetadata responseMetadata = generateResponseMetadata(response);
  7.   return (T) result.toBuilder().responseMetadata(responseMetadata).build();
  8. }

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

  1. @Override
  2. public Socket connectSocket(
  3.     final int connectTimeout,
  4.     final Socket socket,
  5.     final HttpHost host,
  6.     final InetSocketAddress remoteAddress,
  7.     final InetSocketAddress localAddress,
  8.     final HttpContext context) throws IOException {
  9.   log.trace(() -> String.format("Connecting to %s:%s", remoteAddress.getAddress(), remoteAddress.getPort()));
  10.   Socket connectedSocket = super.connectSocket(connectTimeout, socket, host, remoteAddress, localAddress, context);
  11.   if (connectedSocket instanceof SSLSocket) {
  12.     return new SdkSslSocket((SSLSocket) connectedSocket);
  13.   }
  14.   return new SdkSocket(connectedSocket);
  15. }

代码示例来源：origin: software.amazon.awssdk/aws-xml-protocol

  1. @SuppressWarnings("unchecked")
  2. private T unmarshallResponse(SdkHttpFullResponse response) throws Exception {
  3.   SdkStandardLogger.REQUEST_LOGGER.trace(() -> "Parsing service response XML.");
  4.   T result = unmarshaller.unmarshall(pojoSupplier.apply(response), response);
  5.   SdkStandardLogger.REQUEST_LOGGER.trace(() -> "Done parsing service response.");
  6.   AwsResponseMetadata responseMetadata = generateResponseMetadata(response);
  7.   return (T) result.toBuilder().responseMetadata(responseMetadata).build();
  8. }

代码示例来源：origin: software.amazon.awssdk/aws-query-protocol

  1. @SuppressWarnings("unchecked")
  2. private T unmarshallResponse(SdkHttpFullResponse response) throws Exception {
  3.   SdkStandardLogger.REQUEST_LOGGER.trace(() -> "Parsing service response XML.");
  4.   Pair<T, Map<String, String>> result = unmarshaller.unmarshall(pojoSupplier.apply(response), response);
  5.   SdkStandardLogger.REQUEST_LOGGER.trace(() -> "Done parsing service response.");
  6.   AwsResponseMetadata responseMetadata = generateResponseMetadata(response, result.right());
  7.   return (T) result.left().toBuilder().responseMetadata(responseMetadata).build();
  8. }

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

  1. @SuppressWarnings("unchecked")
  2. private T unmarshallResponse(SdkHttpFullResponse response) throws Exception {
  3.   SdkStandardLogger.REQUEST_LOGGER.trace(() -> "Parsing service response XML.");
  4.   Pair<T, Map<String, String>> result = unmarshaller.unmarshall(pojoSupplier.apply(response), response);
  5.   SdkStandardLogger.REQUEST_LOGGER.trace(() -> "Done parsing service response.");
  6.   AwsResponseMetadata responseMetadata = generateResponseMetadata(response, result.right());
  7.   return (T) result.left().toBuilder().responseMetadata(responseMetadata).build();
  8. }

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

  1. @Override
  2. public int read(byte[] b, int off, int len) throws IOException {
  3.   abortIfNeeded();
  4.   if (b == null) {
  5.     throw new NullPointerException();
  6.   } else if (off < 0 || len < 0 || len > b.length - off) {
  7.     throw new IndexOutOfBoundsException();
  8.   } else if (len == 0) {
  9.     return 0;
  10.   }
  11.   if (null == currentChunkIterator || !currentChunkIterator.hasNext()) {
  12.     if (isTerminating) {
  13.       return -1;
  14.     } else {
  15.       isTerminating = setUpNextChunk();
  16.     }
  17.   }
  18.   int count = currentChunkIterator.read(b, off, len);
  19.   if (count > 0) {
  20.     isAtStart = false;
  21.     log.trace(() -> count + " byte read from the stream.");
  22.   }
  23.   return count;
  24. }

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

  1. /**
  2.  * @see HttpResponseHandler#handle(SdkHttpFullResponse, ExecutionAttributes)
  3.  */
  4. public T handle(SdkHttpFullResponse response, ExecutionAttributes executionAttributes) throws Exception {
  5.   SdkStandardLogger.REQUEST_LOGGER.trace(() -> "Parsing service response JSON.");
  6.   SdkStandardLogger.REQUEST_ID_LOGGER.debug(() -> X_AMZN_REQUEST_ID_HEADER + " : " +
  7.                           response.firstMatchingHeader(X_AMZN_REQUEST_ID_HEADER)
  8.                               .orElse("not available"));
  9.   try {
  10.     T result = unmarshaller.unmarshall(pojoSupplier.apply(response), response);
  11.     // Make sure we read all the data to get an accurate CRC32 calculation.
  12.     // See https://github.com/aws/aws-sdk-java/issues/1018
  13.     if (shouldParsePayloadAsJson() && response.content().isPresent()) {
  14.       IoUtils.drainInputStream(response.content().get());
  15.     }
  16.     SdkStandardLogger.REQUEST_LOGGER.trace(() -> "Done parsing service response.");
  17.     return result;
  18.   } finally {
  19.     if (!needsConnectionLeftOpen) {
  20.       response.content().ifPresent(i -> FunctionalUtils.invokeSafely(i::close));
  21.     }
  22.   }
  23. }

代码示例来源：origin: software.amazon.awssdk/aws-json-protocol

  1. /**
  2.  * @see HttpResponseHandler#handle(SdkHttpFullResponse, ExecutionAttributes)
  3.  */
  4. public T handle(SdkHttpFullResponse response, ExecutionAttributes executionAttributes) throws Exception {
  5.   SdkStandardLogger.REQUEST_LOGGER.trace(() -> "Parsing service response JSON.");
  6.   SdkStandardLogger.REQUEST_ID_LOGGER.debug(() -> X_AMZN_REQUEST_ID_HEADER + " : " +
  7.                           response.firstMatchingHeader(X_AMZN_REQUEST_ID_HEADER)
  8.                               .orElse("not available"));
  9.   try {
  10.     T result = unmarshaller.unmarshall(pojoSupplier.apply(response), response);
  11.     // Make sure we read all the data to get an accurate CRC32 calculation.
  12.     // See https://github.com/aws/aws-sdk-java/issues/1018
  13.     if (shouldParsePayloadAsJson() && response.content().isPresent()) {
  14.       IoUtils.drainInputStream(response.content().get());
  15.     }
  16.     SdkStandardLogger.REQUEST_LOGGER.trace(() -> "Done parsing service response.");
  17.     return result;
  18.   } finally {
  19.     if (!needsConnectionLeftOpen) {
  20.       response.content().ifPresent(i -> FunctionalUtils.invokeSafely(i::close));
  21.     }
  22.   }
  23. }

代码示例来源：origin: software.amazon.awssdk/auth

  1. @Override
  2. public int read(byte[] b, int off, int len) throws IOException {
  3.   abortIfNeeded();
  4.   if (b == null) {
  5.     throw new NullPointerException();
  6.   } else if (off < 0 || len < 0 || len > b.length - off) {
  7.     throw new IndexOutOfBoundsException();
  8.   } else if (len == 0) {
  9.     return 0;
  10.   }
  11.   if (null == currentChunkIterator || !currentChunkIterator.hasNext()) {
  12.     if (isTerminating) {
  13.       return -1;
  14.     } else {
  15.       isTerminating = setUpNextChunk();
  16.     }
  17.   }
  18.   int count = currentChunkIterator.read(b, off, len);
  19.   if (count > 0) {
  20.     isAtStart = false;
  21.     log.trace(() -> count + " byte read from the stream.");
  22.   }
  23.   return count;
  24. }

代码示例来源：origin: software.amazon.awssdk/auth

  1. /**
  2.  * Step 3 of the AWS Signature version 4 calculation. It involves deriving
  3.  * the signing key and computing the signature. Refer to
  4.  * http://docs.aws.amazon
  5.  * .com/general/latest/gr/sigv4-calculate-signature.html
  6.  */
  7. protected byte[] deriveSigningKey(AwsCredentials credentials, Aws4SignerRequestParams signerRequestParams) {
  8.   String cacheKey = computeSigningCacheKeyName(credentials, signerRequestParams);
  9.   long daysSinceEpochSigningDate = numberOfDaysSinceEpoch(signerRequestParams.getSigningDateTimeMilli());
  10.   SignerKey signerKey = SIGNER_CACHE.get(cacheKey);
  11.   if (signerKey != null && daysSinceEpochSigningDate == signerKey.getNumberOfDaysSinceEpoch()) {
  12.     return signerKey.getSigningKey();
  13.   }
  14.   LOG.trace(() -> "Generating a new signing key as the signing key not available in the cache for the date: " +
  15.     TimeUnit.DAYS.toMillis(daysSinceEpochSigningDate));
  16.   byte[] signingKey = newSigningKey(credentials,
  17.     signerRequestParams.getFormattedSigningDate(),
  18.     signerRequestParams.getRegionName(),
  19.     signerRequestParams.getServiceSigningName());
  20.   SIGNER_CACHE.add(cacheKey, new SignerKey(daysSinceEpochSigningDate, signingKey));
  21.   return signingKey;
  22. }

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

  1. /**
  2.  * Step 3 of the AWS Signature version 4 calculation. It involves deriving
  3.  * the signing key and computing the signature. Refer to
  4.  * http://docs.aws.amazon
  5.  * .com/general/latest/gr/sigv4-calculate-signature.html
  6.  */
  7. protected byte[] deriveSigningKey(AwsCredentials credentials, Aws4SignerRequestParams signerRequestParams) {
  8.   String cacheKey = computeSigningCacheKeyName(credentials, signerRequestParams);
  9.   long daysSinceEpochSigningDate = numberOfDaysSinceEpoch(signerRequestParams.getSigningDateTimeMilli());
  10.   SignerKey signerKey = SIGNER_CACHE.get(cacheKey);
  11.   if (signerKey != null && daysSinceEpochSigningDate == signerKey.getNumberOfDaysSinceEpoch()) {
  12.     return signerKey.getSigningKey();
  13.   }
  14.   LOG.trace(() -> "Generating a new signing key as the signing key not available in the cache for the date: " +
  15.     TimeUnit.DAYS.toMillis(daysSinceEpochSigningDate));
  16.   byte[] signingKey = newSigningKey(credentials,
  17.     signerRequestParams.getFormattedSigningDate(),
  18.     signerRequestParams.getRegionName(),
  19.     signerRequestParams.getServiceSigningName());
  20.   SIGNER_CACHE.add(cacheKey, new SignerKey(daysSinceEpochSigningDate, signingKey));
  21.   return signingKey;
  22. }

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

  1. /**
  2.  * Step 1 of the AWS Signature version 4 calculation. Refer to
  3.  * http://docs.aws
  4.  * .amazon.com/general/latest/gr/sigv4-create-canonical-request.html to
  5.  * generate the canonical request.
  6.  */
  7. private String createCanonicalRequest(SdkHttpFullRequest.Builder request,
  8.                    String contentSha256,
  9.                    boolean doubleUrlEncode) {
  10.   String canonicalRequest = request.method().toString() +
  11.                SignerConstant.LINE_SEPARATOR +
  12.                // This would optionally double url-encode the resource path
  13.                getCanonicalizedResourcePath(request.encodedPath(), doubleUrlEncode) +
  14.                SignerConstant.LINE_SEPARATOR +
  15.                getCanonicalizedQueryString(request.rawQueryParameters()) +
  16.                SignerConstant.LINE_SEPARATOR +
  17.                getCanonicalizedHeaderString(request.headers()) +
  18.                SignerConstant.LINE_SEPARATOR +
  19.                getSignedHeadersString(request.headers()) +
  20.                SignerConstant.LINE_SEPARATOR +
  21.                contentSha256;
  22.   LOG.trace(() -> "AWS4 Canonical Request: " + canonicalRequest);
  23.   return canonicalRequest;
  24. }

代码示例来源：origin: software.amazon.awssdk/auth

  1. /**
  2.  * Step 1 of the AWS Signature version 4 calculation. Refer to
  3.  * http://docs.aws
  4.  * .amazon.com/general/latest/gr/sigv4-create-canonical-request.html to
  5.  * generate the canonical request.
  6.  */
  7. private String createCanonicalRequest(SdkHttpFullRequest.Builder request,
  8.                    String contentSha256,
  9.                    boolean doubleUrlEncode) {
  10.   String canonicalRequest = request.method().toString() +
  11.                SignerConstant.LINE_SEPARATOR +
  12.                // This would optionally double url-encode the resource path
  13.                getCanonicalizedResourcePath(request.encodedPath(), doubleUrlEncode) +
  14.                SignerConstant.LINE_SEPARATOR +
  15.                getCanonicalizedQueryString(request.rawQueryParameters()) +
  16.                SignerConstant.LINE_SEPARATOR +
  17.                getCanonicalizedHeaderString(request.headers()) +
  18.                SignerConstant.LINE_SEPARATOR +
  19.                getSignedHeadersString(request.headers()) +
  20.                SignerConstant.LINE_SEPARATOR +
  21.                contentSha256;
  22.   LOG.trace(() -> "AWS4 Canonical Request: " + canonicalRequest);
  23.   return canonicalRequest;
  24. }

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

Logger

相关文章

    查看更多

    热门标签

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

    最新文章

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