У нас есть функция AWS Lambda Subscriber (в Python 3.6), которая читает сообщения из Amazon MQ с помощью STOMP.
Для каждого полученного сообщения подписчик Lambda вызывает рабочую лямбду (в Python 3.6), которая отправляет сообщение в Kinesis с использованием другой учетной записи AWS.
Если в Amazon MQ есть 800 сообщений, подписчик считывает все 800 и также вызывает рабочую лямбду.Но мы видим, что вызывается более 800 рабочих лямбда, и в Kinesis есть дубликаты.
Подписчик Lambda вызывает рабочий лямбда синхронно, что означает, что даже если по какой-либо причине рабочий лямбда выходит из строя, он не будет повторяться самостоятельно,Не уверен, почему в нашем случае есть дубликаты.Любая помощь по этому вопросу будет принята с благодарностью.
Спасибо.Venkat