diff --git a/sns-sqs-cdk/requirements.txt b/sns-sqs-cdk/requirements.txt index 3a672bfa6f..d803ad54a3 100644 --- a/sns-sqs-cdk/requirements.txt +++ b/sns-sqs-cdk/requirements.txt @@ -1,2 +1,2 @@ -aws-cdk-lib==2.13.0 +aws-cdk-lib==2.257.0 constructs>=10.0.0,<11.0.0 diff --git a/sns-sqs-cdk/sns_sqs_cdk/sns_sqs_cdk_stack.py b/sns-sqs-cdk/sns_sqs_cdk/sns_sqs_cdk_stack.py index 7d04e220bf..85b0f6ea12 100644 --- a/sns-sqs-cdk/sns_sqs_cdk/sns_sqs_cdk_stack.py +++ b/sns-sqs-cdk/sns_sqs_cdk/sns_sqs_cdk_stack.py @@ -1,9 +1,6 @@ from aws_cdk import ( Stack, CfnOutput, - RemovalPolicy, - Duration, - aws_iam as iam, aws_sns as sns, aws_sns_subscriptions as snssubs, aws_sqs as sqs @@ -28,16 +25,6 @@ def __init__(self, scope: Construct, construct_id: str, **kwargs) -> None: # Add the SQS subscription to the sns topic MySnsTopic.add_subscription(sqsSubscription) - # Add policy statement to SQS Policy that is created as part of the new queue - iam.PolicyStatement(actions=['SQS:SendMessage'], - effect=iam.Effect.ALLOW, - conditions={'ArnEquals': MySnsTopic.topic_arn}, - resources=[MySqsQueue.queue_arn], - principals=[ - iam.ServicePrincipal('sns.amazonaws.com') - ] - ) - CfnOutput(self, "SQS queue name", description="SQS queue name", value=MySqsQueue.queue_name) CfnOutput(self, "SQS queue ARN", description="SQS queue arn", value=MySqsQueue.queue_arn) CfnOutput(self, "SQS queue URL", description="SQS queue URL", value=MySqsQueue.queue_url)