View a markdown version of this page

Utilisation de Lambda avec Amazon MSK - AWS Lambda
Exemple d’évènement

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.

Utilisation de Lambda avec Amazon MSK

Amazon Managed Streaming for Apache Kafka (Amazon MSK) est un service entièrement géré qui vous permet de créer et d’exécuter des applications qui utilisent Apache Kafka pour traiter des données en streaming. Amazon MSK simplifie la configuration, la mise à l’échelle et la gestion des clusters Kafka. Amazon MSK facilite également la configuration de votre application pour plusieurs zones de disponibilité et pour des raisons de sécurité avec Gestion des identités et des accès AWS (IAM).

Ce chapitre explique comment utiliser un cluster Amazon MSK comme source d'événements pour votre fonction d'événement Lambda. Le processus général d’intégration d’Amazon MSK à Lambda comprend les étapes suivantes :

  1. Configuration du cluster et du réseau : configurez d’abord votre cluster Amazon MSK. Cela inclut la configuration réseau correcte pour permettre à Lambda d’accéder à votre cluster.

  2. Configuration du mappage des sources d’événements : créez ensuite la ressource de mappage des sources d’événements dont Lambda a besoin pour connecter de façon sécurisée votre cluster Amazon MSK à votre fonction.

  3. Configuration de la fonction événementielle et des autorisations — Enfin, assurez-vous que votre fonction est correctement configurée et qu'elle dispose des autorisations nécessaires dans son rôle d'exécution.

Note

Vous pouvez désormais créer et gérer vos mappages de sources d'événements Amazon MSK directement depuis la console Lambda ou Amazon MSK. Les deux consoles offrent la possibilité de gérer automatiquement la configuration des autorisations de rôle d'exécution Lambda nécessaires pour un processus de configuration plus rationalisé.

Pour des exemples expliquant comment configurer une intégration Lambda avec un cluster Amazon MSK, consultez les sections Tutoriel : Utilisation d'un mappage de source d'événements Amazon MSK pour appeler une fonction d'événement Lambda Utilisation d'Amazon MSK comme source d'événements AWS Lambda sur le blog AWS Compute et Intégration d'Amazon MSK Lambda dans les Amazon MSK Labs.

Rubriques

Exemple d’évènement

Lambda envoie le lot de messages dans le paramètre d'événement lorsqu'il appelle votre fonction d'événement. La charge utile d’un événement contient un tableau de messages. Chaque élément de tableau contient des détails de la rubrique Amazon MSK et un identifiant de partition, ainsi qu’un horodatage et un message codé en base 64.

{
   "eventSource":"aws:kafka",
   "eventSourceArn":"arn:aws:kafka:us-east-1:123456789012:cluster/vpc-2priv-2pub/751d2973-a626-431c-9d4e-d7975eb44dd7-2",
   "bootstrapServers":"b-2.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092,b-1.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092",
   "records":{
      "mytopic-0":[
         {
            "topic":"mytopic",
            "partition":0,
            "offset":15,
            "timestamp":1545084650987,
            "timestampType":"CREATE_TIME",
            "key":"abcDEFghiJKLmnoPQRstuVWXyz1234==",
            "value":"SGVsbG8sIHRoaXMgaXMgYSB0ZXN0Lg==",
            "headers":[
               {
                  "headerKey":[
                     104,
                     101,
                     97,
                     100,
                     101,
                     114,
                     86,
                     97,
                     108,
                     117,
                     101
                  ]
               }
            ]
         }
      ]
   }
}