This is basically the same issue as in this question, but the answers there didn't get me to a solution. My configuration is: 1 VPC, 1 subnet, 1 security group. My Lambda runs in the VPC/subnet/sec...

Looking for a way to delay a message in a being sent to a lambda by 5 seconds. So, message 1 received by lambda then 5 seconds later message 2, then 5 seconds later message 3, etc, for say a thousa...

I'm currently working on a website developed with Symfony2 and I need to send messages in an Amazon SQS. In order to do that I added to my composer.json: "aws/aws-sdk-php": "2.4.*" Then when I ...

I want to convert one of my synchronous API into asynchronous. And I believe queue are one way to do this. Like a publisher will push(synchronously) the message into queue which will be consumed by...

I'm facing a problem when trying to deploy my stack via AWS SAM CLI. I'm using the SAM simplified template which I package and deploy. All I want is to create an SQS queue and implicitly create an...

I am attempting to utilize the AWS CLI along with a for loop in bash to iteratively purge multiple SQS message queues. The bash script works almost as intended, the problem I am having is with the ...

I'm currently using a Lambda Function written in Javascript that is setup with an SQS event source to automatically pull messages from an SQS Queue and do some basic processing on the message conte...

I'm trying to use Spring Cloud's AWS SQS in a project I'm working on. At this time, I'm only running the application locally on my dev machine. Thus, what I want is to connect to the SQS on AWS wit...

I have an SNS(encrypted with KMS) which is subscribed by two lambdas. I am trying to add a Redrive policy to one of the subscriptions. The DLQ in question is encrypted. Adding Redrive policy is giv...

I want to build a pub/sub messaging system into my services that are hosted on Amazon Web Services, and creating SQS queues that subscribe to SNS topics seems like the obvious direction to take, bu...

I do not care much about the order of events but I would like the message to be processed exactly once. The lambda listening to SQS messages will store it in DynamoDB so throughput is pretty import...

I am working on an task which involves Lambda function running inside VPC. This function is supposed to push messages to SQS and lambda execution role has policies : AWSLambdaSQSQueueExecutionRole ...

Why is AWS SQS not a default connector for Apache Flink? Is there some technical limitation to doing this? Or was it just something that didn't get done? I want to implement this, any pointers woul...

I have a small set of messages in an SQS queue, that are not deleted even though a deletion request sent to the AWS endpoint returns with a 200 response. The messages are processed by my applicatio...

I created an API gateway that receives JSON data and posts it to SQS queue. My problem is: if I post data with a POSITIVE SIGNAL (+), for example, {"date": "25 + 2"} the positiv...

According to the documentation: Q: How many times will I receive each message? Amazon SQS is engineered to provide “at least once” delivery of all messages in its queues. Although most of the time...

I'm looking for help with an architectural design decision I'm making with a product. We've got multiple producers (initiated by API Gateway calls into Lambda) that put messages on a SQS queue (t...

I need to consume SQS events with my rails application. I've written a Sidekiq job which does a long polling like this: class SqsConsumerWorker include Sidekiq::Worker def perform ... poller ...

I am currently building a microservices based backend for my E-Commerce Setup I need to push all the transactions to a Queue Service, but AWS documentation says that I should publish my message to ...

I am trying to set the policy of an SQS queue to allow SNS topics to send messages. I have tried following this, this and this I am using this command policy=$(getPolicy $queueArn $topicArn) echo $...

I am using boto3 to receive_message() in batches. This returns a dict item as specified in the boto3 documentation. After receiving the batch of message, I process them one by one and want to batc...

I have a AWS SQS with 5000 messages already on the Queue (Sample Message looks like this 'Hello @ 1') I created a SpringBoot Application and inside one of the Component Classes create a method to r...

I have a simple task that requires a 3rd party. When a request comes, I push it to an amazon sqs queue, pull it in a worker and call the 3rd party. In case of a time out, I want to implement an ex...

I have an AWS SQS (Standard Queue) which listens to third party SNS. I have a lambda setup which has SQS trigger with Batch size 10000 and Batch window 300. My SQS receives approx. 150 messages at ...

I've set up a small serverless app using Lambda and SQS. In my case i wanted to trigger a lambda every time a message is added to a SQS Queue. functions in my serverless.yml functions: collectG...