diff --git a/application-code/container-queue-proc/src/app.py b/application-code/container-queue-proc/src/app.py index 94e86cc1..d2191559 100644 --- a/application-code/container-queue-proc/src/app.py +++ b/application-code/container-queue-proc/src/app.py @@ -115,10 +115,11 @@ def resize_image(image_path, resized_path): def usage_demo(): """ Shows how to: - * Read the lines from this Python file and send the lines in - batches of 10 as messages to a queue. - * Receive the messages in batches until the queue is empty. - * Reassemble the lines of the file and verify they match the original file. + * Retrieve object metadata from the SQS queue that holds notifications from the source S3 bucket. + * Download each image from the source S3 bucket. + * Resize each image into a standard 224x224 format. + * Upload each resized image to the destination S3 bucket. + * Repeat until the SQS queue is empty. """ def unpack_message(msg): diff --git a/terraform/fargate-examples/queue-processing/README.md b/terraform/fargate-examples/queue-processing/README.md index 6b157d97..72c9d1a0 100644 --- a/terraform/fargate-examples/queue-processing/README.md +++ b/terraform/fargate-examples/queue-processing/README.md @@ -27,7 +27,7 @@ terraform apply -auto-approve ```bash aws s3 cp . s3://ecsdemo-queue-proc-source-xx-xxx-xxx-xx/ecsproc --recursive ``` -* Check the SQS queue for the notificatiosn from the S3 bucket file upload, check CloudWatch Container Insights to see the task count increase from the Lambda run_task invocation, and check destination S3 bucket for resizes images. +* Check the SQS queue for the notifications from the S3 bucket file upload, check CloudWatch Container Insights to see the task count increase from the Lambda run_task invocation, and check destination S3 bucket for resizes images. ## Blueprint Architecture