Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
MSK
L'objet décrivant un type de source d'événement MSK
. Pour plus d'informations, consultez la section Utilisation AWS Lambda avec Amazon MSK dans le manuel du AWS Lambda développeur.
AWS Serverless Application Model (AWS SAM) génère une AWS::Lambda::EventSourceMappingressource lorsque ce type d'événement est défini.
Syntaxe
Pour déclarer cette entité dans votre AWS SAM modèle, utilisez la syntaxe suivante.
YAML
ConsumerGroupId:
String
DestinationConfig:DestinationConfig
FilterCriteria:FilterCriteria
MaximumBatchingWindowInSeconds:Integer
SourceAccessConfigurations:SourceAccessConfigurations
StartingPosition:String
StartingPositionTimestamp:Double
Stream:String
Topics:List
Propriétés
-
ConsumerGroupId
-
Chaîne qui configure la façon dont les événements seront lus à partir des rubriques Kafka.
Type : chaîne
Obligatoire : non
AWS CloudFormation compatibilité : cette propriété est transmise directement à la
AmazonManagedKafkaConfiguration
propriété d'uneAWS::Lambda::EventSourceMapping
ressource. -
DestinationConfig
-
Objet de configuration qui spécifie la destination d'un événement après son traitement par Lambda.
Utilisez cette propriété pour spécifier la destination des invocations ayant échoués à partir de la source d'événements Amazon MSK.
Type : DestinationConfig
Obligatoire : non
AWS CloudFormation compatibilité : cette propriété est transmise directement à la
DestinationConfig
propriété d'uneAWS::Lambda::EventSourceMapping
ressource. -
FilterCriteria
-
Objet qui définit les critères permettant de déterminer si Lambda doit traiter un événement. Pour de plus amples informations, veuillez consulter AWS Lambda le filtrage d’événements dans le AWS Lambda Manuel du développeur.
Type : FilterCriteria
Obligatoire : non
AWS CloudFormation compatibilité : cette propriété est transmise directement à la
FilterCriteria
propriété d'uneAWS::Lambda::EventSourceMapping
ressource. -
MaximumBatchingWindowInSeconds
-
Intervalle de temps maximal (en secondes) pour collecter des enregistrements avant d’invoquer la fonction.
Type : entier
Obligatoire : non
AWS CloudFormation compatibilité : cette propriété est transmise directement à la
MaximumBatchingWindowInSeconds
propriété d'uneAWS::Lambda::EventSourceMapping
ressource. -
SourceAccessConfigurations
-
Tableau du protocole d’authentification, composants VPC ou hôte virtuel pour sécuriser et définir votre source d’événement.
Valeurs valides :
CLIENT_CERTIFICATE_TLS_AUTH
Type : liste de propriétés SourceAccessConfiguration
Obligatoire : non
AWS CloudFormation compatibilité : cette propriété est transmise directement à la
SourceAccessConfigurations
propriété d'uneAWS::Lambda::EventSourceMapping
ressource. -
StartingPosition
-
Position de début de la lecture dans le flux.
-
AT_TIMESTAMP
: spécifier l'heure à partir de laquelle la lecture des enregistrements doit commencer. -
LATEST
: lire uniquement les nouveaux enregistrements. -
TRIM_HORIZON
: traiter tous les enregistrements disponibles.
Valeurs valides :
AT_TIMESTAMP
|LATEST
|TRIM_HORIZON
Type : chaîne
Obligatoire : non
AWS CloudFormation compatibilité : cette propriété est transmise directement à la
StartingPosition
propriété d'uneAWS::Lambda::EventSourceMapping
ressource. -
-
StartingPositionTimestamp
-
L'heure à partir de laquelle commencer la lecture, en secondes au format horaire Unix. Définissez
StartingPositionTimestamp
lorsqueStartingPosition
est défini surAT_TIMESTAMP
.Type : double
Obligatoire : non
AWS CloudFormation compatibilité : cette propriété est transmise directement à la
StartingPositionTimestamp
propriété d'uneAWS::Lambda::EventSourceMapping
ressource. -
Stream
-
L'Amazon Resource Name (ARN) du flux de données ou d'un consommateur de flux.
Type : chaîne
Obligatoire : oui
AWS CloudFormation compatibilité : cette propriété est transmise directement à la
EventSourceArn
propriété d'uneAWS::Lambda::EventSourceMapping
ressource. -
Topics
-
Nom de la rubrique Kafka.
Type : liste
Obligatoire : oui
AWS CloudFormation compatibilité : cette propriété est transmise directement à la
Topics
propriété d'uneAWS::Lambda::EventSourceMapping
ressource.
Exemples
Exemple Amazon MSK pour un cluster existant
Voici un exemple de type de source d'événement MSK
pour un cluster Amazon MSK qui existe déjà dans un Compte 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
Exemple Amazon MSK pour un cluster déclaré dans le même modèle
Voici un exemple de type de source d'événement MSK
pour un cluster Amazon MSK déclaré dans le même fichier modèle.
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