Created sqs queues and eventbridge rules for event delivery

spreaker · Nov 2, 2023 · 79788e2 · 79788e2
1 parent deee963
commit 79788e2
Show file tree

Hide file tree

Showing 2 changed files with 47 additions and 1 deletion.
diff --git a/analytics/deployment/resources/events.yml b/analytics/deployment/resources/events.yml
@@ -2,4 +2,23 @@ Resources:
   MainEventBus:
     Type: AWS::Events::EventBus
     Properties:
-      Name: ${self:custom.appPrefix}-${opt:stage}-main
+      Name: ${self:custom.appPrefix}-${opt:stage}-main
+  SendToSQSArchiveEventRule:
+    Type: AWS::Events::Rule
+    Properties:
+      EventBusName: !Ref MainEventBus
+      EventPattern:
+        source:
+          - monitor
+      State: ENABLED
+      Targets:
+        - Id: send-to-sqs-archive-raw
+          Arn:
+            Fn::GetAtt:
+              - ArchiveRawQueue
+              - Arn
+        - Id: send-to-sqs-archive-database
+          Arn:
+            Fn::GetAtt:
+              - ArchiveDatabaseQueue
+              - Arn
diff --git a/analytics/deployment/resources/sqs.yml b/analytics/deployment/resources/sqs.yml
@@ -4,6 +4,33 @@ Resources:
     Properties:
       QueueName: ${self:custom.appPrefix}-${opt:stage}-blackhole
       MessageRetentionPeriod: 60
+  ArchiveDeadletterQueue:
+    Type: AWS::SQS::Queue
+    Properties:
+      QueueName: ${self:custom.appPrefix}-${opt:stage}-archive-deadletter
+      MessageRetentionPeriod: 604800
+  ArchiveRawQueue:
+    Type: AWS::SQS::Queue
+    Properties:
+      QueueName: ${self:custom.appPrefix}-${opt:stage}-archive-raw
+      VisibilityTimeout: 60
+      RedrivePolicy:
+        maxReceiveCount: 5
+        deadLetterTargetArn:
+          Fn::GetAtt:
+            - ArchiveDeadletterQueue
+            - Arn
+  ArchiveDatabaseQueue:
+    Type: AWS::SQS::Queue
+    Properties:
+      QueueName: ${self:custom.appPrefix}-${opt:stage}-archive-database
+      VisibilityTimeout: 60
+      RedrivePolicy:
+        maxReceiveCount: 5
+        deadLetterTargetArn:
+          Fn::GetAtt:
+            - ArchiveDeadletterQueue
+            - Arn
   AggregateQueue:
     Type: AWS::SQS::Queue
     Properties: