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à.
Creazione di una mappatura della sorgente di eventi Lambda per un'origine di eventi Amazon MSK
Per creare una mappatura delle sorgenti degli eventi, puoi utilizzare la console Lambda, la AWS Command Line Interface (CLI) o un SDK.AWS
Nota
Quando crei la mappatura dell'origine degli eventi, Lambda crea un ENI iperpiano nella sottorete privata che contiene il cluster MSK, permettendo a Lambda di stabilire una connessione sicura. Questo iperpiano consentito da ENI utilizza la configurazione della sottorete e del gruppo di sicurezza del cluster MSK, non la Lambda Event Function.
I seguenti passaggi della console aggiungono un cluster Amazon MSK come trigger per la tua Lambda Event Function. Sotto il cofano, questo crea una risorsa di mappatura delle sorgenti degli eventi.
Per aggiungere un trigger Amazon MSK alla tua Lambda Event Function (console)
-
Apri la pagina Event Functions
della console Lambda. -
Scegli il nome della Lambda Event Function a cui desideri aggiungere un trigger Amazon MSK.
-
In Panoramica delle funzioni, scegliere Aggiungi trigger.
-
In Configurazione Trigger, scegli MSK.
-
Per specificare i dettagli del cluster Kafka, procedi come segue:
-
Per MSK cluster (Cluster MSK) seleziona il cluster.
-
Per Nome argomento, inserisci il nome dell'argomento Kafka da cui consumare i messaggi.
-
Per ID del gruppo di consumatori, inserisci l'ID di un gruppo di consumatori Kafka a cui aderire, se applicabile. Per ulteriori informazioni, consulta ID del gruppo di consumatori personalizzabile in Lambda.
-
-
Per l'autenticazione del cluster, effettua le configurazioni necessarie. Per ulteriori informazioni sull’autenticazione cluster, consulta Configurazione dei metodi di autenticazione del cluster Amazon MSK in Lambda.
-
Attiva Usa autenticazione se desideri che Lambda esegua l'autenticazione con il tuo cluster MSK quando stabilisci una connessione. L'autenticazione è consigliata.
-
Se utilizzi l'autenticazione, per Metodo di autenticazione, scegli il metodo di autenticazione da utilizzare.
-
Se utilizzi l'autenticazione, per la chiave Secrets Manager, scegli la chiave Secrets Manager che contiene le credenziali di autenticazione necessarie per accedere al tuo cluster.
-
-
In Event poller configuration, effettuate le configurazioni necessarie.
-
Scegli Attiva trigger per abilitare il trigger subito dopo la creazione.
-
Scegli se desideri configurare la modalità provisioning per la mappatura delle sorgenti degli eventi. Per ulteriori informazioni, consulta Modalità di ridimensionamento del poller di eventi di Apache Kafka in Lambda.
-
Se configuri la modalità provisioned, inserisci un valore per Minimum event poller, un valore per Maximum event poller e un valore opzionale per PollerGroupName specificare il raggruppamento di più ESM all'interno dello stesso VPC di origine eventi.
-
-
Per Posizione iniziale, scegli come vuoi che Lambda inizi a leggere dal tuo stream. Per ulteriori informazioni, consulta Sondaggi di Apache Kafka e posizioni di partenza per lo streaming in Lambda.
-
-
In Batching, effettua le configurazioni necessarie. Per ulteriori informazioni sulla suddivisione in batch, vedere. Comportamento di batching
-
Per Batch Size (Dimensione batch), immettere il numero massimo di messaggi da recuperare in un singolo batch.
-
Per Batch window, inserisci il numero massimo di secondi che Lambda impiega per raccogliere i record prima di richiamare la funzione.
-
-
In Filtraggio, effettua le configurazioni necessarie. Per ulteriori informazioni sul filtro, consulta Filtraggio degli eventi da Amazon MSK e fonti di eventi Apache Kafka autogestite.
-
Per i criteri di filtro, aggiungete le definizioni dei criteri di filtro per determinare se elaborare o meno un evento.
-
-
In Gestione degli errori, effettuate le configurazioni necessarie. Per ulteriori informazioni sulla gestione degli errori, vedereAcquisizione di batch scartati per un'origine eventi di Amazon MSK e Apache Kafka autogestito.
-
Per On-failure destinazione, specificare l'ARN della destinazione in caso di errore.
-
-
Per Tag, inserisci i tag da associare a questa mappatura dell'origine degli eventi.
-
Per creare il trigger, scegli Aggiungi.
È inoltre possibile creare la mappatura dell'origine dell'evento utilizzando la AWS CLI con il comando create-event-source-mapping.my-msk-function funzione di eventi Lambda AWSKafkaTopic all'argomento, a partire dal LATEST messaggio. Questo comando utilizza l'SourceAccessConfigurationoggetto anche per indicare a Lambda di SASL/SCRAMutilizzare l'autenticazione durante la connessione al cluster.
aws lambda create-event-source-mapping \ --event-source-arn arn:aws:kafka:us-east-1:111122223333:cluster/my-cluster/fc2f5bdf-fd1b-45ad-85dd-15b4a5a6247e-2 \ --topics AWSKafkaTopic \ --starting-position LATEST \ --function-name my-kafka-function --source-access-configurations '[{"Type": "SASL_SCRAM_512_AUTH","URI": "arn:aws:secretsmanager:us-east-1:111122223333:secret:my-secret"}]'
Se il cluster utilizza l'autenticazione MTLS, includi un SourceAccessConfigurationoggetto che specifica CLIENT_CERTIFICATE_TLS_AUTH e una chiave ARN di Secrets Manager. Questo è mostrato nel seguente comando:
aws lambda create-event-source-mapping \ --event-source-arn arn:aws:kafka:us-east-1:111122223333:cluster/my-cluster/fc2f5bdf-fd1b-45ad-85dd-15b4a5a6247e-2 \ --topics AWSKafkaTopic \ --starting-position LATEST \ --function-name my-kafka-function --source-access-configurations '[{"Type": "CLIENT_CERTIFICATE_TLS_AUTH","URI": "arn:aws:secretsmanager:us-east-1:111122223333:secret:my-secret"}]'
Quando il cluster utilizza l'autenticazione IAM, non è necessario un SourceAccessConfigurationoggetto. Questo è mostrato nel seguente comando:
aws lambda create-event-source-mapping \ --event-source-arn arn:aws:kafka:us-east-1:111122223333:cluster/my-cluster/fc2f5bdf-fd1b-45ad-85dd-15b4a5a6247e-2 \ --topics AWSKafkaTopic \ --starting-position LATEST \ --function-name my-kafka-function
