(#245) Amazon CloudWatch Logs

phongnguyend · Jul 20, 2024 · 539677f · 539677f
1 parent d19bb60
commit 539677f
Show file tree

Hide file tree

Showing 6 changed files with 98 additions and 2 deletions.
diff --git a/src/Microservices/Common/ClassifiedAds.Infrastructure/ClassifiedAds.Infrastructure.csproj b/src/Microservices/Common/ClassifiedAds.Infrastructure/ClassifiedAds.Infrastructure.csproj
@@ -7,6 +7,7 @@
 
   <ItemGroup>
     <FrameworkReference Include="Microsoft.AspNetCore.App" />
+    <PackageReference Include="AWS.Logger.SeriLog" Version="3.4.3" />
     <PackageReference Include="AWSSDK.S3" Version="3.7.304.8" />
     <PackageReference Include="Azure.Communication.Sms" Version="1.0.1" />
     <PackageReference Include="Azure.Data.AppConfiguration" Version="1.3.0" />

diff --git a/src/Microservices/Common/ClassifiedAds.Infrastructure/Logging/LoggingExtensions.cs b/src/Microservices/Common/ClassifiedAds.Infrastructure/Logging/LoggingExtensions.cs
@@ -1,4 +1,7 @@
-using Azure.Monitor.OpenTelemetry.Exporter;
+using Amazon.Runtime;
+using AWS.Logger;
+using AWS.Logger.SeriLog;
+using Azure.Monitor.OpenTelemetry.Exporter;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Hosting;
@@ -9,6 +12,7 @@
 using OpenTelemetry.Trace;
 using Serilog;
 using Serilog.Exceptions;
+using Serilog.Formatting.Json;
 using System;
 using System.Collections.Generic;
 using System.Globalization;
@@ -64,6 +68,19 @@ private static void UseClassifiedAdsLogger(this IWebHostEnvironment env, Logging
                 outputTemplate: "{Timestamp:yyyy-MM-dd HH:mm:ss.fff zzz} [{Level:u3}] [{SourceContext}] [TraceId: {TraceId}] [MachineName: {MachineName}] [ProcessId: {ProcessId}] {Message:lj}{NewLine}{Exception}",
                 restrictedToMinimumLevel: options.File.MinimumLogEventLevel);
 
+        if (options?.AwsCloudWatch?.IsEnabled ?? false)
+        {
+            loggerConfiguration
+                .WriteTo.AWSSeriLog(new AWSLoggerConfig(options.AwsCloudWatch.LogGroup)
+                {
+                    LogStreamNamePrefix = options.AwsCloudWatch.LogStreamNamePrefix,
+                    Region = options.AwsCloudWatch.Region,
+                    Credentials = new BasicAWSCredentials(options.AwsCloudWatch.AccessKey, options.AwsCloudWatch.SecretKey),
+                },
+                iFormatProvider: null,
+                textFormatter: new JsonFormatter());
+        }
+
         Log.Logger = loggerConfiguration.CreateLogger();
     }
 
@@ -281,6 +298,19 @@ private static void UseClassifiedAdsLogger(this IHostEnvironment env, LoggingOpt
                 outputTemplate: "{Timestamp:yyyy-MM-dd HH:mm:ss.fff zzz} [{Level:u3}] [{SourceContext}] [TraceId: {TraceId}] [MachineName: {MachineName}] [ProcessId: {ProcessId}] {Message:lj}{NewLine}{Exception}",
                 restrictedToMinimumLevel: options.File.MinimumLogEventLevel);
 
+        if (options?.AwsCloudWatch?.IsEnabled ?? false)
+        {
+            loggerConfiguration
+            .WriteTo.AWSSeriLog(new AWSLoggerConfig(options.AwsCloudWatch.LogGroup)
+                {
+                    LogStreamName = options.AwsCloudWatch.LogStreamNamePrefix,
+                    Region = options.AwsCloudWatch.Region,
+                    Credentials = new BasicAWSCredentials(options.AwsCloudWatch.AccessKey, options.AwsCloudWatch.SecretKey),
+                },
+                iFormatProvider: null,
+                textFormatter: new JsonFormatter());
+        }
+
         Log.Logger = loggerConfiguration.CreateLogger();
     }
 }
diff --git a/src/Microservices/Common/ClassifiedAds.Infrastructure/Logging/LoggingOptions.cs b/src/Microservices/Common/ClassifiedAds.Infrastructure/Logging/LoggingOptions.cs
@@ -13,6 +13,8 @@ public class LoggingOptions
 
     public ApplicationInsightsOptions ApplicationInsights { get; set; }
 
+    public AwsCloudWatchOptions AwsCloudWatch { get; set; }
+
     public OpenTelemetryOptions OpenTelemetry { get; set; }
 
     public class FileOptions
@@ -36,6 +38,21 @@ public class ApplicationInsightsOptions
         public string InstrumentationKey { get; set; }
     }
 
+    public class AwsCloudWatchOptions
+    {
+        public bool IsEnabled { get; set; }
+
+        public string LogGroup { get; set; }
+
+        public string LogStreamNamePrefix { get; set; }
+
+        public string Region { get; set; }
+
+        public string AccessKey { get; set; }
+
+        public string SecretKey { get; set; }
+    }
+
     public class OpenTelemetryOptions
     {
         public bool IsEnabled { get; set; }

diff --git a/src/ModularMonolith/ClassifiedAds.Infrastructure/ClassifiedAds.Infrastructure.csproj b/src/ModularMonolith/ClassifiedAds.Infrastructure/ClassifiedAds.Infrastructure.csproj
@@ -7,6 +7,7 @@
 
   <ItemGroup>
     <FrameworkReference Include="Microsoft.AspNetCore.App" />
+    <PackageReference Include="AWS.Logger.SeriLog" Version="3.4.3" />
     <PackageReference Include="AWSSDK.S3" Version="3.7.304.8" />
     <PackageReference Include="Azure.Communication.Sms" Version="1.0.1" />
     <PackageReference Include="Azure.Data.AppConfiguration" Version="1.3.0" />

diff --git a/src/ModularMonolith/ClassifiedAds.Infrastructure/Logging/LoggingExtensions.cs b/src/ModularMonolith/ClassifiedAds.Infrastructure/Logging/LoggingExtensions.cs
@@ -1,4 +1,7 @@
-using Azure.Monitor.OpenTelemetry.Exporter;
+using Amazon.Runtime;
+using AWS.Logger;
+using AWS.Logger.SeriLog;
+using Azure.Monitor.OpenTelemetry.Exporter;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Hosting;
@@ -9,6 +12,7 @@
 using OpenTelemetry.Trace;
 using Serilog;
 using Serilog.Exceptions;
+using Serilog.Formatting.Json;
 using System;
 using System.Collections.Generic;
 using System.Globalization;
@@ -64,6 +68,19 @@ private static void UseClassifiedAdsLogger(this IWebHostEnvironment env, Logging
                 outputTemplate: "{Timestamp:yyyy-MM-dd HH:mm:ss.fff zzz} [{Level:u3}] [{SourceContext}] [TraceId: {TraceId}] [MachineName: {MachineName}] [ProcessId: {ProcessId}] {Message:lj}{NewLine}{Exception}",
                 restrictedToMinimumLevel: options.File.MinimumLogEventLevel);
 
+        if (options?.AwsCloudWatch?.IsEnabled ?? false)
+        {
+            loggerConfiguration
+                .WriteTo.AWSSeriLog(new AWSLoggerConfig(options.AwsCloudWatch.LogGroup)
+                {
+                    LogStreamNamePrefix = options.AwsCloudWatch.LogStreamNamePrefix,
+                    Region = options.AwsCloudWatch.Region,
+                    Credentials = new BasicAWSCredentials(options.AwsCloudWatch.AccessKey, options.AwsCloudWatch.SecretKey),
+                },
+                iFormatProvider: null,
+                textFormatter: new JsonFormatter());
+        }
+
         Log.Logger = loggerConfiguration.CreateLogger();
     }
 
@@ -281,6 +298,19 @@ private static void UseClassifiedAdsLogger(this IHostEnvironment env, LoggingOpt
                 outputTemplate: "{Timestamp:yyyy-MM-dd HH:mm:ss.fff zzz} [{Level:u3}] [{SourceContext}] [TraceId: {TraceId}] [MachineName: {MachineName}] [ProcessId: {ProcessId}] {Message:lj}{NewLine}{Exception}",
                 restrictedToMinimumLevel: options.File.MinimumLogEventLevel);
 
+        if (options?.AwsCloudWatch?.IsEnabled ?? false)
+        {
+            loggerConfiguration
+            .WriteTo.AWSSeriLog(new AWSLoggerConfig(options.AwsCloudWatch.LogGroup)
+                {
+                    LogStreamName = options.AwsCloudWatch.LogStreamNamePrefix,
+                    Region = options.AwsCloudWatch.Region,
+                    Credentials = new BasicAWSCredentials(options.AwsCloudWatch.AccessKey, options.AwsCloudWatch.SecretKey),
+                },
+                iFormatProvider: null,
+                textFormatter: new JsonFormatter());
+        }
+
         Log.Logger = loggerConfiguration.CreateLogger();
     }
 }
diff --git a/src/ModularMonolith/ClassifiedAds.Infrastructure/Logging/LoggingOptions.cs b/src/ModularMonolith/ClassifiedAds.Infrastructure/Logging/LoggingOptions.cs
@@ -13,6 +13,8 @@ public class LoggingOptions
 
     public ApplicationInsightsOptions ApplicationInsights { get; set; }
 
+    public AwsCloudWatchOptions AwsCloudWatch { get; set; }
+
     public OpenTelemetryOptions OpenTelemetry { get; set; }
 
     public class FileOptions
@@ -36,6 +38,21 @@ public class ApplicationInsightsOptions
         public string InstrumentationKey { get; set; }
     }
 
+    public class AwsCloudWatchOptions
+    {
+        public bool IsEnabled { get; set; }
+
+        public string LogGroup { get; set; }
+
+        public string LogStreamNamePrefix { get; set; }
+
+        public string Region { get; set; }
+
+        public string AccessKey { get; set; }
+
+        public string SecretKey { get; set; }
+    }
+
     public class OpenTelemetryOptions
     {
         public bool IsEnabled { get; set; }