Création d'un EventBridge canal Amazon

EventBridge Pipes vous permet de créer des point-to-point intégrations entre les sources et les cibles, notamment des transformations et des enrichissements d'événements avancés. Pour créer un EventBridge canal, vous devez suivre les étapes suivantes :

1. Spécification d’une source

2. Configuration du filtrage des événements (facultatif)

3. Définition de l’enrichissement des événements (facultatif)

4. Configuration d’une cible

5. Configuration des paramètres de canal

Pour plus d'informations sur la création d'un canal à l'aide de AWS CLI, voir create-pipe dans la référence des AWS CLIcommandes.

Spécification d’une source

Pour commencer, spécifiez la source à partir de laquelle vous souhaitez que le canal reçoive les événements.

Pour spécifier une source de canal à l’aide de la console

1. Ouvrez la EventBridge console Amazon à l'adresse https://console.aws.amazon.com/events/.

2. Dans le volet de navigation, choisissez Pipelines.

3. Choisissez Créer un pipeline.

4. Entrez un nom pour le canal.

5. (Facultatif) Ajoutez une description du canal.

6. Dans l’onglet Construire un pipeline, pour Source, choisissez le type de source que vous souhaitez spécifier pour ce canal, puis configurez la source.

   Les propriétés de configuration varient en fonction du type de source que vous choisissez :

   Confluent

   Pour configurer un flux Confluent Cloud en tant que source, à l'aide de la console

   1. Pour Source, choisissez Confluent Cloud.

   2. Pour Serveurs Bootstrap, entrez les adresses des paires host:port de vos agents.

   3. Pour Nom de la rubrique, entrez le nom de la rubrique à partir de laquelle le canal effectuera la lecture.

   4. (Facultatif) Pour VPC, choisissez celle VPC que vous souhaitez. Ensuite, pour les VPCsous-réseaux, choisissez les sous-réseaux souhaités. Pour les groupes VPC de sécurité, choisissez les groupes de sécurité.

   5. Pour Authentification (facultatif), activez l'option Utiliser l'authentification et procédez comme suit :

      1. Pour Méthode d’authentification, choisissez le type d’authentification.

      2. Pour Clé secrète, choisissez la clé secrète.

      Pour plus d'informations, consultez la section Authentification auprès des ressources Confluent Cloud dans la documentation Confluent.

   6. (Facultatif) Pour Paramètre supplémentaire - facultatif, procédez comme suit :

      1. Pour Position de départ, choisissez l’une des valeurs suivantes :

         • Dernier : commencez à lire le flux par l’enregistrement le plus récent de la partition.

         • Trim horizon : commencez à lire le flux par le dernier enregistrement non découpé de la partition. Il s’agit de l’enregistrement le plus ancien de la partition.

      2. Pour Taille du lot - facultatif, entrez un nombre maximal d’enregistrements par lot. La valeur par défaut est 100.

      3. Pour Fenêtre du lot - facultatif, entrez un nombre maximal de secondes pour collecter les enregistrements avant de continuer.

   DynamoDB

   1. Pour Source, choisissez DynamoDB.

   2. Pour Flux DynamoDB, choisissez le flux que vous souhaitez utiliser en tant que source.

   3. Pour Position de départ, choisissez l’une des valeurs suivantes :

      • Dernier : commencez à lire le flux par l’enregistrement le plus récent de la partition.

      • Trim horizon : commencez à lire le flux par le dernier enregistrement non découpé de la partition. Il s’agit de l’enregistrement le plus ancien de la partition.

   4. (Facultatif) Pour Paramètre supplémentaire - facultatif, procédez comme suit :

      1. Pour Taille du lot - facultatif, entrez un nombre maximal d’enregistrements par lot. La valeur par défaut est 100.

      2. Pour Fenêtre du lot - facultatif, entrez un nombre maximal de secondes pour collecter les enregistrements avant de continuer.

      3. Pour Lots simultanés par partition - facultatif, entrez le nombre de lots issus de la même partition qui peuvent être lus simultanément.

      4. Pour En cas de défaillance partielle d’un lot, choisissez ce qui suit :

         • AUTOMATIC_ BISECT — Réduisez de moitié chaque lot et réessayez chaque moitié jusqu'à ce que tous les enregistrements soient traités ou qu'il reste un message d'échec dans le lot.

         Note

         Si vous ne choisissez pas AUTOMATIC_ BISECT, vous pouvez renvoyer des enregistrements ayant échoué spécifiques et seuls ceux-ci seront réessayés.

   Kinesis

   Pour configurer une source Kinesis à l’aide de la console

   1. Pour Source, choisissez Kinesis.

   2. Pour Flux Kinesis, choisissez le flux que vous souhaitez utiliser en tant que source.

   3. Pour Position de départ, choisissez l’une des valeurs suivantes :

      • Dernier : commencez à lire le flux par l’enregistrement le plus récent de la partition.

      • Trim horizon : commencez à lire le flux par le dernier enregistrement non découpé de la partition. Il s’agit de l’enregistrement le plus ancien de la partition.

      • À l’horodatage : commencez à lire le flux à partir d’une heure spécifiée. Sous Horodatage, entrez une date et une heure au format YYYY /MM/DD et hh:mm:ss.

   4. (Facultatif) Pour Paramètre supplémentaire - facultatif, procédez comme suit :

      1. Pour Taille du lot - facultatif, entrez un nombre maximal d’enregistrements par lot. La valeur par défaut est 100.

      2. (Facultatif) Pour Fenêtre du lot - facultatif, entrez un nombre maximal de secondes pour collecter les enregistrements avant de continuer.

      3. Pour Lots simultanés par partition - facultatif, entrez le nombre de lots issus de la même partition qui peuvent être lus simultanément.

      4. Pour En cas de défaillance partielle d’un lot, choisissez ce qui suit :

         • AUTOMATIC_ BISECT — Réduisez de moitié chaque lot et réessayez chaque moitié jusqu'à ce que tous les enregistrements soient traités ou qu'il reste un message d'échec dans le lot.

         Note

         Si vous ne choisissez pas AUTOMATIC_ BISECT, vous pouvez renvoyer des enregistrements ayant échoué spécifiques et seuls ceux-ci seront réessayés.

   Amazon MQ

   Pour configurer une source Amazon MQ à l’aide de la console

   1. Pour Source, choisissez Amazon MQ.

   2. Pour Courtier Amazon MQ, choisissez le flux que vous souhaitez utiliser en tant que source.

   3. Pour Nom de la file, entrez le nom de la file d’attente à partir de laquelle le canal effectuera la lecture.

   4. Pour Méthode d'authentification, choisissez BASIC_ AUTH.

   5. Pour Clé secrète, choisissez la clé secrète.

   6. (Facultatif) Pour Paramètre supplémentaire - facultatif, procédez comme suit :

      1. Pour Taille du lot - facultatif, entrez un nombre maximal de messages par lot. La valeur par défaut est 100.

      2. Pour Fenêtre du lot - facultatif, entrez un nombre maximal de secondes pour collecter les enregistrements avant de continuer.

   Amazon MSK

   Pour configurer une MSK source Amazon à l'aide de la console

   1. Pour Source, choisissez Amazon MSK.

   2. Pour le MSKcluster Amazon, choisissez le cluster que vous souhaitez utiliser.

   3. Pour Nom de la rubrique, entrez le nom de la rubrique à partir de laquelle le canal effectuera la lecture.

   4. (Facultatif) Pour ID du groupe de consommateurs - facultatif, entrez l’identifiant du groupe de consommateurs que le canal doit rejoindre.

   5. (Facultatif) Pour Authentification - facultatif, activez Utiliser l’authentification et procédez comme suit :

      1. Pour Méthode d’authentification, choisissez le type souhaité.

      2. Pour Clé secrète, choisissez la clé secrète.

   6. (Facultatif) Pour Paramètre supplémentaire - facultatif, procédez comme suit :

      1. Pour Taille du lot - facultatif, entrez un nombre maximal d’enregistrements par lot. La valeur par défaut est 100.

      2. Pour Fenêtre du lot - facultatif, entrez un nombre maximal de secondes pour collecter les enregistrements avant de continuer.

      3. Pour Position de départ, choisissez l’une des valeurs suivantes :

         • Dernier : commencez à lire la rubrique par l’enregistrement le plus récent de la partition.

         • Trim horizon : commencez à lire la rubrique par le dernier enregistrement non découpé de la partition. Il s’agit de l’enregistrement le plus ancien de la partition.

           Note

           Pour Apache Kafka, Trim horizon est identique à Premier.

   Self managed Apache Kafka

   Pour configurer une source Apache Kafka autogérée à l’aide de la console

   1. Pour Source, choisissez Apache Kafka autogéré.

   2. Pour Serveurs Bootstrap, entrez les adresses des paires host:port de vos agents.

   3. Pour Nom de la rubrique, entrez le nom de la rubrique à partir de laquelle le canal effectuera la lecture.

   4. (Facultatif) Pour VPC, choisissez celle VPC que vous souhaitez. Ensuite, pour les VPCsous-réseaux, choisissez les sous-réseaux souhaités. Pour les groupes VPC de sécurité, choisissez les groupes de sécurité.

   5. (Facultatif) Pour Authentification - facultatif, activez Utiliser l’authentification et procédez comme suit :

      1. Pour Méthode d’authentification, choisissez le type d’authentification.

      2. Pour Clé secrète, choisissez la clé secrète.

   6. (Facultatif) Pour Paramètre supplémentaire - facultatif, procédez comme suit :

      1. Pour Position de départ, choisissez l’une des valeurs suivantes :

         • Dernier : commencez à lire le flux par l’enregistrement le plus récent de la partition.

         • Trim horizon : commencez à lire le flux par le dernier enregistrement non découpé de la partition. Il s’agit de l’enregistrement le plus ancien de la partition.

      2. Pour Taille du lot - facultatif, entrez un nombre maximal d’enregistrements par lot. La valeur par défaut est 100.

      3. Pour Fenêtre du lot - facultatif, entrez un nombre maximal de secondes pour collecter les enregistrements avant de continuer.

   Amazon SQS

   Pour configurer une SQS source Amazon à l'aide de la console

   1. Pour Source, choisissez SQS.

   2. Pour SQSfile d'attente, choisissez la file d'attente que vous souhaitez utiliser.

   3. (Facultatif) Pour Paramètre supplémentaire - facultatif, procédez comme suit :

      1. Pour Taille du lot - facultatif, entrez un nombre maximal d’enregistrements par lot. La valeur par défaut est 100.

      2. Pour Fenêtre du lot - facultatif, entrez un nombre maximal de secondes pour collecter les enregistrements avant de continuer.

Configuration du filtrage des événements (facultatif)

Vous pouvez ajouter un filtrage à votre canal afin d’envoyer uniquement un sous-ensemble d’événements de votre source à la cible.

Pour configurer le filtrage à l’aide de la console

1. Choisissez Filtrage.

2. Sous Exemple d’événement - facultatif, vous verrez un exemple d’événement que vous pouvez utiliser pour créer votre modèle d’événement, ou vous pouvez entrer votre propre événement en choisissant Saisir mon propre.

3. Sous Modèle d’événement, entrez le modèle d’événement que vous souhaitez utiliser pour filtrer les événements. Pour plus d'informations sur la création de filtres, consultezFiltrage des événements dans Amazon EventBridge Pipes.

   L’exemple de modèle d’événement suivant envoie uniquement des événements dont le champ City contient la valeur Seattle.

   {
     "data": {
       "City": ["Seattle"]
     }
   }

À présent que les événements sont filtrés, vous pouvez ajouter un enrichissement facultatif et une cible pour le canal.

Définition de l’enrichissement des événements (facultatif)

Vous pouvez envoyer les données d'événement pour enrichissement à une fonction Lambda, à une machine à AWS Step Functions états, à Amazon API Gateway ou API à une destination.

Pour sélectionner l’enrichissement

1. Choisissez Enrichissement.

2. Sous Informations, pour Service, sélectionnez le service et les paramètres associés que vous souhaitez utiliser pour l’enrichissement.

Vous pouvez également transformer les données avant de les envoyer pour les améliorer.

(Facultatif) Pour définir le transformateur d’entrée

1. Choisissez Transformateur d’entrée d’enrichissement - facultatif.

2. Pour Exemples d’événements/charge utile d’événement, choisissez le type d’exemple d’événement.

3. Pour Transformateur, entrez la syntaxe du transformateur, par exemple "Event happened at <$.detail.field>.", où <$.detail.field> est une référence à un champ issu de l’exemple d’événement. Vous pouvez également double-cliquer sur un champ dans l’exemple d’événement pour l’ajouter au transformateur.

4. Pour Sortie, vérifiez que la sortie ressemble à ce que vous souhaitez.

À présent que les données ont été filtrées et améliorées, vous devez définir une cible à laquelle envoyer les données d’événement.

Configuration d’une cible

Pour configurer une cible

1. Choisissez Target.

2. Sous Informations, pour Service cible, choisissez la cible. Les champs qui s’affichent varient en fonction de la cible que vous choisissez. Entrez les informations spécifiques à ce type de cible, selon vos besoins.

Vous pouvez également transformer les données avant de les envoyer à la cible.

(Facultatif) Pour définir le transformateur d’entrée

1. Choisissez Transformateur d’entrée cible - facultatif.

2. Pour Exemples d’événements/charge utile d’événement, choisissez le type d’exemple d’événement.

3. Pour Transformateur, entrez la syntaxe du transformateur, par exemple "Event happened at <$.detail.field>.", où <$.detail.field> est une référence à un champ issu de l’exemple d’événement. Vous pouvez également double-cliquer sur un champ dans l’exemple d’événement pour l’ajouter au transformateur.

4. Pour Sortie, vérifiez que la sortie ressemble à ce que vous souhaitez.

À présent que le canal est configuré, assurez-vous que ses paramètres sont correctement configurés.

Configuration des paramètres de canal

Un canal est actif par défaut, mais vous pouvez le désactiver. Vous pouvez également spécifier les autorisations du canal, configurer la journalisation du canal et ajouter des balises.

Pour configurer les paramètres de canal

1. Cliquez sur l’onglet Réglages des pipelines.

2. Par défaut, les canaux récemment créés sont actifs dès leur création. Si vous souhaitez créer un canal inactif, sous Activation, pour Activer le pipeline, désactivez Actif.

3. Sous Autorisations, pour Rôle d’exécution, effectuez l’une des opérations suivantes :

   1. Pour EventBridge créer un nouveau rôle d'exécution pour ce canal, choisissez Create a new role for this specific resource. Sous Nom du rôle, vous pouvez éventuellement modifier le nom du rôle.

   2. Pour utiliser un rôle d’exécution existant, choisissez Utiliser un rôle existant. Sous Nom du rôle, choisissez le rôle.

4. (Facultatif) Si vous avez spécifié un DynamoDB flux Kinesis ou comme source de canal, vous pouvez configurer une politique de nouvelle tentative et une file d'attente de lettres mortes (). DLQ

   Pour Stratégie de nouvelles tentatives et file d’attente de lettres mortes - facultatif, procédez comme suit :

   Sous Politique de nouvelles tentatives, procédez comme suit :

   1. Si vous souhaitez activer les politiques de nouvelles tentatives, activez Réessayer. Par défaut, aucune politique de nouvelle tentative n’est activée pour les canaux récemment créés.

   2. Pour Maximum age of event (Âge maximal de l'événement), saisissez une valeur comprise entre une minute (00:01) et 24 heures (24:00).

   3. Pour Retry attempts (Nouvelles tentatives), saisissez un nombre compris entre 0 et 185.

   4. Si vous souhaitez utiliser une file d'attente de lettres mortes (DLQ), activez la file d'attente de lettres mortes, choisissez la méthode de votre choix et choisissez la file d'attente ou le sujet que vous souhaitez utiliser. Par défaut, les canaux nouvellement créés n'utilisent pas unDLQ.

5. Choisissez la forme KMS key EventBridge à utiliser lors du chiffrement des données du canal.

   Pour plus d'informations sur la façon dont EventBridge les utilisations sont KMS keys utilisées, consultezChiffrement au repos.

   • Choisissez Utiliser Clé détenue par AWS pour chiffrer EventBridge les données à l'aide d'un Clé détenue par AWS.

     Il s' Clé détenue par AWS agit d'un compte KMS key qui EventBridge possède et gère pour une utilisation dans plusieurs AWS comptes. En général, à moins que vous ne soyez obligé d'auditer ou de contrôler la clé de chiffrement qui protège vos ressources, une Clé détenue par AWS est un bon choix.

     Il s’agit de l’option par défaut.

   • Choisissez Utiliser clé gérée par le client pour chiffrer les données EventBridge à l'aide de celles clé gérée par le client que vous spécifiez ou créez.

     Clés gérées par le client se trouvent KMS keys dans le AWS compte que vous créez, détenez et gérez. Vous en avez le plein contrôle KMS keys.

     1. Spécifiez un existant clé gérée par le client ou choisissez Créer un nouveau KMS key.

        EventBridge affiche le statut de la clé et tous les alias de clé associés à la clé spécifiée clé gérée par le client.

6. (Facultatif) Sous Journaux - facultatif, vous pouvez configurer la manière dont EventBridge Pipes envoie les informations de journalisation aux services pris en charge, notamment comment configurer ces journaux.

   Pour plus d’informations sur la journalisation des enregistrements de journaux, consultez Enregistrement des performances d'Amazon EventBridge Pipes.

   CloudWatch les journaux sont sélectionnés comme destination des journaux par défaut, tout comme le niveau du ERROR journal. Ainsi, par défaut, EventBridge Pipes crée un nouveau groupe de CloudWatch journaux auquel il envoie des enregistrements contenant le ERROR niveau de détail.

   Pour que EventBridge Pipes envoie des enregistrements de journal vers l'une des destinations de journal prises en charge, procédez comme suit :

   1. Sous Journaux - facultatif, choisissez les destinations vers lesquelles vous souhaitez que les enregistrements de journaux soient livrés.

   2. Pour Niveau du journal, choisissez le niveau d'information EventBridge à inclure dans les enregistrements du journal. Le niveau de journalisation ERROR est sélectionné par défaut.

      Pour de plus amples informations, veuillez consulter Spécification du niveau de journalisation des EventBridge tuyaux.

   3. Sélectionnez Inclure les données d'exécution si vous souhaitez inclure les informations relatives EventBridge à la charge utile des événements ainsi que les informations relatives aux demandes de service et aux réponses dans les enregistrements du journal.

      Pour de plus amples informations, veuillez consulter Inclure les données d'exécution dans les logs de EventBridge Pipes.

   4. Configurez chaque destination de journal que vous avez sélectionnée :

      Pour CloudWatch Logs les journaux, sous CloudWatch journaux, procédez comme suit :

      • Pour le groupe de CloudWatch journaux, choisissez de EventBridge créer un nouveau groupe de journaux, de sélectionner un groupe de journaux existant ou de spécifier celui ARN d'un groupe de journaux existant.

      • Pour les nouveaux groupes de journaux, modifiez le nom du groupe de journaux comme vous le souhaitez.

      CloudWatch logs est sélectionné par défaut.

      Pour les journaux de Firehose flux, sous journal de Firehose flux, sélectionnez le Firehose flux.

      Pour Amazon S3 les journaux, sous S3 logs, procédez comme suit :

      • Entrez le nom du compartiment à utiliser comme destination du journal.

      • Entrez l'ID de AWS compte du propriétaire du compartiment.

      • Entrez le texte de préfixe que vous souhaitez utiliser lorsque EventBridge crée des objets S3.

        Pour plus d’informations, consultez Organisation des objets à l’aide de préfixes dans le Guide de l’utilisateur Amazon Simple Storage Service .

      • Choisissez la manière dont vous EventBridge souhaitez formater les enregistrements du journal S3 :

        • json: JSON

        • plain : texte brut

        • w3c : Format de fichier de journalisation étendu W3C

7. (Facultatif) Sous Balises - facultatif, choisissez Ajouter une nouvelle balise et entrez une ou plusieurs balises pour la règle. Pour de plus amples informations, veuillez consulter Marquage des ressources sur Amazon EventBridge.

8. Choisissez Créer un pipeline.

Validation des paramètres de configuration

Après la création d'un canal, EventBridge valide les paramètres de configuration suivants :

• IAMrôle — Comme la source d'un canal ne peut pas être modifiée une fois le canal créé, EventBridge vérifie que le IAM rôle fourni peut accéder à la source.

  Note

  EventBridge n'effectue pas la même validation pour les enrichissements ou les cibles car ils peuvent être mis à jour après la création du canal.

• Traitement par lots : EventBridge vérifie que la taille du lot de la source ne dépasse pas la taille de lot maximale de la cible. Si tel est le cas, EventBridge nécessite une taille de lot inférieure. En outre, si une cible ne prend pas en charge le traitement par lots, vous ne pouvez pas configurer le traitement par lots EventBridge pour la source.

• Enrichissements : EventBridge confirme que la taille de lot pour les enrichissements de API passerelle et de API destination est de 1, car seules les tailles de lot de 1 sont prises en charge.