Lambda: Ассинхронно, DLQ, EventBridge, S3 Events

Question 1

Какие сервисы вызывают Лямбду ассинхронно?

Answer 1

• S3
• SNS
• CloudWatch Events (EventBridge)

Question 2

Что такое вызывать ассинхронно? Как это реализовано в Лямбде?

Answer 2

Это значит, что payload попадает во внутреннюю очередь (event queue).
И Лямбда функция читает его из очереди.

Question 3

Какие фичи реализованы во внутренней Лямбда очереди, как и в SQS?

Answer 3

Как и у обычной SQS очереди, для внутренней Lambda-очереди предусмотрены механизмы “retry” и “dead letter queue”.

Question 4

Как происходит retry во внутренней Лямбда очереди? Какие там тайминги? Сколько попыток?

Answer 4

3 retry attempts

Если при чтении Event’а из внутренней Lambda-очереди произошла ошибка, то
- Через 1 минуту произойдёт вторая попытка
- Ещё через 2 минуты произойдёт третья попытка

В настройках можно выбрать только от 0 до 3-ёх попыток.

Question 5

Если 3 попытки (3 retry attempts) НЕ увенчались успехом, то
дальше …, которая будет создана …
Можно выбрать … или …

Answer 5

мы можем организовать DQL
мёртвую очередь (в отличие от сокрытой внутренней) придётся создать самостоятельно.
В качестве DQL можно выбрать SQS или SNS

Question 6

Какое есть требование к Лямбда функции, вызываемой асинхронно?

Answer 6

Лямбда функция должна быть идемпотемптна
В случае повторных попыток обработки Event’а, Лямбда функция будет обрабатывать ОДИН event НЕСКОЛЬКО раз.
Это может вызвать проблемы, если Лямбда НЕ идемпотемптна.

Question 7

Причины использовать Лямбду ассинхронно?

Answer 7

1. Некоторые сервисы по-другому НЕ умеют (S3, SNS, CloudWatch Events)
2. Возможность ускорить обработку данных (при условии, что НЕ нужно ждать ответа)

Question 8

В чём особенность ассинхронного вызова лямбда функции с точки зрения response Status’а?

Answer 8

Если Лямбда функцию удалось ассинхронно вызвать,
то response-code сразу будет 200.

Даже если в ходе выполнения Лямбда функции произошла ошибка.

Ведь при ассинхронно вызове наша цель - просто вызвать функцию.
А НЕ ждать её выполнения.

Question 9

Что такое Invocation ID? Как ещё он называется?

Answer 9

У каждого Event’а есть атрибут Request ID (он же Invoсation ID), по которому можно идентифицировать вызов Лямбда функции.

Несколько попыток обработать один и тот же Event будут иметь одинаковый Request ID (он же Invoсation ID).

Question 10

Как можно настроить запуск Лямбды по расписанию?

Answer 10

Через EventBridge Rule, типа Schedulled-Rate/CRON Jobs

Question 11

Что такое EventBridge Rule? Например?
Что такое EventBridge Destination / Target?

Answer 11

EventBridge Rule - это поведение, реакция, например отправка сообщения в SNS или запуск Lambda функции.
Каждый Rule имеет Destination: SNS, Lambda, ещё пара десятков.

Question 12

На какие 2 типа разделяются все EventBridge Rule’ы?

Answer 12

• Scheduled-Rate/Cron Jobs - каждый интервал времени
  (например, в пятницу в 9:00 или каждые 2 часа)
• Event Pattern (State Changes) - в случае обнаружения определённого Event’а (например, “IAM Root User Sign In” event)

Question 13

Чтобы EventBridge мог иметь в качестве Target’а Лямбда функцию, то …, в которой будет указаны атрибуты и значения …

Answer 13

К Лямбде должна быть прикреплена IAM Based Policy

”Resource”: “arn.lambda-foo”
будет разрешать операцию “InvokeFunction”
сервису EventBridge (”Principle”: “events.amazonaws.com”, “ArnLike”: “arn.events-rule-bar”).

Resource: “arn.lambda-foo”
Action: “Lambda:InvokeFunction” / “SNS:Publish”
Principle: Service “S3.amazonaws.com”
ConditionLike: ArnLike “arn:aws:s3:::MyBucket”

Question 14

Что такое S3 event - какие примеры?
Что может быть destination’ом для S3 event’а?

Answer 14

• S3:ObjectCreated
• S3:ObjectRemoved
• S3:ObjectRestore
• S3:Replication
• Lambda
• SQS
• SNS

Question 15

Какой тайминг доставки S3 event’ов?

Answer 15

S3 Event Notifications обычно доставляются за секунды.
Но иногда отправка S3 Event Notifications может занять около минуты.

Question 16

Когда может произойти потеря S3 event’а?
Как от неё застраховаться?

Answer 16

Если ДВЕ write-операции записи выполняются с одним S3 объектом одновременно,
то есть шанс отправки ТОЛЬКО ОДНОГО S3 Event’а.

Чтобы избежать этого и дать 100% гарантии отправки S3 Event’а для каждой write-операции, нужно включить версионирование.

Question 17

Какова единица измерения в EventBridge?

Answer 17

Bus