6 async microservices communication

[manguianoepam]

No description provided.

[st3venrose]

Hi! Could you provide a description of this PR about what was done and what is missing? Thanks!

[manguianoepam]

Hi! Could you provide a description of this PR about what was done and what is missing? Thanks!

Done:
Create a lambda function called catalogBatchProcess under the same Serverless config file (i.e. serverless.yaml) of the Product Service which will be triggered by an SQS event.
Create an SQS queue called catalogItemsQueue, in the resources section of the same serverless.yml file.
Configure the SQS to trigger lambda catalogBatchProcess with 5 messages at once via batchSize property.
The lambda function should iterate over all SQS messages and create corresponding products in the products table.
Create an SNS topic createProductTopic and email subscription in the resources section in serverless.yml of the Product Service.
Create a subscription for this SNS topic with an email endpoint type with your own email in there.
Update the catalogBatchProcess lambda function in the Product Service to send an event to the SNS topic once it creates products.

Missing:
Update the importFileParser lambda function in the Import Service to send each CSV record into SQS.
It should no longer log entries from the readable stream to CloudWatch.

[st3venrose]

Where do you set an email address to SNS?
I think the filter policy is also missing:
+1 (All languages) - set a Filter Policy for SNS createProductTopic in serverless.yml (Create an additional email subscription and distribute messages to different emails depending on the filter for any product attribute)

[manguianoepam]

Where do you set an email address to SNS? I think the filter policy is also missing: +1 (All languages) - set a Filter Policy for SNS createProductTopic in serverless.yml (Create an additional email subscription and distribute messages to different emails depending on the filter for any product attribute)

I forgot to add that part