Крючки для потоков AWS DynamoDB

Question

AWS DynamoDB предоставляет streams, что помогает в захвате активности таблицы. Насколько я понимаю, поток захватывающих изменений во сне - это Stream ARN -> Shards -> shardIterator -> Records. Чтобы приложение отслеживало изменения в таблице Dynamo, оно должно продолжать выполнять вышеуказанный цикл. Мне было интересно, можно ли упростить этот поток с помощью перехватчиков, которые могут отслеживать эти изменения и триггер, которые мое приложение может прослушивать. Я знаю, что есть интеграция AWMS Lambda, которая может выполнять вышеупомянутый цикл и предупреждение, но мне было интересно, может ли приложение прослушивать сигналы тревоги лямбда AWS.

Пакет npm dynamodb-stream делает это проще чтобы использовать эти изменения, но механизм опроса, по-видимому, не является наиболее эффективным, если все операции с таблицей должны быть зафиксированы как можно быстрее.

Answer 1

Я не уверен, какова цель этого пакета npm, вы может просто использовать событие, вызванное Lambda с потоками DynamoDB. В основном, Lambda-сервис (а не ваш ягненок) будет опросить Stream для изменений и выполнить вашего ягненка, когда он их найдет. Гораздо чище, чем использовать какую-то смешную бессмысленную таймер. Here are the docs on it.

Amazon DynamoDB интегрируется с AWS Lambda, так что вы можете создать триггеры-фрагменты кода, которые автоматически реагируют на события в DynamoDB Streams. С помощью триггеров вы можете создавать приложения, которые реагируют на изменения данных в таблицах DynamoDB.

Если вы включили потоки DynamoDB в таблице, вы можете связать ARN потока с функцией Lambda, которую вы пишете. Сразу после изменения элемента в таблице новая запись появляется в потоке таблицы. AWS Lambda проверяет поток и синхронно вызывает вашу функцию Lambda при обнаружении новых записей потока.