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à.
MSK
L'oggetto che descrive un tipo di origine MSK
dell'evento. Per ulteriori informazioni, consulta Using AWS Lambda with Amazon MSK nella AWS Lambda Developer Guide.
AWS Serverless Application Model (AWS SAM) genera una AWS::Lambda::EventSourceMappingrisorsa quando viene impostato questo tipo di evento.
Sintassi
Per dichiarare questa entità nel tuo AWS SAM modello, usa la seguente sintassi.
YAML
ConsumerGroupId:
String
DestinationConfig:DestinationConfig
FilterCriteria:FilterCriteria
MaximumBatchingWindowInSeconds:Integer
SourceAccessConfigurations:SourceAccessConfigurations
StartingPosition:String
StartingPositionTimestamp:Double
Stream:String
Topics:List
Proprietà
-
ConsumerGroupId
-
Una stringa che configura il modo in cui gli eventi verranno letti dagli argomenti di Kafka.
▬Tipo: stringa
Required: No
AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla
AmazonManagedKafkaConfiguration
proprietà di una risorsa.AWS::Lambda::EventSourceMapping
-
DestinationConfig
-
Oggetto di configurazione che specifica la destinazione di un evento dopo che Lambda lo elabora.
Utilizza questa proprietà per specificare la destinazione delle chiamate non riuscite dall'origine dell'evento Amazon MSK.
Tipo: DestinationConfig
Required: No
AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla
DestinationConfig
proprietà di unaAWS::Lambda::EventSourceMapping
risorsa. -
FilterCriteria
-
Un oggetto che definisce i criteri che determinano se Lambda deve elaborare un evento. Per ulteriori informazioni, consulta il filtro AWS Lambda degli eventi nella Guida per gli AWS Lambda sviluppatori.
Tipo: FilterCriteria
Required: No
AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla
FilterCriteria
proprietà di unaAWS::Lambda::EventSourceMapping
risorsa. -
MaximumBatchingWindowInSeconds
-
Il tempo massimo in secondi per la raccolta dei record prima di richiamare la funzione.
Tipo: integer
Required: No
AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla
MaximumBatchingWindowInSeconds
proprietà di unaAWS::Lambda::EventSourceMapping
risorsa. -
SourceAccessConfigurations
-
Un array del protocollo di autenticazione, dei componenti VPC o dell'host virtuale per proteggere e definire l'origine eventi.
Valori validi:
CLIENT_CERTIFICATE_TLS_AUTH
Tipo: elenco di SourceAccessConfiguration
Required: No
AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla
SourceAccessConfigurations
proprietà di unaAWS::Lambda::EventSourceMapping
risorsa. -
StartingPosition
-
La posizione in un flusso da cui iniziare la lettura.
-
AT_TIMESTAMP
— Specificare l'ora a partire dalla quale iniziare a leggere i record. -
LATEST
— Leggi solo i nuovi record. -
TRIM_HORIZON
— Elabora tutti i record disponibili.
Valori validi:
AT_TIMESTAMP
|LATEST
|TRIM_HORIZON
▬Tipo: stringa
Required: No
AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla
StartingPosition
proprietà di unaAWS::Lambda::EventSourceMapping
risorsa. -
-
StartingPositionTimestamp
-
L'ora da cui iniziare a leggere, in secondi di tempo Unix. Definisce
StartingPositionTimestamp
quandoStartingPosition
è specificato comeAT_TIMESTAMP
.Tipo: double
Required: No
AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla
StartingPositionTimestamp
proprietà di unaAWS::Lambda::EventSourceMapping
risorsa. -
Stream
-
L'Amazon Resource Name (ARN) del flusso di dati o di un consumatore di streaming.
▬Tipo: stringa
Campo obbligatorio: sì
AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla
EventSourceArn
proprietà di unaAWS::Lambda::EventSourceMapping
risorsa. -
Topics
-
Il nome dell'argomento Kafka.
Tipo: Elenco
Campo obbligatorio: sì
AWS CloudFormation compatibilità: questa proprietà viene passata direttamente alla
Topics
proprietà di unaAWS::Lambda::EventSourceMapping
risorsa.
Esempi
Esempio di Amazon MSK per un cluster esistente
Di seguito è riportato un esempio di un tipo di origine di MSK
eventi per un cluster Amazon MSK che esiste già in un Account AWS.
YAML
Events: MSKEvent: Type: MSK Properties: StartingPosition: LATEST Stream: arn:aws:kafka:us-east-1:012345678012:cluster/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2 Topics: - MyTopic
Esempio di Amazon MSK per un cluster dichiarato nello stesso modello
Di seguito è riportato un esempio di un tipo di origine di MSK
eventi per un cluster Amazon MSK dichiarato nello stesso file modello.
YAML
Events: MSKEvent: Type: MSK Properties: StartingPosition: LATEST Stream: Ref: MyMskCluster # This must be the name of an MSK cluster declared in the same template file Topics: - MyTopic