AWS DynamoDB: trabajo con secuencias

DynamoDB Streams es una función de DynamoDB que permite a los usuarios realizar un seguimiento de los cambios realizados en los datos de DynamoDB. Es un «flujo ordenado de datos» que contiene información sobre los cambios realizados en los datos de la tabla de DynamoDB. Hablemos de un caso de uso. Considere una tabla de «usuarios» en DynamoDB y su aplicación exige realizar un preprocesamiento/verificación de la información del usuario cada vez que se agrega un nuevo usuario o se modifican los datos del usuario. Puede habilitar flujos de base de datos de Dynamo para estos datos, lo que le permitirá acceder al registro de todos los cambios realizados en los datos de esta tabla casi en tiempo real.

Características de los flujos de DynamoDB

• Los datos se almacenan hasta por 24 horas. Cualquier aplicación que procese datos en DynamoDB Streams debe consumir los datos dentro de las 24 horas para evitar cualquier pérdida de datos.
• Los flujos de una tabla de DynamoDB cifrada están cifrados.

Habilitar flujos en una tabla de DynamoDB

Siga los pasos a continuación para habilitar transmisiones en la tabla de DynamoDB:

Paso 1: Abra la consola de AWS. Vaya a Panel de DynamoDB -> Elija tablas -> Seleccione la tabla existente para la que desea habilitar las transmisiones de DynamoDB. Haga clic en el botón Administrar flujos de DynamoDB como se muestra a continuación.

Paso 2: elija la opción adecuada para su caso de uso y haga clic en Habilitar.

1. Solo claves: solo los atributos clave del elemento modificado se reciben en la secuencia.
2. Nueva imagen: se recibe todo el elemento actualizado, tal como aparece después de la actualización.
3. Imagen antigua: se recibe todo el elemento actualizado, tal como aparece antes de que ocurriera la actualización.
4. Imágenes nuevas y antiguas: se reciben ambos registros del elemento actualizado, tal como aparece antes y después de que ocurriera la actualización.

Esto habilitará las transmisiones de DynamoDB que recibirán registros de todos los cambios realizados en los datos en DynamoDB. Tenga en cuenta que si realiza operaciones PUT o UPDATE en la tabla y no se modifica ningún elemento, los registros/datos de la operación no se registran en las secuencias de DynamoDB. 

Uso de datos en secuencias de DynamoDB

DynamoDB Stream Data le proporciona datos casi en tiempo real que consisten en todos los cambios realizados en la tabla de DynamoDB. Para leer y procesar una transmisión, debe crear una aplicación personalizada, que debe conectarse al extremo de DynamoDB Streams a través de requests de API. Otra forma de conectarse a las transmisiones de DynamoDB es crear un disparador de DynamoDB en AWS Lambda. Cada vez que se envían datos a flujos de DynamoDB, se invoca una función Lambda para su procesamiento.

Agregar un disparador lambda: