Question

A media company processes uploaded videos. When a video is uploaded, three independent downstream systems must each receive the notification and process it separately: a transcoding service, a thumbnail generator, and an analytics logger. Each service consumes messages at a different rate and must be able to fail and retry without affecting the others. What is the most appropriate architecture to deliver each upload event to all three services?

Accepted Answer

Publish the upload event to an Amazon SNS topic and subscribe three separate Amazon SQS queues to it, with one queue consumed by each downstream service.

Answer

Send the upload event to a single Amazon SQS queue and have all three services poll the same queue for messages.

Answer

Publish the upload event directly to a Kinesis Data Stream and have each service read from the same shard iterator.

Answer

Invoke a single Lambda function synchronously that calls each of the three downstream services in sequence.