4,295 questions
1
vote
2
answers
77
views
Lambda processing SQS messages Race condition in Node.js
I’m processing webhook events using AWS Lambda + SQS, and I’m running into a race condition that causes duplicate processing, even with safeguards in place. I have tried adding unique index on orderId,...
user32623614
1
vote
1
answer
23
views
How to fix "unable to verify SNS topic attributes" panic when self-hosting Encore with AWS SNS/SQS
I'm self-hosting an Encore application on AWS ECS with SNS/SQS for PubSub. The application panics on startup with the following error:
panic: unable to verify SNS topic attributes (may be missing IAM ...
- 19
Advice
0
votes
2
replies
82
views
Can SQSEvent.Records return multiple values with FIFO SQS and MessageGroupId?
The AWS documentation makes it sound like SQSEvent.Records will only ever return a single record at a time if using FIFO with MessageGroupId. Is this truly what happens? If so, I am really going to ...
- 2,440
1
vote
0
answers
72
views
SQS client not working when base endpoint is provided
When supplying base endpoint in aws config for sqs-client it is fails to get attributes or messages with 400 status code.
cfg, err := config.LoadDefaultConfig(context.TODO(),
config.WithRegion(...
- 321
1
vote
0
answers
64
views
Using Mass Transit, is there a granular way to override the headers on error messages when there is a fault?
On errors in my service (while consuming a message) Mass Transit will attempt to send the message to an '_error' queue and will fail due to an SQS hard limit on message Attributes:
MassTransit....
- 23
1
vote
1
answer
97
views
Filter aws lambda event source on metadata
I'm trying to filter based on metadata values of incoming SQS events, not what is in their body.
From the documentation, it is mentioned that there is a messageAttributes attribute. I want to filter ...
- 1,013
-4
votes
1
answer
134
views
What is the difference between a key managed by SQS vs a KMS key managed by SQS?
I'm looking into encrypting an SQS Queue that I've got using the CDK, and as options, there are
Encryption type
Description
UNENCRYPTED
Messages in the queue are not encrypted.
KMS_MANAGED
Server-side ...
- 19
0
votes
0
answers
58
views
Camel aws2 sqs warns it cannot add headers to MessageAttributes, but it shouldn't
I'm upgrading from camel-aws to camel-aws2. All in all, everything seems to be working. However, I keep getting these warnings in the logs:
WARN 23652 --- [Camel (camel-1) thread #11 - seda://to-image-...
- 1,423
Advice
0
votes
2
replies
148
views
How to retry sending a message to AWS SQS in Spring Boot, and then send it to a DLQ if all retries fail?
I am working on a Spring Boot 3.5.0 application that publishes messages to an AWS SQS FIFO queue.
My requirement is:
When sending a message to SQS:
If it fails (network error, AWS error etc.), the ...
- 49
1
vote
0
answers
66
views
Django Celery Beat SQS slow scheduling
Beat seems to be sending the messages into SQS very slowly, about 100/minute.
Every Sunday I have a sendout to about 16k users, and they're all booked for 6.30pm. Beat starts picking it up at the ...
- 11
0
votes
0
answers
89
views
Laravel + RoadRunner + SQS — API workers blocked while publishing to SQS (70ms latency per request)
I’m running a high-concurrency Laravel application on an EC2 instance using RoadRunner (12 PHP workers).
Each incoming request simply publishes a message to AWS SQS — that’s all it does.
The problem: ...
- 323
0
votes
1
answer
54
views
WSO2 MI 4.4.0 - Unable to push data to AWS SQS Queue using AWS SQS connector via proxy server
I am trying to push incoming data to AWS SQS in WSO2 MI 4.4.0 using AWS SQS connector v3.0.1.
Integration: WSO2 MI 4.4.0
Developer Tool: WSO2 MI for VS Code extension
OS: Ubuntu 22.04
Proxy server: ...
- 997
0
votes
0
answers
74
views
Why Upon failure SQS does not place the failed message upon DLQ?
I am running this worker:
php -d memory_limit=-1 bin/console messenger:consume sqs_channel_manager -vv
And worker fails:
14:29:32 INFO [messenger] Received message App\Domain\Event\ChannelManager\...
- 10.6k
0
votes
1
answer
128
views
How can I disable ssl upon sqs on localstack?
Upon a symfony app I try to use localstack for local sqs:
services:
php:
container_name: php
build:
context: ./php
args:
TIMEZONE: ${...
- 10.6k
0
votes
1
answer
102
views
SQS endpoint resolution by AWS SDK
I am configuring SQS client as shown in the below snippet:
SqsClient client = SqsClient.builder()
.region(region)
.credentialsProvider(DefaultCredentialsProvider.create(...
