docs(examples): add SAM template with S3 and SQS resources

Signed-off-by: Santiago <sasanchezramirez@gmail.com>

Author: sasanchezramirez

examples/pom.xml

@@ -45,6 +45,7 @@
         <module>powertools-examples-batch</module>
         <module>powertools-examples-validation</module>
         <module>powertools-examples-cloudformation</module>
+        <module>powertools-examples-large-messages</module>
     </modules>
 
     <build>

examples/powertools-examples-large-messages/pom.xml

@@ -3,9 +3,9 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>software.amazon.lambda.examples</groupId>
     <version>2.8.0</version>
-    <artifactId>powertools-examples-kafka</artifactId>
+    <artifactId>powertools-examples-large-messages</artifactId>
     <packaging>jar</packaging>
-    <name>Powertools for AWS Lambda (Java) - Examples - Kafka</name>
+    <name>Powertools for AWS Lambda (Java) - Examples - Large Messages</name>
 
     <properties>
         <maven.compiler.source>11</maven.compiler.source>
@@ -18,23 +18,13 @@
     <dependencies>
         <dependency>
             <groupId>software.amazon.lambda</groupId>
-            <artifactId>powertools-kafka</artifactId>
+            <artifactId>powertools-large-messages</artifactId>
             <version>${project.version}</version>
         </dependency>
         <dependency>
-            <groupId>org.apache.kafka</groupId>
-            <artifactId>kafka-clients</artifactId>
-            <version>4.1.1</version> <!-- Supports >= 3.0.0 -->
-        </dependency>
-        <dependency>
-            <groupId>org.apache.avro</groupId>
-            <artifactId>avro</artifactId>
-            <version>${avro.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>com.google.protobuf</groupId>
-            <artifactId>protobuf-java</artifactId>
-            <version>${protobuf.version}</version>
+            <groupId>com.amazonaws</groupId>
+            <artifactId>amazon-sqs-java-extended-client-lib</artifactId>
+            <version>2.1.1</version>
         </dependency>
 
         <!-- Basic logging setup -->

examples/powertools-examples-large-messages/template.yaml

@@ -1,59 +1,63 @@
 AWSTemplateFormatVersion: "2010-09-09"
 Transform: AWS::Serverless-2016-10-31
 Description: >
-  Kafka Deserialization example with Kafka Lambda ESM
+  Large Message Handling Example using SQS and S3 offloading
 
 Globals:
   Function:
-    Timeout: 20
+    Timeout: 30
     Runtime: java11
     MemorySize: 512
     Tracing: Active
+    Environment:
+      Variables:
+        JAVA_TOOL_OPTIONS: "-XX:+TieredCompilation -XX:TieredStopAtLevel=1"
+        POWERTOOLS_LOG_LEVEL: INFO
+        POWERTOOLS_SERVICE_NAME: LargeMessageExample
 
 Resources:
-  JsonDeserializationFunction:
-    Type: AWS::Serverless::Function
+  LargeMessageBucket:
+    Type: AWS::S3::Bucket
     Properties:
-      CodeUri: .
-      Handler: org.demo.kafka.JsonDeserializationFunction::handleRequest
-      Environment:
-        Variables:
-          JAVA_TOOL_OPTIONS: "-XX:+TieredCompilation -XX:TieredStopAtLevel=1"
-          POWERTOOLS_LOG_LEVEL: DEBUG
-          POWERTOOLS_SERVICE_NAME: JsonDeserialization
-          POWERTOOLS_METRICS_NAMESPACE: JsonDeserializationFunction
-
-  AvroDeserializationFunction:
-    Type: AWS::Serverless::Function
+      LifecycleConfiguration:
+        Rules:
+          - Id: DeleteOldMessages
+            Status: Enabled
+            ExpirationInDays: 1
+  MyLargeMessageQueue:
+    Type: AWS::SQS::Queue
     Properties:
-      CodeUri: .
-      Handler: org.demo.kafka.AvroDeserializationFunction::handleRequest
-      Environment:
-        Variables:
-          JAVA_TOOL_OPTIONS: "-XX:+TieredCompilation -XX:TieredStopAtLevel=1"
-          POWERTOOLS_LOG_LEVEL: DEBUG
-          POWERTOOLS_SERVICE_NAME: AvroDeserialization
-          POWERTOOLS_METRICS_NAMESPACE: AvroDeserializationFunction
-
-  ProtobufDeserializationFunction:
+      VisibilityTimeout: 30
+  LargeMessageProcessingFunction:
     Type: AWS::Serverless::Function
     Properties:
       CodeUri: .
-      Handler: org.demo.kafka.ProtobufDeserializationFunction::handleRequest
+      # IMPORTANTE: Asegúrate que esto coincida con tu paquete y clase Java
+      Handler: helloworld.App::handleRequest
+
+      Policies:
+        - S3CrudPolicy:
+            BucketName: !Ref LargeMessageBucket
+        - SQSPollerPolicy:
+            QueueName: !GetAtt MyLargeMessageQueue.QueueName
+
       Environment:
         Variables:
-          JAVA_TOOL_OPTIONS: "-XX:+TieredCompilation -XX:TieredStopAtLevel=1"
-          POWERTOOLS_LOG_LEVEL: DEBUG
-          POWERTOOLS_SERVICE_NAME: ProtobufDeserialization
-          POWERTOOLS_METRICS_NAMESPACE: ProtobufDeserializationFunction
+          POWERTOOLS_LARGE_MESSAGES_BUCKET: !Ref LargeMessageBucket
 
+      Events:
+        SQSEvent:
+          Type: SQS
+          Properties:
+            Queue: !GetAtt MyLargeMessageQueue.Arn
+            BatchSize: 1
 Outputs:
-  JsonFunction:
-    Description: "Kafka JSON Lambda Function ARN"
-    Value: !GetAtt JsonDeserializationFunction.Arn
-  AvroFunction:
-    Description: "Kafka Avro Lambda Function ARN"
-    Value: !GetAtt AvroDeserializationFunction.Arn
-  ProtobufFunction:
-    Description: "Kafka Protobuf Lambda Function ARN"
-    Value: !GetAtt ProtobufDeserializationFunction.Arn
+  LargeMessageBucketName:
+    Description: "S3 Bucket for large payloads"
+    Value: !Ref LargeMessageBucket
+  QueueURL:
+    Description: "SQS Queue URL"
+    Value: !Ref MyLargeMessageQueue
+  FunctionArn:
+    Description: "Lambda Function ARN"
+    Value: !GetAtt LargeMessageProcessingFunction.Arn