SQS + лямбда-ожидание обработки всех сообщений - PullRequest
0 голосов
/ 25 января 2019

Я пытаюсь использовать SQS + Lambda для выполнения ежедневной пакетной операции.

Это может быть достигнуто с помощью следующих

  1. лямбда (запускаемая событием Cloudwatch в определенное время), отправляющая сообщения в очередь SQS. Сообщение представляет собой единицу работы, которая может обрабатываться параллельно.

  2. еще один лямбда (рабочий), запускаемый SQS, который запускает несколько одновременных выполнений для использования очереди.

У меня есть требование выполнить другое действие после того, как все сообщения будут полностью обработаны работающими Lambdas. Можно ли достичь с помощью решения выше?

(На самом деле это типичная проблема синхронизации потоков, наблюдаемая в многопоточной среде)

...