@@ -50,7 +50,7 @@ def __init__(self, scope: Construct, construct_id: str, **kwargs) -> None:
5050 time_to_live_attribute = "ttl"
5151 )
5252
53- # create a lambda function to process messages from the queue
53+ # create a Lambda function to process messages from the queue
5454 process_queue_function = lambda_ .Function (self , "ProcessMessageLambda" ,
5555 runtime = lambda_ .Runtime .PYTHON_3_9 ,
5656 code = lambda_ .Code .from_asset ("lambda" ),
@@ -86,13 +86,13 @@ def __init__(self, scope: Construct, construct_id: str, **kwargs) -> None:
8686 )
8787
8888
89- # create lambda execution role that has access to receive messages from primary_queue queue
89+ # create Lambda execution role that has access to receive messages from primary_queue queue
9090 process_queue_function .add_to_role_policy (iam .PolicyStatement (
9191 actions = ["sqs:ReceiveMessage" , "sqs:DeleteMessage" , "sqs:GetQueueAttributes" , "sqs:GetQueueUrl" ],
9292 resources = [primary_queue .queue_arn ]
9393 ))
9494
95- # add to lambda execution role policy to send messages to the downstream_queue queue
95+ # add to Lambda execution role policy to send messages to the downstream_queue queue
9696 process_queue_function .add_to_role_policy (iam .PolicyStatement (
9797 actions = ["sqs:SendMessage" ],
9898 resources = [downstream_queue .queue_arn ]
@@ -105,7 +105,7 @@ def __init__(self, scope: Construct, construct_id: str, **kwargs) -> None:
105105 report_batch_item_failures = True
106106 )
107107
108- # give permissions for the lambda function to read and write to the dynamodb table
108+ # give permissions for the function to read and write to the dynamodb table
109109 customer_table .grant_read_write_data (process_queue_function )
110110
111- cfnoutput (self , "DelayFifoQueueURL" , value = primary_queue .queue_url )
111+ cfnoutput (self , "DelayFifoQueueURL" , value = primary_queue .queue_url )
0 commit comments