Java V2 Added a new example for CloudWatch logs for tix V1818828107

.doc_gen/metadata/cloudwatch-logs_metadata.yaml

@@ -99,6 +99,19 @@ cloudwatch-logs_DescribeExportTasks:
                 - CloudWatchLogs.dotnetv3.DescribeExportTasksExammple
   services:
     cloudwatch-logs: {DescribeExportTasks}
+cloudwatch-logs_DescribeLogStreams:
+  languages:
+    Java:
+      versions:
+        - sdk_version: 2
+          github: javav2/example_code/cloudwatch
+          sdkguide:
+          excerpts:
+            - description:
+              snippet_tags:
+                - cloudwatch.javav2.describe.log.streams.main
+  services:
+    cloudwatch-logs: {DescribeLogStreams}
 cloudwatch-logs_DescribeLogGroups:
   languages:
     .NET:

javav2/example_code/cloudwatch/src/main/java/com/example/cloudwatch/CloudWatchLogQuery.java

@@ -0,0 +1,95 @@
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+
+package com.example.cloudwatch;
+
+import software.amazon.awssdk.regions.Region;
+import software.amazon.awssdk.services.cloudwatchlogs.CloudWatchLogsClient;
+import software.amazon.awssdk.services.cloudwatchlogs.model.CloudWatchLogsException;
+import software.amazon.awssdk.services.cloudwatchlogs.model.DescribeLogStreamsRequest;
+import software.amazon.awssdk.services.cloudwatchlogs.model.DescribeLogStreamsResponse;
+import software.amazon.awssdk.services.cloudwatchlogs.model.GetLogEventsRequest;
+import software.amazon.awssdk.services.cloudwatchlogs.model.GetLogEventsResponse;
+import software.amazon.awssdk.services.cloudwatchlogs.model.LogStream;
+import software.amazon.awssdk.services.cloudwatchlogs.model.OrderBy;
+import software.amazon.awssdk.services.cloudwatchlogs.model.OutputLogEvent;
+import java.util.List;
+
+// snippet-start:[cloudwatch.javav2.describe.log.streams.main]
+/**
+ * Before running this Java V2 code example, set up your development
+ * environment, including your credentials.
+ * <p>
+ * For more information, see the following documentation topic:
+ * <p>
+ * https://docs.aws.amazon.com/sdk-for-java/latest/developer-guide/get-started.html
+ */
+public class CloudWatchLogQuery {
+    public static void main(final String[] args) {
+        final String usage = """
+
+                Usage:
+                  <logGroupName> <startTime> <endTime>
+
+                Where:
+                  logGroupName - The name of the log group (for example, /aws/lambda/ChatAIHandler).
+                """;
+
+        if (args.length != 1) {
+            System.out.print(usage);
+            System.exit(1);
+        }
+
+        String logGroupName = args[0] ;
+        CloudWatchLogsClient logsClient = CloudWatchLogsClient.builder()
+                .region(Region.US_EAST_1)
+                .build();
+
+        getLogEvents(logsClient, logGroupName);
+
+    }
+
+    /**
+     * Retrieves and prints the log events from the specified log group and the most recent log stream within that group.
+     *
+     * @param logsClient the CloudWatchLogsClient used to interact with AWS CloudWatch Logs
+     * @param logGroupName the name of the log group from which to retrieve the log events
+     */
+    public static void getLogEvents(CloudWatchLogsClient logsClient, String logGroupName) {
+        DescribeLogStreamsRequest streamsRequest = DescribeLogStreamsRequest.builder()
+                .logGroupName(logGroupName)
+                .orderBy(OrderBy.LAST_EVENT_TIME)
+                .descending(true)
+                .limit(1)
+                .build();
+        try {
+            DescribeLogStreamsResponse streamsResponse = logsClient.describeLogStreams(streamsRequest);
+            List<LogStream> logStreams = streamsResponse.logStreams();
+
+            if (logStreams.isEmpty()) {
+                System.out.println("No log streams found for log group: " + logGroupName);
+                return;
+            }
+
+            String logStreamName = logStreams.get(0).logStreamName();
+
+            // Get Log Events.
+            GetLogEventsRequest eventsRequest = GetLogEventsRequest.builder()
+                    .logGroupName(logGroupName)
+                    .logStreamName(logStreamName)
+                    .startFromHead(true)
+                    .build();
+
+            GetLogEventsResponse eventsResponse = logsClient.getLogEvents(eventsRequest);
+            System.out.println("Log events from: " + logStreamName);
+            for (OutputLogEvent event : eventsResponse.events()) {
+                System.out.printf("[%s] %s%n", event.timestamp(), event.message());
+            }
+
+        } catch (CloudWatchLogsException e) {
+            System.err.println("Failed to fetch logs: " + e.awsErrorDetails().errorMessage());
+        }
+    }
+}
+// snippet-end:[cloudwatch.javav2.describe.log.streams.main]