.NET: CloudWatch Logs Large Query Feature Scenario

.doc_gen/metadata/cloudwatch-logs_metadata.yaml

@@ -288,6 +288,14 @@ cloudwatch-logs_PutSubscriptionFilter:
     cloudwatch-logs: {PutSubscriptionFilter}
 cloudwatch-logs_GetQueryResults:
   languages:
+    .NET:
+      versions:
+        - sdk_version: 4
+          github: dotnetv4/CloudWatchLogs/LargeQuery
+          excerpts:
+            - description:
+              snippet_tags:
+                - CloudWatchLogs.dotnetv4.GetQueryResults
     JavaScript:
       versions:
         - sdk_version: 3
@@ -308,6 +316,14 @@ cloudwatch-logs_GetQueryResults:
     cloudwatch-logs: {GetQueryResults}
 cloudwatch-logs_StartQuery:
   languages:
+    .NET:
+      versions:
+        - sdk_version: 4
+          github: dotnetv4/CloudWatchLogs/LargeQuery
+          excerpts:
+            - description:
+              snippet_tags:
+                - CloudWatchLogs.dotnetv4.StartQuery
     JavaScript:
       versions:
         - sdk_version: 3
@@ -332,6 +348,14 @@ cloudwatch-logs_Scenario_BigQuery:
   synopsis: use &CWL; to query more than 10,000 records.
   category: Scenarios
   languages:
+    .NET:
+      versions:
+        - sdk_version: 4
+          github: dotnetv4/CloudWatchLogs/LargeQuery
+          excerpts:
+            - description: This is the main workflow that demonstrates the large query scenario.
+              snippet_tags:
+                - CloudWatchLogs.dotnetv4.LargeQueryWorkflow
     JavaScript:
       versions:
         - sdk_version: 3

.doc_gen/validation.yaml

@@ -215,6 +215,7 @@ allow_list:
   - "EnablePropagateAdditionalUserContextData"
   - "StopQueryWorkloadInsightsTopContributors"
   - "com/location/latest/APIReference/Welcome"
+  - "LargeQuery/Actions/CloudWatchLogsWrapper"
 sample_files:
   - "README.md"
   - "chat_sfn_state_machine.json"

.gitignore

@@ -38,3 +38,6 @@ kotlin/services/**/gradlew
 kotlin/services/**/gradlew.bat
 kotlin/services/**/.kotlin/
 /.local/
+.kiro/settings/
+.kiro/steering/
+

.tools/readmes/config.py

@@ -129,6 +129,7 @@
                 "auto-scaling": "dotnetv4/AutoScaling",
                 "cloudformation": "dotnetv4/CloudFormation",
                 "cloudwatch": "dotnetv4/CloudWatch",
+                "cloudwatch-logs": "dotnetv4/CloudWatchLogs",
                 "cognito-identity-provider": "dotnetv4/Cognito",
                 "ec2": "dotnetv4/EC2",
                 "ecs": "dotnetv4/ECS",

dotnetv3/CloudWatchLogs/README.md

@@ -99,4 +99,4 @@ in the `dotnetv3` folder.
 
 Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 
-SPDX-License-Identifier: Apache-2.0
+SPDX-License-Identifier: Apache-2.0

dotnetv4/CloudWatchLogs/LargeQuery/Actions/CloudWatchLogsActions.csproj

@@ -0,0 +1,18 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Library</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="AWSSDK.CloudFormation" Version="3.7.*" />
+    <PackageReference Include="AWSSDK.CloudWatchLogs" Version="3.7.*" />
+    <PackageReference Include="AWSSDK.Extensions.NETCore.Setup" Version="3.7.*" />
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="8.0.*" />
+    <PackageReference Include="Microsoft.Extensions.Hosting" Version="8.0.*" />
+  </ItemGroup>
+
+</Project>

dotnetv4/CloudWatchLogs/LargeQuery/Actions/CloudWatchLogsWrapper.cs

@@ -0,0 +1,148 @@
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+// snippet-start:[CloudWatchLogs.dotnetv4.CloudWatchLogsWrapper]
+using Amazon.CloudWatchLogs;
+using Amazon.CloudWatchLogs.Model;
+using Microsoft.Extensions.Logging;
+
+namespace CloudWatchLogsActions;
+
+/// <summary>
+/// Wrapper class for Amazon CloudWatch Logs operations.
+/// </summary>
+public class CloudWatchLogsWrapper
+{
+    private readonly IAmazonCloudWatchLogs _amazonCloudWatchLogs;
+    private readonly ILogger<CloudWatchLogsWrapper> _logger;
+
+    /// <summary>
+    /// Constructor for the CloudWatchLogsWrapper class.
+    /// </summary>
+    /// <param name="amazonCloudWatchLogs">The injected CloudWatch Logs client.</param>
+    /// <param name="logger">The injected logger.</param>
+    public CloudWatchLogsWrapper(IAmazonCloudWatchLogs amazonCloudWatchLogs, ILogger<CloudWatchLogsWrapper> logger)
+    {
+        _amazonCloudWatchLogs = amazonCloudWatchLogs;
+        _logger = logger;
+    }
+
+    // snippet-start:[CloudWatchLogs.dotnetv4.StartQuery]
+    /// <summary>
+    /// Starts a CloudWatch Logs Insights query.
+    /// </summary>
+    /// <param name="logGroupName">The name of the log group to query.</param>
+    /// <param name="queryString">The CloudWatch Logs Insights query string.</param>
+    /// <param name="startTime">The start time for the query (seconds since epoch).</param>
+    /// <param name="endTime">The end time for the query (seconds since epoch).</param>
+    /// <param name="limit">The maximum number of results to return.</param>
+    /// <returns>The query ID if successful, null otherwise.</returns>
+    public async Task<string?> StartQueryAsync(
+        string logGroupName,
+        string queryString,
+        long startTime,
+        long endTime,
+        int limit = 10000)
+    {
+        try
+        {
+            var request = new StartQueryRequest
+            {
+                LogGroupName = logGroupName,
+                QueryString = queryString,
+                StartTime = startTime,
+                EndTime = endTime,
+                Limit = limit
+            };
+
+            var response = await _amazonCloudWatchLogs.StartQueryAsync(request);
+            return response.QueryId;
+        }
+        catch (InvalidParameterException ex)
+        {
+            _logger.LogError($"Invalid parameter for query: {ex.Message}");
+            return null;
+        }
+        catch (ResourceNotFoundException ex)
+        {
+            _logger.LogError($"Log group not found: {ex.Message}");
+            return null;
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError($"An error occurred while starting query: {ex.Message}");
+            return null;
+        }
+    }
+    // snippet-end:[CloudWatchLogs.dotnetv4.StartQuery]
+
+    // snippet-start:[CloudWatchLogs.dotnetv4.GetQueryResults]
+    /// <summary>
+    /// Gets the results of a CloudWatch Logs Insights query.
+    /// </summary>
+    /// <param name="queryId">The ID of the query.</param>
+    /// <returns>The query results response.</returns>
+    public async Task<GetQueryResultsResponse?> GetQueryResultsAsync(string queryId)
+    {
+        try
+        {
+            var request = new GetQueryResultsRequest
+            {
+                QueryId = queryId
+            };
+
+            var response = await _amazonCloudWatchLogs.GetQueryResultsAsync(request);
+            return response;
+        }
+        catch (ResourceNotFoundException ex)
+        {
+            _logger.LogError($"Query not found: {ex.Message}");
+            return null;
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError($"An error occurred while getting query results: {ex.Message}");
+            return null;
+        }
+    }
+    // snippet-end:[CloudWatchLogs.dotnetv4.GetQueryResults]
+
+    // snippet-start:[CloudWatchLogs.dotnetv4.PutLogEvents]
+    /// <summary>
+    /// Puts log events to a CloudWatch Logs log stream.
+    /// </summary>
+    /// <param name="logGroupName">The name of the log group.</param>
+    /// <param name="logStreamName">The name of the log stream.</param>
+    /// <param name="logEvents">The list of log events to put.</param>
+    /// <returns>True if successful, false otherwise.</returns>
+    public async Task<bool> PutLogEventsAsync(
+        string logGroupName,
+        string logStreamName,
+        List<InputLogEvent> logEvents)
+    {
+        try
+        {
+            var request = new PutLogEventsRequest
+            {
+                LogGroupName = logGroupName,
+                LogStreamName = logStreamName,
+                LogEvents = logEvents
+            };
+
+            await _amazonCloudWatchLogs.PutLogEventsAsync(request);
+            return true;
+        }
+        catch (ResourceNotFoundException ex)
+        {
+            _logger.LogError($"Log group or stream not found: {ex.Message}");
+            return false;
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError($"An error occurred while putting log events: {ex.Message}");
+            return false;
+        }
+    }
+    // snippet-end:[CloudWatchLogs.dotnetv4.PutLogEvents]
+}
+// snippet-end:[CloudWatchLogs.dotnetv4.CloudWatchLogsWrapper]

dotnetv4/CloudWatchLogs/LargeQuery/CloudWatchLogsLargeQuery.sln

@@ -0,0 +1,31 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.0.31903.59
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CloudWatchLogsActions", "Actions\CloudWatchLogsActions.csproj", "{A1B2C3D4-E5F6-4A5B-8C9D-0E1F2A3B4C5D}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CloudWatchLogsScenario", "Scenarios\CloudWatchLogsScenario.csproj", "{B2C3D4E5-F6A7-5B6C-9D0E-1F2A3B4C5D6E}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CloudWatchLogsTests", "Tests\CloudWatchLogsTests.csproj", "{C3D4E5F6-A7B8-6C7D-0E1F-2A3B4C5D6E7F}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{A1B2C3D4-E5F6-4A5B-8C9D-0E1F2A3B4C5D}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{A1B2C3D4-E5F6-4A5B-8C9D-0E1F2A3B4C5D}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{A1B2C3D4-E5F6-4A5B-8C9D-0E1F2A3B4C5D}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{A1B2C3D4-E5F6-4A5B-8C9D-0E1F2A3B4C5D}.Release|Any CPU.Build.0 = Release|Any CPU
+		{B2C3D4E5-F6A7-5B6C-9D0E-1F2A3B4C5D6E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{B2C3D4E5-F6A7-5B6C-9D0E-1F2A3B4C5D6E}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{B2C3D4E5-F6A7-5B6C-9D0E-1F2A3B4C5D6E}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{B2C3D4E5-F6A7-5B6C-9D0E-1F2A3B4C5D6E}.Release|Any CPU.Build.0 = Release|Any CPU
+		{C3D4E5F6-A7B8-6C7D-0E1F-2A3B4C5D6E7F}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{C3D4E5F6-A7B8-6C7D-0E1F-2A3B4C5D6E7F}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{C3D4E5F6-A7B8-6C7D-0E1F-2A3B4C5D6E7F}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{C3D4E5F6-A7B8-6C7D-0E1F-2A3B4C5D6E7F}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+EndGlobal