Dynamodb desencadenadores tipos de desencadenantes y todo lo que necesita saber

Los desencadenantes de DynamodB funcionan como desencadenantes en cualquier otra base de datos. La función habilita la ejecución automática de varias acciones personalizadas basada en una matriz de actualizaciones de nivel de nivel de elemento en su tabla o índice Dynamodb. Sigue siendo el método más eficiente para capturar los cambios de nivel de método o nivel de elemento en un elemento dentro de su tabla Dynamodb.

Los desencadenantes son generalmente piezas de código que ejecutan y responden automáticamente a nuevos eventos que ocurren para desencadenar una función AWS Lambda. Puede usar los desencadenantes de DynamodB para construir las aplicaciones potentes y funcionales basadas en eventos que ocurren en sus transmisiones o base de datos.

Este artículo discute los conceptos básicos de los desencadenantes de Dynamodb. Conocerá los tipos de desencadenantes de DynamodB, cómo habilitar cada tipo y algunos casos de uso.

Tipos de desencadenantes de DynamodB

Hay dos tipos de desencadenantes de DynamodB. Incluyen:

A. Transmisiones de DynamodB

Una secuencia de DynamodB es un flujo de información ordenado o programado basado en cambios asociados con los elementos en una tabla DynamodB. Cada vez que habilita una transmisión en una tabla en particular, DynamodB captura la información sobre cada cambio a un elemento de datos dentro de la tabla y almacena la información en un flujo.

Las transmisiones pueden activar la función lambda una vez que configura la función. Puede configurar sus transmisiones para activar una función Lambda utilizando los siguientes pasos:

Paso 1: Confirme si su sistema cumple con todos los requisitos previos

Primero, debe ser conversado con las operaciones básicas de AWS Lambda. También debe confirmar si su máquina tiene la última versión de AWS. El siguiente comando debe ayudar:

versión de AWS

La respuesta para el comando anterior debe tomar el siguiente formato. Tenga en cuenta que esta ilustración usa AWS SDK para Python Boto3.

AWS-Cli/2.X.x python/3.X.x Linux/4.X.X-XXX-STD Botocore/2.X.X

Nuestra respuesta es como se ilustra en lo siguiente:

Paso 2: cree una tabla DynamodB y proceda a habilitar las transmisiones en ella

Crea la tabla para la que quieres habilitar tus transmisiones. Tenga en cuenta que también puede habilitar las transmisiones en una tabla existente.

Usamos el AWS SDK para Python para crear nuestra tabla como se muestra en la siguiente línea de comando:

importar boto3
# Crear un cliente Dynamodb
Dynamodb = Boto3.Cliente ('Dynamodb')
# Crear una tabla con una clave principal 'PK' y una clave de clasificación 'SK'
table_name = 'my-table-name'
attribute_definitions = [

'AttributeName': 'PK',
'AttributeType': 's'
,

'AttributeName': 'SK',
'AttributeType': 's'
,
]
key_schema = [

'AttributeName': 'PK',
'KeyType': 'hash'
,

'AttributeName': 'SK',
'KeyType': 'rango'
,
]
provisioned_throughput =
'ReadCapacityUnits': 10,
'WriteCapacityUnits': 10

dinamodb.crear mesa(
TableName = table_name,
AttributeDefinitions = attribute_definitions,
KeySchema = key_schema,
ProvisioneDtroughput = provisioned_throughput,
StreamSpecification =
'Streamenable': verdadero,
'StreamViewType': 'new_and_old_images'

)

Paso 3: crear una función de lambda de AWS

Es hora de crear una función AWS Lambda. También debe especificar la secuencia Dynamodb como disparador. El comando python es el siguiente:

importar boto3
# Crea un cliente Lambda
lambda_client = boto3.Cliente ('Lambda')
# Configurar los detalles de la función
function_name = 'my-function'
Runtime = 'Python3.11 '
rol = 'arn: aws: iam :: x123456789012y: rol/lambda-masic-ejecución'
handler = 'función.manipulador'
# Crea la función
lambda_client.create_function (
FunctionName = function_name,
Tiempo de ejecución = tiempo de ejecución,
Rol = rol,
Manejador = controlador,
# Otras configuraciones de funciones, como variables de entorno, configuraciones de VPC, etc.
)
# Obtenga el nombre de recursos de Amazon (ARN) de la función
function_arn = lambda_client.get_function (functionName = function_name) ['Configuración'] ['Functionarn']
# Configure los detalles del activador de transmisión
stream_arn = 'Arn: AWS: Dynamodb: EU-West-1: 123456789012: Table/My-Table/Stream/2022-01-02T00: 00: 00.000 '
starting_position = 'Último'
# Agregue el disparador a la función
lambda_client.create_event_source_mapping (
Eventsourcearn = stream_arn,
FunctionName = function_arn,
InicioPosition = starting_position,
# Otras opciones de configuración, incluyendo tamaño por lotes, intentos de reintento máximo, etc.
)

El código anterior crea una nueva función lambda con el rol de nombre, tiempo de ejecución y ejecución especificados. También desencadena la función que escucha los cambios en la transmisión DynamodB especificada.

Paso 4: Habilite un acceso a los registros de Steam

Utilizar el evento Parámetro en el código anterior para acceder a sus registros de transmisión para acceder a los registros de transmisión. También necesitas usar el evento.Registros campo para acceder a los registros de transmisión individual. Cada récord tiene un dinamodb campo que contiene los datos del registro de transmisión.

Paso 5: Habilite un acceso a la nueva imagen

Proceder a habilitar un acceso a la nueva imagen a través del evento.Registros [i].dinamodb.Nueva imagen campo. Una vez hecho, configure el evento.Registros [i].dinamodb.Antigüedad Para acceder a la imagen anterior del elemento antes de cualquier cambio.

Utilizar el evento.Registros [i].nombre del evento sección para determinar el tipo de cambio que ocurrió (e.gramo., "Insertar", "modificar", "eliminar") y usar el evento.Registros [i].eventid campo para identificar de manera única cada registro de transmisión.

Paso 6: Confirme el ARN de su transmisión

Utilizar el evento.Registros [i].eventsurcearn campo para conocer el nombre de recursos de Amazon (ARN) de la transmisión habilitada.

Paso 7: procese los registros de transmisión adecuadamente

Procesar su transmisión según lo desee le permite realizar cualquier acción necesaria. Con el análisis de transmisión, puede reconocer la recepción de sus registros de transmisión devolviendo desde la función.

B. Dynamodb dispara con eventos de AWS CloudWatch

El segundo tipo de disparadores de DynamodB es usar los eventos de CloudWatch. Puede usar esta función para configurar las reglas que coincidan con los eventos seleccionados en la transmisión de eventos DynamodB. El evento CloudWatch Troggers una función AWS Lambda cada vez que una regla coincide con un evento.

El siguiente es un ejemplo de los pasos involucrados al crear una regla de eventos de CloudWatch para activar una función AWS Lambda cada vez que agrega un elemento a su tabla Dynamodb. Usamos la consola de administración de AWS.

• Configure una secuencia de DynamodB en la tabla que desea monitorear.
• Crear una función lambda que invoque el disparador.
• Cree una regla de eventos de CloudWatch con un patrón que coincida con los eventos de transmisión de DynamoDB en los que desea activar.
• Seleccione la función Lambda como el objetivo para la regla.

Ahora, cada vez que agrega, modifica o elimina un elemento, el evento correspondiente se envía a la transmisión DynamodB que desencadena la regla de eventos de CloudWatch e invoca la función Lambda.

Conclusión

Este artículo es todo lo que necesita saber sobre Dynamodb desencadenantes. Más importante aún, esperamos que pueda habilitar los desencadenantes de DyanModb en sus transmisiones directamente o usar CloudWatchEvents.