I was preparing to take the exam for AWS Solutions architecture Associate level certificate and I faced a really trick question: I see Kinesis Streams as a good solution, we receive data from multiple sources and the number of cosumers…
everyone. I'm interested in get the content of SQS Message using Lambda. Let me explain my infrastructure: I have an EC2 instance that has a script like that bellow. So, it script will send to SQS the message containing instance…
this lambda is triggered by sqs and fetches messages from sqs and updates dynamodb table. 2 policies are attached to the lambda - to be called by sqs(get queue) and to put_item into dynamodb table. import boto3 import json import…
I'd like to receive an email if my Lambda fails. The Lambda is triggered via SNS (which is triggered by SES). When I publish to the SNS Topic, the Lambda runs and throws an error (for testing) due to a…
I created SQS service with terraform resource "aws_sqs_queue" "ses_queue" { name = "ses_queue" message_retention_seconds = 86400 receive_wait_time_seconds = 1 visibility_timeout_seconds = 15 } resource "aws_lambda_event_source_mapping" "send_email_message" { event_source_arn = aws_sqs_queue.ses_queue.arn function_name = aws_lambda_function.send_email_message.function_name batch_size = 5 } I am sending…
When using AWS Lambda with a SQS queue (as event source), it is written in the doc If messages are still available, Lambda increases the number of processes that are reading batches by up to 60 more instances per minute.…
My requirement is like this. Read from a SQS every 2 hours, take all the messages available and then process it. Processing includes creating a file with details from SQS messages and sending it to an sftp server. I implemented…
I created a standard queue with the following specs: delay seconds: 0 max receive count (redrive policy): 10 visibility timeout: 300 I have a lambda consumer that receives the messages. From the documentation, it says that you need to explicitly…
in the AWS doc, it is written Lambda reads up to five batches and sends them to your function. (https://docs.aws.amazon.com/lambda/latest/dg/with-sqs.html#events-sqs-scaling) I am a bit confused about that part "reads up to five batches". Does it mean: 5 SQS ReceiveMessage API…
I am using the AWS SDK for PHP to push a message into an AWS SQS queue. I'd like to be able to set the visibility timeout for specific messages to be different than the default. It would make sense…