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 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](#pipes-configure-source)
1. [Configuration du filtrage des événements (facultatif)](#pipes-configure-filtering)
1. [Définition de l’enrichissement des événements (facultatif)](#pipes-define-enrichment)
1. [Configuration d’une cible](#pipes-configure-target)
1. [Configuration des paramètres de canal](#pipes-configure-pipe-settings)
Pour configurer rapidement un tube d'échantillonnage, voir[Pour commencer : créer un EventBridge canal Amazon](pipes-get-started.md). Cette rubrique permet CloudFormation de déployer un canal et ses ressources associées, et vous présente une vue d'ensemble des fonctionnalités d'un canal.
Pour plus d'informations sur la création d'un canal à l'aide de la AWS CLI, voir [create-pipe](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/pipes/create-pipe.html) dans le manuel de référence des *commandes de la AWS CLI*.
## 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/](https://console.aws.amazon.com/events/).
1. Dans le volet de navigation, choisissez **Pipelines**.
1. Choisissez **Créer un pipeline**.
1. Entrez un nom pour le canal.
1. (Facultatif) Ajoutez une description du canal.
1. 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**.
1. Pour **Serveurs Bootstrap**, entrez les adresses des paires `host:port` de vos agents.
1. Pour **Nom de la rubrique**, entrez le nom de la rubrique à partir de laquelle le canal effectuera la lecture.
1. (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é.
1. 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.
1. Pour **Clé secrète**, choisissez la clé secrète.
Pour plus d'informations, consultez la section [Authentification auprès des ressources Confluent Cloud](https://docs.confluent.io/cloud/current/access-management/authenticate/overview.html) dans la documentation Confluent.
1. (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.
1. Pour **Taille du lot - facultatif**, entrez un nombre maximal d’enregistrements par lot. La valeur par défaut est 100.
1. 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**.
1. Pour **Flux DynamoDB**, choisissez le flux que vous souhaitez utiliser en tant que source.
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.
1. (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.
1. Pour **Fenêtre du lot - facultatif**, entrez un nombre maximal de secondes pour collecter les enregistrements avant de continuer.
1. Pour **Lots simultanés par partition - facultatif**, entrez le nombre de lots issus de la même partition qui peuvent être lus simultanément.
1. 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**.
1. Pour **Flux Kinesis**, choisissez le flux que vous souhaitez utiliser en tant que source.
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.
+ **À 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.
1. (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.
1. (Facultatif) Pour **Fenêtre du lot - facultatif**, entrez un nombre maximal de secondes pour collecter les enregistrements avant de continuer.
1. Pour **Lots simultanés par partition - facultatif**, entrez le nombre de lots issus de la même partition qui peuvent être lus simultanément.
1. 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**.
1. Pour **Courtier Amazon MQ**, choisissez le flux que vous souhaitez utiliser en tant que source.
1. Pour **Nom de la file**, entrez le nom de la file d’attente à partir de laquelle le canal effectuera la lecture.
1. Pour **Méthode d’authentification**, choisissez **BASIC\_AUTH**.
1. Pour **Clé secrète**, choisissez la clé secrète.
1. (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.
1. 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**.
1. Pour **Cluster Amazon MSK**, choisissez le cluster à utiliser.
1. Pour **Nom de la rubrique**, entrez le nom de la rubrique à partir de laquelle le canal effectuera la lecture.
1. (Facultatif) Pour **ID du groupe de consommateurs - facultatif**, entrez l’identifiant du groupe de consommateurs que le canal doit rejoindre.
1. (Facultatif) Pour **Authentification - facultatif**, activez **Utiliser l’authentification** et procédez comme suit :
1. Pour **Méthode d’authentification**, choisissez le type souhaité.
1. Pour **Clé secrète**, choisissez la clé secrète.
1. (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.
1. Pour **Fenêtre du lot - facultatif**, entrez un nombre maximal de secondes pour collecter les enregistrements avant de continuer.
1. 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é**.
1. Pour **Serveurs Bootstrap**, entrez les adresses des paires `host:port` de vos agents.
1. Pour **Nom de la rubrique**, entrez le nom de la rubrique à partir de laquelle le canal effectuera la lecture.
1. (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é.
1. (Facultatif) Pour **Authentification - facultatif**, activez **Utiliser l’authentification** et procédez comme suit :
1. Pour **Méthode d’authentification**, choisissez le type d’authentification.
1. Pour **Clé secrète**, choisissez la clé secrète.
1. (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.
1. Pour **Taille du lot - facultatif**, entrez un nombre maximal d’enregistrements par lot. La valeur par défaut est 100.
1. 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**.
1. Pour **File d’attente SQS**, choisissez la file d’attente que vous souhaitez utiliser.
1. (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.
1. 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**.
1. 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**.
1. 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, consultez[Filtrage des événements dans Amazon EventBridge Pipes](eb-pipes-event-filtering.md).
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**.
1. 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**.
1. Pour **Sample events/Event Payload**, choisissez le type d'événement d'exemple.
1. 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.
1. 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**.
1. 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**.
1. Pour **Sample events/Event Payload**, choisissez le type d'événement d'exemple.
1. 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.
1. 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**.
1. 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**.
1. 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.
1. Pour utiliser un rôle d’exécution existant, choisissez **Utiliser un rôle existant**. Sous **Nom du rôle**, choisissez le rôle.
1. (Facultatif) Si vous avez spécifié un DynamoDB flux Kinesis ou comme source de canal, vous pouvez configurer une politique de nouvelles tentatives 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.
1. 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).
1. Pour **Retry attempts (Nouvelles tentatives)**, saisissez un nombre compris entre 0 et 185.
1. Si vous souhaitez utiliser une file d’attente de lettres mortes (DLQ), activez **File d’attente de lettres mortes**, choisissez la méthode de votre choix et choisissez la file d’attente ou la rubrique que vous souhaitez utiliser. Par défaut, les canaux récemment créés n’utilisent pas de DLQ.
1. Choisissez la forme KMS key EventBridge à utiliser lors du chiffrement des données du canal.
Pour plus d'informations sur EventBridge les utilisations KMS keys, voir[Chiffrement au repos](eb-data-protection.md#eb-encryption-at-rest).
+ 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.
1. (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](eb-pipes-logs.md).
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.
1. 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](eb-pipes-logs.md#eb-pipes-logs-level).
1. 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](eb-pipes-logs.md#eb-pipes-logs-execution-data).
1. 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 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 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](https://docs.aws.amazon.com/AmazonS3/latest/userguide/using-prefixes.html) 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](https://www.w3.org/TR/WD-logfile)
1. (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](eb-tagging.md).
1. 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 :
+ **Rôle IAM** : étant donné que la source d'un canal ne peut pas être modifiée une fois le canal créé, 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 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 d'API Gateway et de destination d'API est de 1, car seules les tailles de lot de 1 sont prises en charge.