From 850990161020b66deb5a7e34765b9c8f8f28f8e8 Mon Sep 17 00:00:00 2001 From: Akhil Dangore Date: Thu, 16 Apr 2026 17:26:38 +0530 Subject: [PATCH 1/4] Updated loggroup lambda connector --- loggroup-lambda-connector/sam/packaged.yaml | 6 +-- loggroup-lambda-connector/sam/template.yaml | 4 +- .../src/loggroup-lambda-connector.js | 41 ++++++++++++------- 3 files changed, 31 insertions(+), 20 deletions(-) diff --git a/loggroup-lambda-connector/sam/packaged.yaml b/loggroup-lambda-connector/sam/packaged.yaml index 92a99a3..dd55e82 100644 --- a/loggroup-lambda-connector/sam/packaged.yaml +++ b/loggroup-lambda-connector/sam/packaged.yaml @@ -107,9 +107,9 @@ Resources: SumoLogGroupLambdaConnector: Type: AWS::Serverless::Function Properties: - CodeUri: s3://appdevstore/LoggroupConnector/v1.0.16/1c2a1905b7cc328190497a4582481fb6 + CodeUri: s3://appdevstore/LoggroupConnector/00026b4d91b0d0a89abec3e0cfe43475 Handler: loggroup-lambda-connector.handler - Runtime: nodejs22.x + Runtime: nodejs24.x Environment: Variables: DESTINATION_ARN: @@ -202,7 +202,7 @@ Resources: \ console.log(responseData.Error + \":\\n\", err);\n }\n \n await response.send(event,\ \ context, responseStatus, responseData);\n};\n" Handler: index.handler - Runtime: nodejs22.x + Runtime: nodejs24.x Environment: Variables: FUNCTION_NAME: diff --git a/loggroup-lambda-connector/sam/template.yaml b/loggroup-lambda-connector/sam/template.yaml index 732406a..21984f8 100644 --- a/loggroup-lambda-connector/sam/template.yaml +++ b/loggroup-lambda-connector/sam/template.yaml @@ -99,7 +99,7 @@ Resources: Properties: CodeUri: ../src/ Handler: "loggroup-lambda-connector.handler" - Runtime: nodejs22.x + Runtime: nodejs24.x Environment: Variables: DESTINATION_ARN: !Ref "DestinationArnValue" @@ -193,7 +193,7 @@ Resources: await response.send(event, context, responseStatus, responseData); }; Handler: "index.handler" - Runtime: nodejs22.x + Runtime: nodejs24.x Environment: Variables: FUNCTION_NAME: !Ref SumoLogGroupLambdaConnector diff --git a/loggroup-lambda-connector/src/loggroup-lambda-connector.js b/loggroup-lambda-connector/src/loggroup-lambda-connector.js index 85912d0..9a36692 100644 --- a/loggroup-lambda-connector/src/loggroup-lambda-connector.js +++ b/loggroup-lambda-connector/src/loggroup-lambda-connector.js @@ -218,32 +218,43 @@ async function processEvents(env, event, additionalArgs, errorHandler, retryCoun } } -exports.handler = async function (event, context, callback) { +exports.handler = async (event, context) => { + const partition = context.invokedFunctionArn?.split(":")?.[1] ?? "aws"; + let additionalArgs = { recordCount: 0, subscribeCount: 0, invokeCount: 0, partition: partition }; + if (event.additionalArgs) { - additionalArgs = event.additionalArgs + additionalArgs = event.additionalArgs; } + console.log("Invoking Log Group connector function"); + function errorHandler(err, msg) { if (err) { - console.log(err, msg); - callback(err); - } else { - callback(null, "Success"); - } - } - if (!process.env.LOG_GROUP_PATTERN || process.env.LOG_GROUP_PATTERN.trim().length === 0) { - console.warn("LOG_GROUP_PATTERN is empty, it will subscribe to all loggroups"); - } - if (event.existingLogs == "true") { - await processExistingLogGroups(context, event.token, additionalArgs, errorHandler); - } else { - await processEvents(process.env, event, additionalArgs, errorHandler); + console.error(msg, err); + throw err; } + return "Success"; + } + + if (!process.env.LOG_GROUP_PATTERN || process.env.LOG_GROUP_PATTERN.trim().length === 0) { + console.warn("LOG_GROUP_PATTERN is empty, it will subscribe to all loggroups"); + } + + if (event.existingLogs === "true") { + await processExistingLogGroups(context, event.token, additionalArgs, errorHandler); + } else { + await processEvents(process.env, event, additionalArgs, errorHandler); + } + + return { + statusCode: 200, + body: "Success" + }; }; \ No newline at end of file From bc94797256ab480d849a425d37c691b5f3b33ac2 Mon Sep 17 00:00:00 2001 From: Akhil Dangore Date: Thu, 16 Apr 2026 18:12:59 +0530 Subject: [PATCH 2/4] Updated Python version sumo_app_utils --- sumologic-app-utils/packaged_sumo_app_utils.yaml | 2 +- sumologic-app-utils/sumo_app_utils.yaml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/sumologic-app-utils/packaged_sumo_app_utils.yaml b/sumologic-app-utils/packaged_sumo_app_utils.yaml index f263ab5..725dd17 100644 --- a/sumologic-app-utils/packaged_sumo_app_utils.yaml +++ b/sumologic-app-utils/packaged_sumo_app_utils.yaml @@ -29,7 +29,7 @@ Resources: Type: AWS::Serverless::Function Properties: Handler: main.handler - Runtime: python3.13 + Runtime: python3.14 CodeUri: s3://appdevstore/sumo_app_utils/v2.0.23/sumo_app_utils.zip MemorySize: 128 Timeout: 300 diff --git a/sumologic-app-utils/sumo_app_utils.yaml b/sumologic-app-utils/sumo_app_utils.yaml index 6f1398e..3e5d701 100644 --- a/sumologic-app-utils/sumo_app_utils.yaml +++ b/sumologic-app-utils/sumo_app_utils.yaml @@ -28,7 +28,7 @@ Resources: Type: 'AWS::Serverless::Function' Properties: Handler: main.handler - Runtime: python3.13 + Runtime: python3.14 CodeUri: s3://appdevstore/sumo_app_utils/v2.0.23/sumo_app_utils.zip MemorySize: 128 Timeout: 300 From 1c768e329540d1ffa73f8ad4ee0fcb146dba62c6 Mon Sep 17 00:00:00 2001 From: Akhil Dangore Date: Thu, 16 Apr 2026 19:13:41 +0530 Subject: [PATCH 3/4] Updated Runtime --- awsautoenableS3Logging/packaged.yaml | 14 +++++++------- .../sumologic-s3-logging-auto-enable.yaml | 10 +++++----- 2 files changed, 12 insertions(+), 12 deletions(-) diff --git a/awsautoenableS3Logging/packaged.yaml b/awsautoenableS3Logging/packaged.yaml index b6be531..a4a31c2 100644 --- a/awsautoenableS3Logging/packaged.yaml +++ b/awsautoenableS3Logging/packaged.yaml @@ -24,10 +24,10 @@ Metadata: - s3logging - flowlogs Name: sumologic-s3-logging-auto-enable - SemanticVersion: 1.0.18 + SemanticVersion: 1.0.19 SourceCodeUrl: https://github.com/SumoLogic/sumologic-aws-lambda/tree/main/awsautoenableS3Logging - LicenseUrl: s3://appdevstore/AutoEnableS3Logs/v1.0.18/978602b5b9ec16f8bab0e38fd6b3998f - ReadmeUrl: s3://appdevstore/AutoEnableS3Logs/v1.0.18/d05d411471e0bb4db3389f2523f515f0 + LicenseUrl: s3://appdevstore/AutoEnableS3Logs/v1.0.19/978602b5b9ec16f8bab0e38fd6b3998f + ReadmeUrl: s3://appdevstore/AutoEnableS3Logs/v1.0.19/d05d411471e0bb4db3389f2523f515f0 SpdxLicenseId: Apache-2.0 Mappings: Region2ELBAccountId: @@ -229,9 +229,9 @@ Resources: Type: AWS::Serverless::Function Condition: auto_enable_new Properties: - CodeUri: s3://appdevstore/sumo_app_utils/v2.0.21/sumo_app_utils.zip + CodeUri: s3://appdevstore/sumo_app_utils/v2.0.23/sumo_app_utils.zip Handler: awsresource.enable_s3_logs - Runtime: python3.13 + Runtime: python3.14 Role: Fn::GetAtt: - SumoLambdaRole @@ -466,8 +466,8 @@ Resources: Condition: auto_enable_existing Properties: Handler: main.handler - Runtime: python3.13 - CodeUri: s3://appdevstore/sumo_app_utils/v2.0.21/sumo_app_utils.zip + Runtime: python3.14 + CodeUri: s3://appdevstore/sumo_app_utils/v2.0.23/sumo_app_utils.zip MemorySize: 128 Timeout: 900 Role: diff --git a/awsautoenableS3Logging/sumologic-s3-logging-auto-enable.yaml b/awsautoenableS3Logging/sumologic-s3-logging-auto-enable.yaml index 9f972be..e8d9cdd 100755 --- a/awsautoenableS3Logging/sumologic-s3-logging-auto-enable.yaml +++ b/awsautoenableS3Logging/sumologic-s3-logging-auto-enable.yaml @@ -24,7 +24,7 @@ Metadata: - s3logging - flowlogs Name: sumologic-s3-logging-auto-enable - SemanticVersion: 1.0.18 + SemanticVersion: 1.0.19 SourceCodeUrl: https://github.com/SumoLogic/sumologic-aws-lambda/tree/main/awsautoenableS3Logging LicenseUrl: ./LICENSE ReadmeUrl: ./README.md @@ -208,9 +208,9 @@ Resources: Type: 'AWS::Serverless::Function' Condition: auto_enable_new Properties: - CodeUri: s3://appdevstore/sumo_app_utils/v2.0.21/sumo_app_utils.zip + CodeUri: s3://appdevstore/sumo_app_utils/v2.0.23/sumo_app_utils.zip Handler: "awsresource.enable_s3_logs" - Runtime: python3.13 + Runtime: python3.14 Role: !GetAtt SumoLambdaRole.Arn Description: "Lambda Function for auto enable s3 logs for AWS Resources." MemorySize: 128 @@ -384,8 +384,8 @@ Resources: Condition: auto_enable_existing Properties: Handler: main.handler - Runtime: python3.13 - CodeUri: s3://appdevstore/sumo_app_utils/v2.0.21/sumo_app_utils.zip + Runtime: python3.14 + CodeUri: s3://appdevstore/sumo_app_utils/v2.0.23/sumo_app_utils.zip MemorySize: 128 Timeout: 900 Role: From 8fd67f7f3cf0b10505495b9641ea6b4ae0b42eed Mon Sep 17 00:00:00 2001 From: Akhil Dangore Date: Thu, 16 Apr 2026 19:16:19 +0530 Subject: [PATCH 4/4] Fixed version --- loggroup-lambda-connector/sam/packaged.yaml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/loggroup-lambda-connector/sam/packaged.yaml b/loggroup-lambda-connector/sam/packaged.yaml index dd55e82..ff70fb1 100644 --- a/loggroup-lambda-connector/sam/packaged.yaml +++ b/loggroup-lambda-connector/sam/packaged.yaml @@ -107,7 +107,7 @@ Resources: SumoLogGroupLambdaConnector: Type: AWS::Serverless::Function Properties: - CodeUri: s3://appdevstore/LoggroupConnector/00026b4d91b0d0a89abec3e0cfe43475 + CodeUri: s3://appdevstore/LoggroupConnector/v1.0.16/00026b4d91b0d0a89abec3e0cfe43475 Handler: loggroup-lambda-connector.handler Runtime: nodejs24.x Environment: