I have a Lambda function that has some data and must send it to a SQS queue. But it seems like the send is not working. There is no error and it seems to gracefully continue execution without any message…
I'm trying to use Celery with SQS with the below config. But I receive InvalidClientToken error. Could some one help me to resolve this? I'm using celery[sqs]==5.3.6, Kombu==5.3.7 # Celery configuration SQS_QUEUE_URL = f'https://sqs.us-east-2.amazonaws.com/{settings.aws_account}/{settings.celery_worker_queue}' result_backend = f'db+postgresql://{settings.pg_db_config.user}:{settings.pg_db_config.pwd}@{settings.pg_db_config.host}:5432/{settings.pg_db_config.db_name}' pg_db_conn_string = f"postgresql://{settings.pg_db_config.user}:{settings.pg_db_config.pwd}@{settings.pg_db_config.host}:{settings.pg_db_config.port}/{settings.pg_db_config.db_name}"…
I have many topics and queues named in the same pattern. Now I need to delete them all in bulk using some pattern with a wildcard. The AWS CLI only allows deleting one by one. Same in the AWS Console…
When creating new AWS SQS queues in an account with too many existing queues, I find that the newly created queues can't be found in either the AWS console or via the CLI list-queues command. I believe this issue is…
I have sqs queue, which has no policy defined. Queue is not owned by me, I have no idea how it is used, and I do not want to break it. I need to add permission for sending messages from…
I have integrated AWS API Gateway to SQS queue and it give response in format { "SendMessageResponse": { "ResponseMetadata": { "RequestId": "acfa1737-7d53-5aeb-8c75-482a8f8eab1b" }, "SendMessageResult": { "MD5OfMessageAttributes": null, "MD5OfMessageBody": "ed1dbe6fa17bf45a3d20ea7be2661bfb", "MD5OfMessageSystemAttributes": null, "MessageId": "e41f656e-1e2a-4269-a0e0-2016d9406ac8", "SequenceNumber": null } } } how can…
The scenario is this: When my process start I send around 3k messages to a queue in SQS. From there I have a lambda that I want to pick 500 of those messages and process them, then take the next…
I have a Lambda function that performs QLDB transactions. Because QLDB uses OCC (optimistic concurrency control), it's necessary to add a SQS Fifo in front, making sure that potential conflicting transactions (in my case: transactions attached to a specific user)…
I have a problem statement where i need to decide what TTL to set on SQS messages. I have an SQS where i get the message to copyDetail of transaction. There is no use of processing a message if txn…
I have an AWS Lambda function configured with an event source mapping from an SQS queue. I recently disabled the event source mapping using the update_event_source_mapping method with the Enabled parameter set to False. During this period of disablement, new…