adding s3 trigger event

Author: Raparker88

infra/main.tf

@@ -38,3 +38,53 @@ resource "aws_lambda_function" "hello_lambda" {
   }
 
 }
+
+resource "aws_s3_bucket" "lambda_trigger_bucket" {
+  bucket = var.s3_bucket_name
+}
+
+resource "aws_s3_bucket_notification" "lambda_bucket_notification" {
+  bucket = aws_s3_bucket.lambda_trigger_bucket.id
+
+  lambda_function {
+    lambda_function_arn = aws_lambda_function.hello_lambda.arn
+    events              = ["s3:ObjectCreated:*"]
+    filter_prefix       = "uploads/"
+    filter_suffix       = ".txt"
+  }
+}
+
+resource "aws_lambda_permission" "allow_s3_bucket_notification" {
+  statement_id  = "AllowExecutionFromS3Bucket"
+  action        = "lambda:InvokeFunction"
+  function_name = aws_lambda_function.hello_lambda.function_name
+  principal     = "s3.amazonaws.com"
+  source_arn    = aws_s3_bucket.lambda_trigger_bucket.arn
+}
+
+resource "aws_iam_role_policy" "s3_access_policy" {
+  name = "lambda_s3_access_policy"
+  role = aws_iam_role.lambda_exec_role.id
+
+  policy = jsonencode({
+    Version = "2012-10-17"
+    Statement = [
+      {
+        Action = [
+          "s3:GetObject",
+          "s3:PutObject",
+          "s3:DeleteObject"
+        ]
+        Effect   = "Allow"
+        Resource = "${aws_s3_bucket.lambda_trigger_bucket.arn}/*"
+      },
+      {
+        Action = [
+          "s3:ListBucket"
+        ]
+        Effect   = "Allow"
+        Resource = aws_s3_bucket.lambda_trigger_bucket.arn
+      }
+    ]
+  })
+}

infra/variables.tf

@@ -3,3 +3,9 @@ variable "aws_region" {
   type        = string
   default     = "us-east-2"
 }
+
+variable "s3_bucket_name" {
+  description = "Name of the S3 bucket to trigger the Lambda function"
+  type        = string
+  default     = "hello-lambda-trigger-bucket-unique-name" # IMPORTANT: Change this to a globally unique name
+}

lambda_function.py

@@ -1,6 +1,19 @@
+import json
 
 def lambda_handler(event, context):
+    print("Received S3 event:", json.dumps(event))
+
+    for record in event['Records']:
+        bucket_name = record['s3']['bucket']['name']
+        object_key = record['s3']['object']['key']
+        event_name = record['eventName']
+
+        print(f"Event Name: {event_name}")
+        print(f"Bucket Name: {bucket_name}")
+        print(f"Object Key: {object_key}")
+
+        # You can add more processing here, e.g., download the object, analyze it, etc.
+
     return {
-        'statusCode': 200,
-        'body': 'Hello from Lambda!'
+        'body': json.dumps('Successfully processed S3 event!')
     }