View a markdown version of this page

Création d'un EventBridge tube Amazon - Amazon EventBridge
Spécification d’une sourceConfiguration du filtrageDéfinition de l’enrichissementConfiguration d’une cibleConfiguration des paramètres de canalValidation des paramètres de configuration

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.

Création d'un EventBridge tube Amazon

EventBridge Pipes vous permet de créer des intégrations point à point entre les sources et les cibles, y compris des transformations et un enrichissement avancés des événements.

Pour créer un EventBridge tube, 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 configurer rapidement un tuyau d'échantillonnage, voirPour commencer : créer un EventBridge canal Amazon. Cette rubrique permet CloudFormation de déployer un tube et ses ressources associées, et vous donne un aperçu des fonctionnalités d'un canal.

Pour plus d'informations sur la création d'un tube à l'aide de l' AWS interface de ligne de commande, voir create-pipe dans la référence des commandes de l'AWS interface de ligne de commande.

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 un VPC. Ensuite, pour Sous-réseaux VPC, choisissez les sous-réseaux souhaités. Pour Groupes de sécurité VPC, choisissez les groupes de sécurité.

    5. 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.

      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 10.

      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 : divisez chaque lot en deux et effectuez une nouvelle tentative avec 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 certains enregistrements ayant échoué et uniquement ceux ayant fait l’objet d’une nouvelle tentative.

    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 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 10.

      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 : divisez chaque lot en deux et effectuez une nouvelle tentative avec 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 certains enregistrements ayant échoué et uniquement ceux ayant fait l’objet d’une nouvelle tentative.

    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 source Amazon MSK à l’aide de la console

    1. Pour Source, choisissez Amazon MSK.

    2. Pour Cluster Amazon MSK, choisissez le cluster à 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 Self-managed Apache Kafka.

    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 un VPC. Ensuite, pour Sous-réseaux VPC, choisissez les sous-réseaux souhaités. Pour Groupes de sécurité VPC, 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 source Amazon SQS à l’aide de la console

    1. Pour Source, choisissez SQS.

    2. Pour File d’attente SQS, 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 les enrichir à une fonction Lambda, à une machine à AWS Step Functions états, à Amazon API Gateway ou à une destination d'API.

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 Sample events/Event Payload, choisissez le type d'événement d'exemple.

  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 Sample events/Event Payload, choisissez le type d'événement d'exemple.

  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 tube, choisissez Créer un nouveau rôle pour cette ressource spécifique. 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.

    Gestionnaire de rôles activé

    Si le gestionnaire de rôles est activé sur votre compte, il EventBridge associe le rôle à votre place. EventBridge remplace les options Créer un nouveau rôle pour cette ressource spécifique et Utiliser les rôles existants par une option Personnaliser. Pour utiliser un autre rôle, choisissez Personnaliser. Pour plus d’informations, consultez Création de rôles IAM dans le Guide de l’utilisateur IAM.

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

    Pour Politique de nouvelle tentative et Dead-letter file d'attente (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 Dead-letter file d'attente, choisissez la méthode de votre choix, puis choisissez la file d'attente ou le sujet que vous souhaitez utiliser. Par défaut, les canaux récemment créés n’utilisent pas de DLQ.

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

    Pour plus d'informations sur les EventBridge utilisations KMS keys, consultezChiffrement au repos.

    • Choisissez Utiliser Clé détenue par AWS pour EventBridge pour chiffrer 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 plusieurs AWS comptes pour une utilisation. En général, à moins que vous ne soyez tenu d'auditer ou de contrôler la clé de chiffrement qui protège vos ressources, an Clé détenue par AWS constitue un bon choix.

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

    • Choisissez Utiliser clé gérée par le client pour EventBridge pour chiffrer les données à l'aide de clé gérée par le client ce 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, possédez et gérez. Vous en avez le contrôle total KMS keys.

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

        EventBridge affiche l'état de la clé et tous les alias de clé qui ont été 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 logs est sélectionné comme destination du journal 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 de journal 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'informations 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 et 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 si vous EventBridge souhaitez créer un nouveau groupe de journaux, ou vous pouvez sélectionner un groupe de journaux existant ou spécifier l'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 des Firehose flux, sélectionnez le Firehose flux.

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

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

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

      • 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 :

  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

Une fois qu'un tube est créé, EventBridge valide les paramètres de configuration suivants :

  • Rôle IAM  : étant donné que la source d'un canal ne peut pas être modifiée après sa création, EventBridge vérifie que le rôle IAM 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 tube.

  • Traitement par lots  : EventBridge permet de vérifier que la taille du lot de la source ne dépasse pas la taille de lot maximale de la cible. Si c'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 valide que la taille de lot pour les enrichissements d'API Gateway et de destination d'API est de 1, car seules les tailles de lot de 1 sont prises en charge.