aboutsummaryrefslogtreecommitdiffstats
path: root/terraform/events.tf
diff options
context:
space:
mode:
authorbulve-ad <78788030+bulve-ad@users.noreply.github.com>2024-08-21 15:51:03 +0100
committerGitHub <noreply@github.com>2024-08-21 15:51:03 +0100
commitce76bbb2b32b58a93d88db4abdb1bbfbf27243ea (patch)
treeb8e77c62b6a2d50ab04215beb54055d14210a423 /terraform/events.tf
parentc8e94530b65d6807b2b9bb246a542963839cce9d (diff)
parentd01d3bed939d7a17ea2205af502baeeb35510b5c (diff)
downloadde-project-bentley-ce76bbb2b32b58a93d88db4abdb1bbfbf27243ea.tar.gz
de-project-bentley-ce76bbb2b32b58a93d88db4abdb1bbfbf27243ea.zip
Merge branch 'development' into feature/transform_lambda
Diffstat (limited to 'terraform/events.tf')
-rw-r--r--terraform/events.tf44
1 files changed, 31 insertions, 13 deletions
diff --git a/terraform/events.tf b/terraform/events.tf
index 263141f..53ae10a 100644
--- a/terraform/events.tf
+++ b/terraform/events.tf
@@ -1,3 +1,7 @@
+#################
+# Random String #
+#################
+
resource "random_string" "eventbridge_suffix" {
length = 8
special = false
@@ -16,6 +20,10 @@ resource "random_string" "s3_transform_suffix" {
upper = false
}
+#############################
+# EventBridge Configuration #
+#############################
+
resource "aws_cloudwatch_event_rule" "lambda_trigger" {
name = "lambda-scheduled-trigger"
description = "Schedule to trigger the Lambda function"
@@ -25,7 +33,7 @@ resource "aws_cloudwatch_event_rule" "lambda_trigger" {
resource "aws_cloudwatch_event_target" "extract_lambda_cw_event" {
rule = aws_cloudwatch_event_rule.lambda_trigger.name
target_id = "TargetFunctionV1"
- arn = aws_lambda_function.extract_lambda.arn #replaced lambda name placeholder
+ arn = aws_lambda_function.extract_lambda.arn
depends_on = [aws_lambda_permission.allow_eventbridge]
}
@@ -37,54 +45,64 @@ resource "aws_lambda_permission" "allow_eventbridge" {
source_arn = aws_cloudwatch_event_rule.lambda_trigger.arn
lifecycle {
- replace_triggered_by = [random_string.eventbridge_suffix]
+ create_before_destroy = true
+ replace_triggered_by = [random_string.eventbridge_suffix]
}
}
-# below is step function 1
+########################################
+# S3 Extract Bucket Notification Setup #
+########################################
+
resource "aws_lambda_permission" "allow_s3_ingestion" {
statement_id = "AllowS3InvokeLambdaTransform${random_string.s3_ingestion_suffix.result}"
action = "lambda:InvokeFunction"
- function_name = aws_lambda_function.transform_lambda.function_name #replaced lambda name placeholder
+ function_name = aws_lambda_function.transform_lambda.function_name
principal = "s3.amazonaws.com"
- source_arn = aws_s3_bucket.extract_bucket.arn #replaced bucket name placeholder
+ source_arn = aws_s3_bucket.extract_bucket.arn
lifecycle {
- replace_triggered_by = [random_string.s3_ingestion_suffix]
+ create_before_destroy = true
+ replace_triggered_by = [random_string.s3_ingestion_suffix]
}
}
resource "aws_s3_bucket_notification" "extract_bucket_notification" {
- bucket = aws_s3_bucket.extract_bucket.id #replaced bucket name placeholder
+ bucket = aws_s3_bucket.extract_bucket.id
lambda_function {
events = ["s3:ObjectCreated:*"]
- lambda_function_arn = aws_lambda_function.transform_lambda.arn #replaced lambda name placeholder
+ lambda_function_arn = aws_lambda_function.transform_lambda.arn
}
depends_on = [aws_lambda_permission.allow_s3_ingestion]
}
+##########################################
+# S3 Transform Bucket Notification Setup #
+##########################################
+
resource "aws_lambda_permission" "allow_s3_transform_bucket" {
statement_id = "AllowS3InvokeLambdaTransform${random_string.s3_transform_suffix.result}"
action = "lambda:InvokeFunction"
- function_name = aws_lambda_function.transform_lambda.function_name #replaced lambda name placeholder
+ function_name = aws_lambda_function.transform_lambda.function_name
principal = "s3.amazonaws.com"
- source_arn = aws_s3_bucket.transform_bucket.arn #replaced bucket name placeholder
+ source_arn = aws_s3_bucket.transform_bucket.arn
lifecycle {
- replace_triggered_by = [random_string.s3_transform_suffix]
+ create_before_destroy = true
+ replace_triggered_by = [random_string.s3_transform_suffix]
}
}
resource "aws_s3_bucket_notification" "transform_bucket_notification" {
- bucket = aws_s3_bucket.transform_bucket.id #replaced bucket name placeholder
+ bucket = aws_s3_bucket.transform_bucket.id
lambda_function {
events = ["s3:ObjectCreated:*"]
- lambda_function_arn = aws_lambda_function.transform_lambda.arn #replaced lambda name placeholder
+ lambda_function_arn = aws_lambda_function.transform_lambda.arn
}
depends_on = [aws_lambda_permission.allow_s3_transform_bucket]
git.ajschof.me — hosted by ajschofield — powered by cgit