Skip to content

Lab3: Use return address #40

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Lab3: Use return address #40

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 4 additions & 2 deletions code/lab-3/generic-unicorn-management-service/app.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@
import time

SERVICE_NAME = os.environ['SERVICE_NAME']
QUEUE_URL = os.environ['QUEUE_URL']

config = Config(connect_timeout=5, read_timeout=5, retries={'max_attempts': 1})
sqs = boto3.client('sqs', config=config)
Expand All @@ -32,8 +31,11 @@ def lambda_handler(event, context):
'quote': random.randint(0,100)
})

# extract return address from the payload
responseQueueUrl = message['response-queue-url']

response = sqs.send_message(
QueueUrl = QUEUE_URL,
QueueUrl = responseQueueUrl,
MessageBody = response_message
)

Expand Down
2 changes: 2 additions & 0 deletions code/lab-3/request-for-quotes-service/app.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@

TABLE_NAME = os.environ['TABLE_NAME']
TOPIC_ARN = os.environ['TOPIC_ARN']
RESPONSE_QUEUE_URL = os.environ['RESPONSE_QUEUE_URL']

config = Config(connect_timeout=5, read_timeout=5, retries={'max_attempts': 1})
dynamodb = boto3.client('dynamodb', config=config)
Expand All @@ -29,6 +30,7 @@ def lambda_handler(event, context):

rfq_id = str(uuid.uuid4())
request['rfq-id'] = rfq_id
request['response-queue-url'] = RESPONSE_QUEUE_URL

response = dynamodb.put_item(
TableName = TABLE_NAME,
Expand Down
31 changes: 11 additions & 20 deletions code/lab-3/template.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@ Resources:
Variables:
TABLE_NAME: !Ref RidesBookingTable
TOPIC_ARN: !Ref RequestForQuotesTopic
RESPONSE_QUEUE_URL: !Ref RequestForQuotesResponseQueue
Policies:
- DynamoDBCrudPolicy: # https://github.com/awslabs/serverless-application-model/blob/develop/samtranslator/policy_templates_data/policy_templates.json
TableName:
Expand Down Expand Up @@ -90,12 +91,11 @@ Resources:
Environment:
Variables:
SERVICE_NAME: UnicornManagementResource1
QUEUE_URL: !Ref RequestForQuotesResponseQueue
Policies:
- AWSLambdaExecute
- SQSSendMessagePolicy: # https://github.com/awslabs/serverless-application-model/blob/develop/samtranslator/policy_templates_data/policy_templates.json
QueueName:
!GetAtt RequestForQuotesResponseQueue.QueueName
'*-RequestForQuotesResponseQueue-*'
Events:
SqsJobQueue:
Type: SNS
Expand All @@ -109,12 +109,11 @@ Resources:
Environment:
Variables:
SERVICE_NAME: UnicornManagementResource2
QUEUE_URL: !Ref RequestForQuotesResponseQueue
Policies:
- AWSLambdaExecute
- SQSSendMessagePolicy: # https://github.com/awslabs/serverless-application-model/blob/develop/samtranslator/policy_templates_data/policy_templates.json
QueueName:
!GetAtt RequestForQuotesResponseQueue.QueueName
'*-RequestForQuotesResponseQueue-*'
Events:
SqsJobQueue:
Type: SNS
Expand All @@ -128,12 +127,11 @@ Resources:
Environment:
Variables:
SERVICE_NAME: UnicornManagementResource3
QUEUE_URL: !Ref RequestForQuotesResponseQueue
Policies:
- AWSLambdaExecute
- SQSSendMessagePolicy: # https://github.com/awslabs/serverless-application-model/blob/develop/samtranslator/policy_templates_data/policy_templates.json
QueueName:
!GetAtt RequestForQuotesResponseQueue.QueueName
'*-RequestForQuotesResponseQueue-*'
Events:
SqsJobQueue:
Type: SNS
Expand All @@ -147,12 +145,11 @@ Resources:
Environment:
Variables:
SERVICE_NAME: UnicornManagementResource4
QUEUE_URL: !Ref RequestForQuotesResponseQueue
Policies:
- AWSLambdaExecute
- SQSSendMessagePolicy: # https://github.com/awslabs/serverless-application-model/blob/develop/samtranslator/policy_templates_data/policy_templates.json
QueueName:
!GetAtt RequestForQuotesResponseQueue.QueueName
'*-RequestForQuotesResponseQueue-*'
Events:
SqsJobQueue:
Type: SNS
Expand All @@ -166,12 +163,11 @@ Resources:
Environment:
Variables:
SERVICE_NAME: UnicornManagementResource5
QUEUE_URL: !Ref RequestForQuotesResponseQueue
Policies:
- AWSLambdaExecute
- SQSSendMessagePolicy: # https://github.com/awslabs/serverless-application-model/blob/develop/samtranslator/policy_templates_data/policy_templates.json
QueueName:
!GetAtt RequestForQuotesResponseQueue.QueueName
'*-RequestForQuotesResponseQueue-*'
Events:
SqsJobQueue:
Type: SNS
Expand All @@ -185,12 +181,11 @@ Resources:
Environment:
Variables:
SERVICE_NAME: UnicornManagementResource6
QUEUE_URL: !Ref RequestForQuotesResponseQueue
Policies:
- AWSLambdaExecute
- SQSSendMessagePolicy: # https://github.com/awslabs/serverless-application-model/blob/develop/samtranslator/policy_templates_data/policy_templates.json
QueueName:
!GetAtt RequestForQuotesResponseQueue.QueueName
'*-RequestForQuotesResponseQueue-*'
Events:
SqsJobQueue:
Type: SNS
Expand All @@ -204,12 +199,11 @@ Resources:
Environment:
Variables:
SERVICE_NAME: UnicornManagementResource7
QUEUE_URL: !Ref RequestForQuotesResponseQueue
Policies:
- AWSLambdaExecute
- SQSSendMessagePolicy: # https://github.com/awslabs/serverless-application-model/blob/develop/samtranslator/policy_templates_data/policy_templates.json
QueueName:
!GetAtt RequestForQuotesResponseQueue.QueueName
'*-RequestForQuotesResponseQueue-*'
Events:
SqsJobQueue:
Type: SNS
Expand All @@ -223,12 +217,11 @@ Resources:
Environment:
Variables:
SERVICE_NAME: UnicornManagementResource8
QUEUE_URL: !Ref RequestForQuotesResponseQueue
Policies:
- AWSLambdaExecute
- SQSSendMessagePolicy: # https://github.com/awslabs/serverless-application-model/blob/develop/samtranslator/policy_templates_data/policy_templates.json
QueueName:
!GetAtt RequestForQuotesResponseQueue.QueueName
'*-RequestForQuotesResponseQueue-*'
Events:
SqsJobQueue:
Type: SNS
Expand All @@ -242,12 +235,11 @@ Resources:
Environment:
Variables:
SERVICE_NAME: UnicornManagementResource9
QUEUE_URL: !Ref RequestForQuotesResponseQueue
Policies:
- AWSLambdaExecute
- SQSSendMessagePolicy: # https://github.com/awslabs/serverless-application-model/blob/develop/samtranslator/policy_templates_data/policy_templates.json
QueueName:
!GetAtt RequestForQuotesResponseQueue.QueueName
'*-RequestForQuotesResponseQueue-*'
Events:
SqsJobQueue:
Type: SNS
Expand All @@ -261,12 +253,11 @@ Resources:
Environment:
Variables:
SERVICE_NAME: UnicornManagementResource10
QUEUE_URL: !Ref RequestForQuotesResponseQueue
Policies:
- AWSLambdaExecute
- SQSSendMessagePolicy: # https://github.com/awslabs/serverless-application-model/blob/develop/samtranslator/policy_templates_data/policy_templates.json
QueueName:
!GetAtt RequestForQuotesResponseQueue.QueueName
'*-RequestForQuotesResponseQueue-*'
Events:
SqsJobQueue:
Type: SNS
Expand Down