Могу ли я написать в SQS + Lambda логику распределенной обработки внутреннего опросчика Lambda, который считывает сообщения из SQS?
В настоящее время я использую архитектуру триггера SQS(fifo) + Lambda. Каждый раз, когда сообщение отправляется в SQS, функция Lambda создается и обрабатывается внутренним опросчиком.
Это совершенно нормальная, типичная логика обработки SQS + Lambda. Но я хочу ограничить максимальное количество лямбд, создаваемых в секунду. Независимо от того, как сотни тысяч сообщений доставляются в SQS, внутренний опросчик Lambda ограничивает скорость этих сообщений для создания функции Lambda, и я хочу написать эту логику ограничения скорости самостоятельно.
Является ли это возможным? Если возможно, я был бы признателен, если бы вы могли оставить любые сопутствующие материалы! Кроме того, если у вас есть лучшая рекомендованная архитектура, чем SQS + Lambda , поделитесь, пожалуйста!
1 ответ
Но я хочу ограничить максимальное количество лямбд, создаваемых в секунду.
Вы делаете это, устанавливая предел параллелизма вашей лямбды. Если вам нужна только одна функция, установите для нее значение 1.
и я хочу сам написать эту логику ограничения скорости.
Вы не можете изменить внутреннюю логику пула лямбда-выражений SQS.