Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
Tutorial: Utilizzo AWS Lambda con flussi Amazon DynamoDB
In questo tutorial creerai una funzione Lambda per consumare eventi da un flusso Amazon DynamoDB.
Prerequisiti
Questo tutorial presuppone una certa conoscenza delle operazioni di base di Lambda e della console relativa. Se non lo si è già fatto, seguire le istruzioni riportate in Creare una funzione Lambda con la console per creare la prima funzione Lambda.
Per completare i passaggi seguenti, è necessaria l'AWS Command Line Interface (AWS CLI) versione 2. I comandi e l'output previsto sono elencati in blocchi separati:
aws --version
Verrà visualizzato l'output seguente:
aws-cli/2.13.27 Python/3.11.6 Linux/4.14.328-248.540.amzn2.x86_64 exe/x86_64.amzn.2
Per i comandi lunghi viene utilizzato un carattere di escape (\
) per dividere un comando su più righe.
In Linux e macOS utilizzare la propria shell e il proprio programma di gestione dei pacchetti preferiti.
Nota
In Windows, alcuni CLI comandi Bash che usi comunemente con Lambda (zip
come) non sono supportati dai terminali integrati del sistema operativo. Per ottenere una versione integrata su Windows di Ubuntu e Bash, installa il sottosistema Windows per Linux
Creazione del ruolo di esecuzione
Create il ruolo di esecuzione che autorizza la funzione ad accedere alle risorse. AWS
Creazione di un ruolo di esecuzione
-
Apri la pagina dei ruoli
nella IAM console. -
Scegliere Crea ruolo.
-
Creare un ruolo con le seguenti proprietà.
-
Entità attendibile – Lambda.
-
Autorizzazioni — AWSLambdaDynamoDBExecutionRole.
-
Nome ruolo –
lambda-dynamodb-role
.
-
AWSLambdaDynamoDBExecutionRoleDispone delle autorizzazioni necessarie alla funzione per leggere gli elementi da DynamoDB e scrivere i log nei log. CloudWatch
Creazione della funzione
Crea una funzione Lambda che elabori i tuoi eventi DynamoDB. Il codice della funzione scrive alcuni dei dati degli eventi in entrata in Logs. CloudWatch
Per creare la funzione
-
Copiare il codice di esempio in un file denominato
example.js
. -
Crea un pacchetto di implementazione.
zip function.zip example.js
-
Creare una funzione Lambda con il comando
create-function
.aws lambda create-function --function-name ProcessDynamoDBRecords \ --zip-file fileb://function.zip --handler example.handler --runtime nodejs18.x \ --role arn:aws:iam::
111122223333
:role/lambda-dynamodb-role
Test della funzione Lambda
In questo passaggio, si richiama manualmente la funzione Lambda utilizzando il comando e invoke
AWS Lambda CLI il seguente evento DynamoDB di esempio. Copia quanto segue in un file denominato. input.txt
Esempio input.txt
{ "Records":[ { "eventID":"1", "eventName":"INSERT", "eventVersion":"1.0", "eventSource":"aws:dynamodb", "awsRegion":"us-east-1", "dynamodb":{ "Keys":{ "Id":{ "N":"101" } }, "NewImage":{ "Message":{ "S":"New item!" }, "Id":{ "N":"101" } }, "SequenceNumber":"111", "SizeBytes":26, "StreamViewType":"NEW_AND_OLD_IMAGES" }, "eventSourceARN":"stream-ARN" }, { "eventID":"2", "eventName":"MODIFY", "eventVersion":"1.0", "eventSource":"aws:dynamodb", "awsRegion":"us-east-1", "dynamodb":{ "Keys":{ "Id":{ "N":"101" } }, "NewImage":{ "Message":{ "S":"This item has changed" }, "Id":{ "N":"101" } }, "OldImage":{ "Message":{ "S":"New item!" }, "Id":{ "N":"101" } }, "SequenceNumber":"222", "SizeBytes":59, "StreamViewType":"NEW_AND_OLD_IMAGES" }, "eventSourceARN":"stream-ARN" }, { "eventID":"3", "eventName":"REMOVE", "eventVersion":"1.0", "eventSource":"aws:dynamodb", "awsRegion":"us-east-1", "dynamodb":{ "Keys":{ "Id":{ "N":"101" } }, "OldImage":{ "Message":{ "S":"This item has changed" }, "Id":{ "N":"101" } }, "SequenceNumber":"333", "SizeBytes":38, "StreamViewType":"NEW_AND_OLD_IMAGES" }, "eventSourceARN":"stream-ARN" } ] }
Eseguire il seguente comando invoke
.
aws lambda invoke --function-name ProcessDynamoDBRecords \ --cli-binary-format raw-in-base64-out \ --payload file://input.txt outputfile.txt
L'cli-binary-formatopzione è obbligatoria se utilizzi la AWS CLI versione 2. Per rendere questa impostazione come predefinita, esegui aws configure set cli-binary-format raw-in-base64-out
. Per ulteriori informazioni, consulta la pagina AWS CLI supported global command line options nella Guida per l'utente di AWS Command Line Interface versione 2.
La funzione restituisce la stringa message
nel corpo della risposta.
Verificare l'output nel file outputfile.txt
.
Creazione di una tabella DynamoDB con un flusso abilitato
Crea una tabella Amazon DynamoDB con un flusso abilitato.
Per creare una tabella DynamoDB
-
Aprire la console DynamoDB
. -
Scegliere Create table (Crea tabella).
-
Creare una tabella con le impostazioni seguenti.
-
Table name (Nome tabella) –
lambda-dynamodb-stream
-
Primary key (Chiave primaria) –
id
(string)
-
-
Scegliere Create (Crea).
Per abilitare i flussi
-
Aprire la console DynamoDB
. -
Scegliere Tables (Tabelle).
-
Seleziona la tabella lambda-dynamodb-stream.
-
In Exports and streams (Esportazioni e flussi), scegliere DynamDB stream details (Dettagli del flusso di Dynamo DB).
-
Scegliere Turn On (Attiva).
-
Per Tipo di visualizzazione, scegli Solo attributi chiave.
-
Scegli Attiva lo streaming.
Annota lo streamARN. Questa operazione è necessaria nella fase successiva quando si associa il flusso alla funzione Lambda. Per ulteriori informazioni sull'attivazione dei flussi, consultare Acquisizione dell'attività sulla tabella tramite DynamoDB Streams.
Aggiungi una fonte di eventi in AWS Lambda
Creare una mappatura dell'origine eventi in AWS Lambda. Questa mappatura dell'origine eventi associa il flusso DynamoDB alla funzione Lambda. Dopo aver creato questa mappatura delle sorgenti degli eventi, AWS Lambda inizia il polling dello stream.
Eseguire il seguente comando AWS CLI create-event-source-mapping
. Dopo l'esecuzione del comando, annota il. UUID Ne avrai bisogno UUID per fare riferimento alla mappatura della sorgente dell'evento in qualsiasi comando, ad esempio, quando elimini la mappatura della fonte dell'evento.
aws lambda create-event-source-mapping --function-name ProcessDynamoDBRecords \ --batch-size 100 --starting-position LATEST --event-source
DynamoDB-stream-arn
Questa procedura crea una mappatura tra il flusso DynamoDB specificato e la funzione Lambda. È possibile associare un flusso DynamoDB a più funzioni Lambda e associare la stessa funzione Lambda a più flussi. Tuttavia, le funzioni Lambda condivideranno il throughput di lettura per il flusso che condividono.
Mediante l'esecuzione del comando riportato di seguito è possibile ottenere l'elenco di mappature delle origini eventi.
aws lambda list-event-source-mappings
L'elenco restituisce tutte le mappature delle origini eventi create e per ciascuna mappatura mostra, tra l'altro, il valore LastProcessingResult
. Questo campo è utilizzato per fornire un messaggio informativo nel caso in cui vengano riscontrati problemi. Valori come No records processed
(indica che non AWS Lambda è stato avviato il polling o che non ci sono record nello stream) e OK
(indica che i record dallo stream sono AWS Lambda stati letti correttamente e che è stata richiamata la funzione Lambda) indicano che non ci sono problemi. Se vengono riscontrati problemi, si riceve un messaggio di errore.
Se disponi di una grande quantità di mappature delle origini eventi, utilizza il parametro funzione-nome per restringere i risultati.
aws lambda list-event-source-mappings --function-name ProcessDynamoDBRecords
Eseguire il test della configurazione
Metti alla prova l'esperienza. end-to-end Quando vengono eseguiti gli aggiornamenti delle tabelle, DynamoDB scrive record di eventi nel flusso. Quando AWS Lambda esegue il polling del flusso, rileva nuovi record nel flusso e richiama la funzione Lambda per proprio conto passando eventi alla funzione.
-
Nella console di DynamoDB, aggiungi, aggiorna ed elimina elementi dalla tabella. DynamoDB scrive record di queste operazioni nel flusso.
-
AWS Lambda esegue il polling dello stream e, quando rileva aggiornamenti allo stream, richiama la funzione Lambda passando i dati degli eventi che trova nello stream.
-
La tua funzione viene eseguita e crea registri in Amazon CloudWatch. Puoi verificare i log riportati nella CloudWatch console Amazon.
Pulizia delle risorse
Ora è possibile eliminare le risorse create per questo tutorial, a meno che non si voglia conservarle. Eliminando AWS le risorse che non utilizzi più, eviti addebiti inutili ai tuoi. Account AWS
Per eliminare la funzione Lambda
-
Aprire la pagina Functions (Funzioni)
della console Lambda. -
Selezionare la funzione creata.
-
Scegliere Operazioni, Elimina.
-
Inserisci
delete
nel campo di immissione del testo, quindi scegli Elimina.
Come eliminare il ruolo di esecuzione
-
Apri la pagina Ruoli
della IAM console. -
Selezionare il ruolo di esecuzione creato.
-
Scegliere Elimina.
-
Inserisci il nome del ruolo nel campo di immissione testo e seleziona Delete (Elimina).
Per eliminare la tabella DynamoDB
-
Aprire la pagina Tables (Tabelle)
della console DynamoDB. -
Selezionare la tabella creata.
-
Scegliere Delete (Elimina).
-
Immettere
delete
nella casella di testo. -
Seleziona Delete Table (Elimina tabella).