Tutorial: Utilizzo AWS Lambda con Amazon DocumentDB Streams

Apri la AWS Cloud9 console e scegli Crea ambiente.

Crea un ambiente con la seguente configurazione:

Scegli Create (Crea) . Il provisioning del nuovo AWS Cloud9 ambiente può richiedere diversi minuti.

Apri la EC2console. In Rete e sicurezza, scegli Gruppi di sicurezza.

Scegliere Create Security Group (Crea gruppo di sicurezza).

Crea un gruppo di sicurezza con la seguente configurazione:

Scegliere Create Security Group (Crea gruppo di sicurezza).

Apri la console Amazon DocumentDB. In Cluster, scegli Crea.

Crea un cluster con la seguente configurazione:

Scegli Create cluster (Crea cluster). Il provisioning del cluster Amazon DocumentDB può richiedere diversi minuti.

Apri la console Gestione dei segreti e scegli Archivia un nuovo segreto.

In Scegli il tipo di segreto, scegli una delle seguenti opzioni:

Per Configura segreto, scegli tra le seguenti opzioni:

Scegli Next (Successivo).

Scegli Store.

Aggiorna la console per verificare di aver archiviato correttamente il segreto DocumentDBSecret.

Apri la AWS Cloud9 console. Accanto all'DocumentDBCloud9Environmentambiente che hai creato in precedenza, fai clic sul link Apri sotto la AWS Cloud9 IDEcolonna.

In una finestra del terminale, crea il file di repository MongoDB con il comando seguente:

echo -e "[mongodb-org-5.0] \nname=MongoDB Repository\nbaseurl=https://repo.mongodb.org/yum/amazon/2/mongodb-org/5.0/x86_64/\ngpgcheck=1 \nenabled=1 \ngpgkey=https://www.mongodb.org/static/pgp/server-5.0.asc" | sudo tee /etc/yum.repos.d/mongodb-org-5.0.repo

Quindi, installa la shell mongo con il comando seguente:

sudo yum install -y mongodb-org-shell

Per crittografare i dati in transito, scarica la chiave pubblica per Amazon DocumentDB. Il comando seguente scarica un file denominato global-bundle.pem:

wget https://truststore.pki.rds.amazonaws.com/global/global-bundle.pem

Apri la console Amazon DocumentDB. In Cluster, scegli il cluster selezionando il relativo identificatore.

Nella scheda Connettività e sicurezza, in Connetti a questo cluster con la shell mongo, scegli Copia.

Nel tuo AWS Cloud9 ambiente, incolla questo comando nel terminale. Sostituisci <insertYourPassword> con la password corretta.

Nel tuo AWS Cloud9 ambiente, assicurati di essere ancora connesso al cluster Amazon DocumentDB.

In una finestra del terminale, utilizza il comando seguente per creare un nuovo database denominato docdbdemo:

use docdbdemo

Quindi, utilizza il comando seguente per inserire un record in docdbdemo:

db.products.insert({"hello":"world"})

L'output visualizzato dovrebbe essere di questo tipo:

WriteResult({ "nInserted" : 1 })

Utilizza il seguente comando per elencare tutti i database:

show dbs

Assicurati che l'output contenga il database docdbdemo:

docdbdemo  0.000GB

Apri la VPCconsole. Nel menu a sinistra, in Cloud privato virtuale, scegli Endpoint.

Seleziona Crea endpoint. Crea un endpoint con la seguente configurazione:

Seleziona di nuovo Crea endpoint. Crea un endpoint con la seguente configurazione:

Apri la pagina Politiche nella IAM console e scegli Crea policy.

Scegli la JSONscheda. Nella seguente politica, sostituisci la risorsa Secrets Manager ARN nella riga finale dell'istruzione con il tuo segreto ARN di prima e copia la politica nell'editor.

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Sid": "LambdaESMNetworkingAccess",
            "Effect": "Allow",
            "Action": [
                "ec2:CreateNetworkInterface",
                "ec2:DescribeNetworkInterfaces",
                "ec2:DescribeVpcs",
                "ec2:DeleteNetworkInterface",
                "ec2:DescribeSubnets",
                "ec2:DescribeSecurityGroups",
                "kms:Decrypt"
            ],
            "Resource": "*"
        },
        {
            "Sid": "LambdaDocDBESMAccess",
            "Effect": "Allow",
            "Action": [
                "rds:DescribeDBClusters",
                "rds:DescribeDBClusterParameters",
                "rds:DescribeDBSubnetGroups"
            ],
            "Resource": "*"
        },
        {
            "Sid": "LambdaDocDBESMGetSecretValueAccess",
            "Effect": "Allow",
            "Action": [
                "secretsmanager:GetSecretValue"
            ],
            "Resource": "arn:aws:secretsmanager:us-east-1:123456789012:secret:DocumentDBSecret"
        }
    ]
}

Scegli Successivo: Tag, quindi Successivo: Verifica.

In Nome, inserisci AWSDocumentDBLambdaPolicy.

Scegli Create Policy (Crea policy).

Apri la pagina Ruoli nella IAM console e scegli Crea ruolo.

Per Seleziona un'entità attendibile, scegli le seguenti opzioni:

Per Aggiungi autorizzazioni, scegli la AWSDocumentDBLambdaPolicy policy che hai appena creato e AWSLambdaBasicExecutionRole autorizza la funzione a scrivere su Amazon CloudWatch Logs.

Scegli Next (Successivo).

Per Nome ruolo, inserisci AWSDocumentDBLambdaExecutionRole.

Scegliere Crea ruolo.

Copiare il codice di esempio in un file denominato index.js.

Crea un pacchetto di implementazione utilizzando il seguente comando.

zip function.zip index.js

Usa il seguente CLI comando per creare la funzione. Sostituisci us-east-1 Regione AWS con e 123456789012 con l'ID del tuo account.

aws lambda create-function \
  --function-name ProcessDocumentDBRecords \
  --zip-file fileb://function.zip --handler index.handler --runtime nodejs20.x \
  --region us-east-1 \
  --role arn:aws:iam::123456789012:role/AWSDocumentDBLambdaExecutionRole

Apri la pagina Funzioni della console Lambda.

Scegli la funzione ProcessDocumentDBRecords creata in precedenza.

Scegli la scheda Configurazione, quindi scegli Triggers nel menu a sinistra.

Selezionare Add trigger (Aggiungi trigger).

In Configurazione Trigger, come sorgente, seleziona Amazon DocumentDB.

Crea la mappatura dell'origine degli eventi con la seguente configurazione:

Scegli Aggiungi. La creazione della mappatura dell'origine degli eventi può richiedere alcuni minuti.

Apri la pagina Funzioni della console Lambda.

Scegli la scheda Monitor, quindi scegli Visualizza registri. CloudWatch Questo ti porta al gruppo di log specifico associato alla tua funzione nella CloudWatch console.

Scegli il flusso di log più recente. All'interno dei messaggi di registro, dovresti vedere l'eventoJSON.

Riconnettiti al cluster Amazon DocumentDB nel AWS Cloud9 tuo ambiente.

Utilizza questo comando per verificare che stai attualmente utilizzando il database docdbdemo:

use docdbdemo

Inserisci un record nella raccolta products del database docdbdemo:

db.products.insert({"name":"Pencil", "price": 1.00})

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.

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 Elimina.

Apri la VPCconsole. Nel menu a sinistra, in Cloud privato virtuale, scegli Endpoint.

Seleziona gli endpoint creati.

Scegli Azioni, Elimina VPC endpoint.

Inserisci delete nel campo di immissione del testo.

Scegli Elimina.

Apri la console Amazon DocumentDB.

Scegli il cluster Amazon DocumentDB che hai creato per questo tutorial e disabilita la protezione da eliminazione.

Nella pagina principale Clusters, scegli nuovamente il tuo cluster Amazon DocumentDB.

Scegli Operazioni > Elimina.

Per Crea snapshot finale del cluster, seleziona No.

Inserisci delete nel campo di immissione del testo.

Scegli Elimina.

Apri la console Secrets Manager.

Scegli il segreto creato per questo tutorial.

Scegli Operazioni, Elimina segreto.

Scegliere Schedule deletion (Pianifica eliminazione).

Apri la EC2console. In Rete e sicurezza, scegli Gruppi di sicurezza.

Seleziona il gruppo di sicurezza creato per questo tutorial.

Scegli Operazioni, Elimina gruppi di sicurezza.

Scegli Elimina.

Apri la AWS Cloud9 console.

Seleziona l'ambiente creato per questo tutorial.

Scegli Elimina.

Inserisci delete nel campo di immissione del testo.

Scegli Delete (Elimina).