Spring Boot 为AWS Cloudwatch日志客户端指定凭据

zi8p0yeb  于 2024-01-06  发布在  Spring
关注(0)|答案(2)|浏览(215)

嗨，我试图在AWS cloudwatch中创建我的Java应用程序代码的异常日志，因为我已经使用CloudWatchLogsClient将我的事件放入其中，但我得到了下面的错误

  1. DEBUG software.amazon.awssdk.auth.credentials.AwsCredentialsProviderChain - Unable to load credentials from SystemPropertyCredentialsProvider(): Unable to load credentials from system settings. Access key must be specified either via environment variable (AWS_ACCESS_KEY_ID) or system property (aws.accessKeyId).
  2. software.amazon.awssdk.core.exception.SdkClientException: Unable to load credentials from system settings. Access key must be specified either via environment variable (AWS_ACCESS_KEY_ID) or system property (aws.accessKeyId).
  3.     at software.amazon.awssdk.core.exception.SdkClientException$BuilderImpl.build(SdkClientException.java:97)
  4.     at software.amazon.awssdk.auth.credentials.internal.SystemSettingsCredentialsProvider.resolveCredentials(SystemSettingsCredentialsProvider.java:58)
  5.     at software.amazon.awssdk.auth.credentials.AwsCredentialsProviderChain.resolveCredentials(AwsCredentialsProviderChain.java:91)
  6.     at software.amazon.awssdk.auth.credentials.internal.LazyAwsCredentialsProvider.resolveCredentials(LazyAwsCredentialsProvider.java:52)
  7.     at software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider.resolveCredentials(DefaultCredentialsProvider.java:100)
  8.     at software.amazon.awssdk.awscore.client.handler.AwsClientHandlerUtils.createExecutionContext(AwsClientHandlerUtils.java:71)
  9.     at software.amazon.awssdk.awscore.client.handler.AwsSyncClientHandler.createExecutionContext(AwsSyncClientHandler.java:68)
  10.     at software.amazon.awssdk.core.client.handler.BaseSyncClientHandler.execute(BaseSyncClientHandler.java:68)
  11.     at software.amazon.awssdk.core.client.handler.SdkSyncClientHandler.execute(SdkSyncClientHandler.java:44)
  12.     at software.amazon.awssdk.awscore.client.handler.AwsSyncClientHandler.execute(AwsSyncClientHandler.java:55)
  13.     at software.amazon.awssdk.services.cloudwatchlogs.DefaultCloudWatchLogsClient.describeLogStreams(DefaultCloudWatchLogsClient.java:1168)
  14.     at com.WorkingwithS3.WorkingwithS3.PutLogEvents.main(PutLogEvents.java:58)

字符串

这是我的代码示例

  1. package com.WorkingwithS3.WorkingwithS3;
  3. import com.amazonaws.auth.AWSStaticCredentialsProvider;
  4. import com.amazonaws.auth.BasicAWSCredentials;
  5. import com.amazonaws.regions.Regions;
  6. import com.amazonaws.services.s3.AmazonS3;
  7. import com.amazonaws.services.s3.AmazonS3ClientBuilder;
  8. import software.amazon.awssdk.regions.Region;
  9. import software.amazon.awssdk.services.cloudwatchlogs.CloudWatchLogsClient;
  10. import software.amazon.awssdk.services.cloudwatchlogs.CloudWatchLogsClientBuilder;
  11. import software.amazon.awssdk.services.cloudwatchlogs.model.DescribeLogStreamsRequest;
  12. import software.amazon.awssdk.services.cloudwatchlogs.model.DescribeLogStreamsResponse;
  13. import software.amazon.awssdk.services.cloudwatchlogs.model.InputLogEvent;
  14. import software.amazon.awssdk.services.cloudwatchlogs.model.PutLogEventsRequest;
  16. import java.util.Arrays;
  17. // snippet-end:[cloudwatch.java2.put_log_events.import]
  19. /**
  20.  * Puts a sample CloudWatch log event
  21.  */
  22. public class PutLogEvents {
  23.     public static void main(String[] args) {
  24.         BasicAWSCredentials creds = new BasicAWSCredentials("xxxx",
  25.                 "xxxxx");
  27. //        BasicAWSCredentials creds = new BasicAWSCredentials("xxxxxxxx",
  28. //                "xxxx");
  30.         String regionId = "xxx";
  31.         String logGroupName = "xxxx";
  32.         String streamName = "xxxxx";
  34.         // snippet-start:[cloudwatch.java2.put_log_events.main]
  36.         CloudWatchLogsClient logsClient = CloudWatchLogsClient.builder().region(Region.of(regionId)).build();
  38.         // A sequence token is required to put a log event in an existing stream.
  39.         // Look up the stream to find its sequence token.
  41.         // First describe all streams in the log group.
  42.         DescribeLogStreamsRequest logStreamRequest = DescribeLogStreamsRequest.builder()
  43.                 .logGroupName(logGroupName)
  44.                 .logStreamNamePrefix(streamName)
  45.                 .build();
  46.         DescribeLogStreamsResponse describeLogStreamsResponse = logsClient.describeLogStreams(logStreamRequest);
  48.         // Assume that a single stream is returned since a specific stream name was specified in the previous request.
  49.         String sequenceToken = describeLogStreamsResponse.logStreams().get(0).uploadSequenceToken();
  51.         // Build an input log message to put to CloudWatch.
  52.         InputLogEvent inputLogEvent = InputLogEvent.builder()
  53.                 .message("{ \"key1\": \"value1\", \"key2\": \"value2\" }")
  54.                 .timestamp(System.currentTimeMillis())
  55.                 .build();
  57.         // Specify the request parameters.
  58.         PutLogEventsRequest putLogEventsRequest = PutLogEventsRequest.builder()
  59.                 .logEvents(Arrays.asList(inputLogEvent))
  60.                 .logGroupName(logGroupName)
  61.                 .logStreamName(streamName)
  62.                 // Sequence token is required so that the log can be written to the
  63.                 // latest location in the stream.
  64.                 .sequenceToken(sequenceToken)
  65.                 .build();
  66.         logsClient.putLogEvents(putLogEventsRequest);
  67.         // snippet-end:[cloudwatch.java2.put_log_events.main]
  69.         System.out.println("Successfully put CloudWatch log event");
  70.     }
  71. }

型
有没有人可以指导如何指定CloudWatchLogsClient的凭据？提前感谢

spring-boot

2条答案

按热度按时间
sg3maiej

sg3maiej1#

从跟踪中我们可以看到这个示例CloudWatchLogsClient.builder()中的sdk客户端无法找到凭据，因此无法构建。
客户端将在以下defaults locations中查找凭据
出于多种原因，最好将代码设置为从环境变量读取凭据。
这有很多原因。
AWS鼓励使用environment variables for credentials。
越来越需要在某种容器集群中运行应用程序，例如Kubernetes。
在容器化的环境中，访问文件系统通常是有问题的。
在许多容器工具中，比如docker-compose，它的作用很小，就像pass environment variables to the container一样。
在链接defaults locations中，它精确地指定了如何为CloudWatchLogsClient.builder()操作提供凭据的选项，并且由于上述原因，建议您采用环境变量解决方案，并且您可以使用`

  1. Map<String, String> mapOfEnvironmentVariables = System.getenv();

字符串
去取回它们

更新20-12-2023

更改了“默认位置”的AWS文档链接，查找副标题“凭据设置检索顺序”下的第2节

展开查看全部
赞(0）分享  回复(0）举报  2024-01-06
rjee0c15

rjee0c152#

下面的代码工作正常，我能够使用CloudWatchLogsClient在cloudwatch中编写异常，仅供参考，我附上了代码

  1. package com.example.DynamoDB;
  3. import org.springframework.http.HttpStatus;
  4. import org.springframework.http.ResponseEntity;
  5. import org.springframework.web.bind.annotation.ControllerAdvice;
  6. import org.springframework.web.bind.annotation.ExceptionHandler;
  7. import software.amazon.awssdk.regions.Region;
  8. import software.amazon.awssdk.services.cloudwatchlogs.CloudWatchLogsClient;
  9. import software.amazon.awssdk.services.cloudwatchlogs.model.DescribeLogStreamsRequest;
  10. import software.amazon.awssdk.services.cloudwatchlogs.model.DescribeLogStreamsResponse;
  11. import software.amazon.awssdk.services.cloudwatchlogs.model.InputLogEvent;
  12. import software.amazon.awssdk.services.cloudwatchlogs.model.PutLogEventsRequest;
  14. import java.util.Arrays;
  16. @ControllerAdvice
  17. public class ExceptionControllerAdvice {
  18.     @ExceptionHandler(Exception.class)
  19.     public ResponseEntity<ErrorResponse> exceptionHandler(Exception ex) {
  20.         ErrorResponse error = new ErrorResponse();
  21.         error.setErrorCode(HttpStatus.INTERNAL_SERVER_ERROR.value());
  22.         error.setMessage(ex.getMessage());
  23.         error.setController(ex.getStackTrace()[0].getClassName());
  24.         error.setService(ex.getStackTrace()[0].getClassName());
  25.         error.setTimestamp(System.currentTimeMillis());
  26.         PutLogEvents(error);
  27.         return new ResponseEntity<ErrorResponse>(error, HttpStatus.OK);
  28.     }
  30.     public static void PutLogEvents(ErrorResponse Er)
  31.     {
  32.         String regionId = "us-east-1";
  33.         String logGroupName = "xxxxxxxxx";
  34.         String logStreamName = "xxxxxxxxx";
  36.         CloudWatchLogsClient logsClient = CloudWatchLogsClient.builder().region(Region.of(regionId)).build();
  38.         // A sequence token is required to put a log event in an existing stream.
  39.         // Look up the stream to find its sequence token.
  40.         String sequenceToken = getNextSequenceToken(logsClient, logGroupName, logStreamName);
  42.         // Build a JSON log using the EmbeddedMetricFormat.
  44.         String message = "[{" +
  45.                 "  \"Timestamp\": " + Er.getTimestamp()  + "," +
  46.                 "  \"ErrorCode\": " + Er.getErrorCode()  + "," +
  47.                 "  \"ControllerName\": " + Er.getErrorCode()  + "," +
  48.                 "  \"ServiceName\": " + Er.getErrorCode()  + "," +
  49.                 "  \"ErrorMsg\": " + Er.getErrorCode()   + "" +
  50.                 "}]";
  51.         InputLogEvent inputLogEvent = InputLogEvent.builder()
  52.                 .message(message)
  53.                 .timestamp(Er.getTimestamp())
  54.                 .build();
  56.         // Specify the request parameters.
  57.         PutLogEventsRequest putLogEventsRequest = PutLogEventsRequest.builder()
  58.                 .logEvents(Arrays.asList(inputLogEvent))
  59.                 .logGroupName(logGroupName)
  60.                 .logStreamName(logStreamName)
  61.                 // Sequence token is required so that the log can be written to the
  62.                 // latest location in the stream.
  63.                 .sequenceToken(sequenceToken)
  64.                 .build();
  66.         logsClient.putLogEvents(putLogEventsRequest);
  67.     }
  69.     private static String getNextSequenceToken(CloudWatchLogsClient logsClient, String logGroupName, String logStreamName) {
  70.         DescribeLogStreamsRequest logStreamRequest = DescribeLogStreamsRequest.builder()
  71.                 .logGroupName(logGroupName)
  72.                 .logStreamNamePrefix(logStreamName)
  73.                 .build();
  75.         DescribeLogStreamsResponse describeLogStreamsResponse = logsClient.describeLogStreams(logStreamRequest);
  77.         // Assume that a single stream is returned since a specific stream name was
  78.         // specified in the previous request.
  79.         return describeLogStreamsResponse.logStreams().get(0).uploadSequenceToken();
  80.     }
  82. }

字符串

展开查看全部
赞(0）分享  回复(0）举报  2024-01-06
我来回答

相关问题

    查看更多

    热门标签

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

    最新问答

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