Task 6 (SQS & SNS, Async Microservices Communication)

[Tati-Moon]

Task 6

https://github.com/rolling-scopes-school/aws/blob/main/aws-developer/06_async_microservices_communication/task.md

When exporting data, the values are either updated or added

• File for update products file_test.csv
• File for add new products file.csv
• Frontend
• Product Service API
• Product Service API for id = 441905d7-55c7-4814-85be-b3e6045b29b2
• Swagger openapi.yaml

Evaluation Criteria

• 100/100

Task 6.1

• Created a lambda function called catalogBatchProcess under the Product Service, which is triggered by an SQS event.
• Created an SQS queue called catalogItemsQueue in the AWS CDK Stack.
• Configured the SQS to trigger the lambda catalogBatchProcess with 5 messages at once via the batchSize property.
• The lambda function iterates over all SQS messages and creates corresponding products in the products table.

Task 6.2

• Updated the importFileParser lambda function in the Import Service to send each CSV record into SQS.
• It no longer logs entries from the readable stream to CloudWatch.

Task 6.3

• Created an SNS topic createProductTopic and an email subscription in the AWS CDK Stack of the Product Service.
• Created a subscription for this SNS topic with an email endpoint type, using your own email.
• Updated the catalogBatchProcess lambda function in the Product Service to send an event to the SNS topic once it creates products.

Additional Tasks

• The catalogBatchProcess lambda is covered by unit tests.
  Tests catalogBatchProcess.js

• Set a Filter Policy for the SNS createProductTopic in the AWS CDK Stack and created an additional email subscription to distribute messages to different emails depending on the filter for any product attribute.