Prerequisite:
AWS SQS | AWS Simple Queue Service | How SQS Works | AWS Tutorial
• AWS SQS | AWS Simple Q...
Create and Use an Amazon SQS Queue | Practical
• Create and Use an Amaz...
Note:
---------
A very important in using Lambda with SQS is , if your Lambda function successfully process the message , then Lambda will delete that message from the queue to avoid reprocessing the same message after visibility timeout!
Another very important point is in setting up the visibility time-out -- generally you can put this value = 6 times the Lambda Function execution timeout value.
Lambda Codes:
--------------------------
import json
def lambda_handler(event, context):
TODO implement
print(event['Records'][0]['body'])
print("Event for Team A")
return event
import json
def lambda_handler(event, context):
TODO implement
print(event['Records'][0]['body'])
print("Event for Team B")
return event
In this lab, In this tutorial, you will implement a fanout messaging scenario using Amazon Simple Notification Service (SNS) and Amazon Simple Queue Service (SQS) & Lambda.
Check this playlist for more AWS Projects or POC in Big Data domain:
• Demystifying Data Engi...
20 ноя 2021