aws-cdk: I cannot add access permission to existing SQS

I have a code where I need to grant send messages to an existing sqs queue. I have this code in the aws-cdk. But this is not working. No access permission get added. const sqsQ =...

aws-cdk aws-cli cloudformation generating extra characters in arn

I am using the aws-cdk to create cloudformation templates, really just SNS and SQS. My problem is that the names of the generated Topics and Queues are not what I see in the yaml file. Here is the...

How to solve circular dependency between AWS resources using AWS CDK

I am creating S3, SQS, and KMS resources using aws cdk. I enabled encryption on the S3 and SQS resources. When I enabled the notification from S3 to SQS, I am getting a circular dependency error....

Handle errors with AWS CDK Python

I am trying to set-up SQS queues with AWS CDK in Python. I would like to wrap the statements in try...except block. The documentation does not explain what errors are raised. How does one handle...

Insufficients3bucketpolicyexception with aws-cdk

So I am trying to create a solution that creates an s3 bucket that allows cloudtrail to log to it. I am getting the error as follows: Incorrect S3 bucket policy is detected for bucket:...

AWS CDK sns Delivery status logging

I have a scenario where I publish a message in a SNS topic and this message then is sent to SQS queue. What I want is to have logs in SNS everytime a message is sent to a subscriber (like my sqs...

aws sqs messages consistently disappear

Got 3 SQS queues and 3 lambdas. Lambda1 sends 50 messages to queue1, lambda2 picks up a message from queue1 and sends to queue2, lambda3 picks up off queue2 and relays to queue3. Queues defined...

AWS ECS Fargate task parallelization with SQS

I have an SQS FIFO Queue in which I'm sending messages every time I want to process data. I sent batches of data 1-2 times a day and I want to process them with ECS Fargate all together because...

SQS Interface Endpoint in CDK

Working with AWS-CDK. I had to move my Lambda that writes to SQS inside a VPC. I added the Interface Gateway to allow for direct connection from VPC to SQS...

AWS CDK apply path to lambda role created

I'm using AWS CDK (node js) to create a lambda function. Below is the definition of my function: const receiverFunction = new lambda.Function(this, "Receiver", { description:...

Adding SQS as eventSource to Lambda in CDK

I am writing CDK app to deploy aws infra using Python. CDK generates a cft template that deploy infra inside aws account. Now, I want to configure a SQS generated from CDK to be an event source...

Subscribe a sqs queue to a sns topic that is in a different account, using aws cdk(typescript)

I would like to connect an sqs queue to an sns topic that is in a different account, using cdk (typescript). Below is the code (this code is in a stack) that I think should work but I have some...

Lambda function fails to instantiate when using AWS CDK

I'm trying to use the AWS CDK to deploy a Lambda function that will be triggered by an S3 upload event. When I try doing cdk ls or cdk synth, I get the error: Traceback (most recent call last): ...

Argument of type 'this' is not assignable to parameter of type 'Construct' in AWS CDK

I am having an issue while using the CDK in that the this property is erroring and saying that I can't assign 'this' to parameter of type construct. This is happens start on the const...

How to subscribe an SQS queue to an SNS topic with aws cdk?

I first create a queue: const notificationQueue: sqs.IQueue = new sqs.Queue(this, `${domain}-notificationsQueue`, { queueName: `${domain}-notificationsQueue.fifo`, fifo: true, ...

How do I create an SNS subscription filter involving two attributes using the AWS CDK in Python?

I am setting up our AWS infrastructure using CDK in Python. I want to subscribe an sqs queue to an SNS topic using a filter when the id is in a range and the type is one of two types. The filter...

How to integrate API Gateway with s3 in CDK

The docs are very clear in doing this in the console, https://docs.aws.amazon.com/apigateway/latest/developerguide/integrating-api-with-aws-services-s3.html, but replicating in CDK is really...

Create Elastic Beanstalk Worker Auto Scaling infrastructure based on SQS queue size

I am using infrastructure as code to organize my cloud services and I am trying to reproduce with AWS CDK the CloudFormation template necessary to create resources to auto scale my Elastic...

Is it normal that SQS takes around 10s to process an incoming message and can it be made faster?

The setup is pretty simple: one backend service (e.g. Java) one lambda (e.g. JavaScript) one SQS backend service sends a message to SQS -> SQS triggers lambda -> lambda code is executed I added...

Deploying Lambda Function with CDK Failing Due to Missing Parameters

new Function(this, "TestFunction", { handler: "TestFunction.handler", code: Code.asset(path.join(__dirname, "lambdas/")), runtime:...

AWS Step Functions SendSQSMessage: Dynamic MessageGroupId

I am using the AWS CDK to create a state machine that sends a message to a fifo queue and waits for a callback from the lambda worker to continue execution. I would like the messages that get sent...

SQS messages idle in queue for up to 99seconds until readMessage picks it up

I have an ETL process that converts files from s3. S3 event notification sends a message to SQS and a fargate task polls the queue for the message. My problem is that the message doesn't get...

Send message to encrypted SQS queue from Lambda

I have a AWS Lambda function that needs to send messages to an encrypted SQS queue. At one point I got it working that my AWS Lambda function could send messages to this encrypted SQS queue. After...

SQS Receive Missing Messages from the Queue

I have AWS infrastructure set up so that every update to a dynamo db entry ends up in SQS FIFO queue with deduplication enabled. I also have a test covering this scenario where I purge the queue...

High Latency in ECS Fargate service

We are using a Fargate cluster to evaluate a POC and move our existing service over to ECS Fargate compute. We have 2 tasks reading from a SQS queue and processing requests. We were having...

Argument of type 'this' not assignable to parameter 'Construct'

I am trying to call a lambda function into a 'sample app' stack and it is giving me an error because I am trying to pass it a parameter of 'this'. Here is my lambda function `` export async...