All Questions
Tagged with boto3 amazon-sqs
117
questions
0
votes
1
answer
187
views
moto upgrade results in error The queue should either have ContentBasedDeduplication enabled or MessageDeduplicationId provided explicitly
I upgraded moto from 4.1.x to 4.2.x and now I am hitting this error when I run my pytest unit tests.
botocore.exceptions.ClientError: An error occurred (InvalidParameterValue) when calling the ...
- 8,127
1
vote
1
answer
155
views
Error in AWS SQS Redrive from Lambda - boto3 AttributeError: SQS client object has no attribute 'start_message_move_task'
I'm trying to execute from an AWS Lambda the method to start DLQ redrive. According to documentation, boto3 version must be 1.34.44 or higher.
The lambda has 1.34.9 as boto3 version and Python version ...
- 1,562
1
vote
0
answers
96
views
Overlook AWS credentials from env and instead use IAM role attached to node_group of EKS to push msgs to SQS
Problem: I have some downstream services which needs to push msgs to sqs using my python package but boto3 uses the credentials defined in their respect env instead of using IAM role of node_group.
I ...
0
votes
0
answers
69
views
What is the use of endpoint in sns.subscribe in case of sns fan-out events
I'm working on a service that uses an SNS-SQS fanout model in Python. I understand that in order to send a notification to a specific SQS, I need to provide a filter policy. However, I'm confused ...
- 1
2
votes
1
answer
300
views
Boto3 SQS MD5OfMessageBody
How does a python/boto3 sqs client get the MD5OfMessageBody? Is this generated by the client or received by the server? For example:
{
"response": {
"MD5OfMessageBody": "...
- 173
1
vote
0
answers
115
views
serverless-offline-sqs : I get botocore.exceptions.NoCredentialsError: Unable to locate credentials
I am working on an application that uses AWS SQS. For testing functionality locally I am trying to use serverless-offline-sqs plugin however I am unable to move past the following error:
File "/...
- 11
0
votes
0
answers
874
views
Using Celery with Amazon SQS, messages are waiting in 'Messages Avaliable'
I have a problem with Celery. I am using Celery with Amazon SQS. I set up everything about Celery and SQS.
The function in tasks.py works without delay() but not working with delay().
I succesfully ...
- 59
0
votes
1
answer
1k
views
How to set max retries in SQS (dead-letter queues) on lambda timed out error?
How to delete message from DLQ when same kind of error keep repeating? for example lambda timed out after 15 minute of execution.
I've integrated SQS with lambda and attached DLQ. SO when lambda got ...
- 178
0
votes
1
answer
846
views
How can I make apply_async to accept messagegroupid parameter for sqs fifo queue
the problem I am having is that celery's apply_async is not delivering a required keyword argument, MessageGroupId, to sendmessage method of boto3 to publish message to sqs fifo queue.
I have been ...
0
votes
1
answer
1k
views
How to get receipt handle from sqs queue response, getting(TypeError 'sqs.Message' object is not subscriptable
I have one queue I'm sending some message in that and want to get receipt handle from output response.
messages = queue.receive_messages()
print(messages)
I am receiving this type of response:
[sqs....
- 45
1
vote
0
answers
663
views
AWS SQS send_messages (batch) where some deliveries fail
Suppose I want to bulk-send three messages, A, B, C, in that order, to a FIFO SQS queue. I could use the bulk SendMessageBatch call.
We provide the ordered list [A,B,C] to the API call.
Suppose that ...
- 347
0
votes
0
answers
270
views
Error while trying to set custom AWSTraceHeader when sending a SQS message
My architecture is built like this:
I have a Lambda (let's call it l1), that sends messages to a SQS, and other lambda (let's call it l2) that listen to this queue.
I am trying to set a custom ...
1
vote
1
answer
6k
views
botot3 with sqs: the address 'QueueUrl' is not valid for this endpoint
I am trying to the get queue url from a SQS queue. I have read about other posts Set the endpoint for boto3 SQS and boto3 sqs incorrect url when not specified endpoint url but it is still puzzling why ...
- 392
-1
votes
1
answer
3k
views
Trigger task on ECS Fargate based on SQS Queue
For my application, I'm trying to use ECS Fargate to run a computing task. I want ECS Fargate to be able to service a queue of requests and autoscale as needed. In other words, the backend of my app ...
- 33
3
votes
1
answer
387
views
Garbage collection is not happening properly when using boto3
I'm just running the code to listen to sqs messages in a loop for n times. After each iteration I'm calling gc.collect() but it's returning some unreachable objects and also I'm checking the gc....
- 9,051