Я бы посоветовал вам иметь одну лямбда-функцию, которая будет запускаться на основе любых сообщений SQS, которые вы получите. Затем вы можете обработать сообщение и использовать содержимое в своем сценарии использования, который вы упомянули. По сути, вы получите событие SQS от вашей лямбда-функции, как только триггер будет активирован. Вам нужно захватить это событие и процесс:
SNS / DynamoDB / другой запрос SQS
Но убедитесь, что у вас есть механизм удаления SQS сообщение, как только вы обработали его, чтобы вы не продолжали читать или опрашивать старые сообщения SQS повторно. Вы можете прочитать о DLQ (Dead-Letter-Queue), что может быть полезно. Для справки, взгляните на this , чтобы вы могли начать самостоятельно.