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.

Transformation EventBridge des entrées Amazon Pipes

Amazon EventBridge Pipes prend en charge les transformateurs d'entrée facultatifs lors du transfert de données à l'enrichissement et à la cible. Vous pouvez utiliser des transformateurs d'entrée pour remodeler la charge utile d'entrée des JSON événements afin de répondre aux besoins du service d'enrichissement ou du service cible. Pour Amazon API Gateway et les API destinations, voici comment vous adaptez l'événement d'entrée au RESTful modèle de votreAPI. Les transformateurs d’entrée sont modélisés sous forme de paramètre InputTemplate. Il peut s'agir de texte libre, d'un JSON chemin vers la charge utile de l'événement ou d'un JSON objet incluant des JSON chemins intégrés vers la charge utile de l'événement. Pour l’enrichissement, la charge utile de l’événement provient de la source. Pour les cibles, la charge utile de l’événement correspond à ce qui est renvoyé par l’enrichissement, si une telle charge est configurée sur le canal. Outre les données propres au service incluses dans la charge utile de l’événement, vous pouvez utiliser des variables réservées dans InputTemplate pour référencer les données de votre canal.

Pour accéder aux éléments d’un tableau, utilisez la notation entre crochets.

Voici des exemples de InputTemplate paramètres faisant référence à la charge utile d'un SQS événement Amazon :

Chaîne statique

InputTemplate: "Hello, sender"

JSONParcours

InputTemplate: <$.attributes.SenderId>

Chaîne dynamique

InputTemplate: "Hello, <$.attributes.SenderId>"

Statique JSON

InputTemplate: >
{
  "key1": "value1",
  "key2": "value2",
  "key3": "value3",
}

Dynamique JSON

InputTemplate: >
{
  "key1": "value1"
  "key2": <$.body.key>,
  "d": <aws.pipes.event.ingestion-time>
}

Utilisation de la notation entre crochets pour accéder à un élément dans un tableau :

InputTemplate: >
{
  "key1": "value1"
  "key2": <$.body.Records[3]>,
  "d": <aws.pipes.event.ingestion-time>
}

Variables réservées

Les modèles d’entrée peuvent utiliser les variables réservées suivantes :

Exemple de transformation d’entrée

Voici un exemple d'EC2événement Amazon que nous pouvons utiliser comme exemple d'événement.

{
  "version": "0",
  "id": "7bf73129-1428-4cd3-a780-95db273d1602",
  "detail-type": "EC2 Instance State-change Notification",
  "source": "aws.ec2",
  "account": "123456789012",
  "time": "2015-11-11T21:29:54Z",
  "region": "us-east-1",
  "resources": [
    "arn:aws:ec2:us-east-1:123456789012:instance/i-abcd1111"
  ],
  "detail": {
    "instance-id": "i-0123456789",
    "state": "RUNNING"
  }
}
		

Utilisons ce qui suit JSON comme transformateur.

{
  "instance" : <$.detail.instance-id>,
  "state": <$.detail.state>,
  "pipeArn" : <aws.pipes.pipe-arn>,
  "pipeName" : <aws.pipes.pipe-name>,
  "originalEvent" : <aws.pipes.event.json>
}

La sortie générée est la suivante :

{
  "instance" : "i-0123456789",
  "state": "RUNNING",
  "pipeArn" : "arn:aws:pipe:us-east-1:123456789012:pipe/example",
  "pipeName" : "example",
  "originalEvent" : {
    ... // commented for brevity
  }
}

Analyse implicite des données de corps

Les champs suivants de la charge utile entrante peuvent être JSON échappés, tels que l'SQSbodyobjet Amazon, ou codés en base64, comme l'objet Kinesis. data Pour le filtrage et la transformation des entrées, EventBridge transforme ces champs en champs valides JSON afin que les sous-valeurs puissent être référencées directement. Par exemple, <$.data.someKey> pour Kinesis.

Pour que la cible reçoive la charge utile d’origine sans aucune métadonnée supplémentaire, utilisez un transformateur d’entrée avec ces données de corps, propres à la source. Par exemple, <$.body> pour Amazon SQS ou <$.data> pour Kinesis. Si la charge utile d'origine est une JSON chaîne valide (par exemple{"key": "value"}), l'utilisation du transformateur d'entrée avec des données corporelles spécifiques à la source entraînera la suppression des guillemets contenus dans la charge utile source d'origine. Par exemple, {"key": "value"} deviendra "{key: value}" une fois livré à la cible. Si votre cible a besoin de JSON charges utiles valides (par exemple, EventBridge Lambda ou Step Functions), cela entraînera un échec de livraison. Pour que la cible reçoive les données source d'origine sans générer de données invalidesJSON, insérez le transformateur d'entrée des données du corps sourceJSON. Par exemple, {"data": <$.data>}.

L’analyse implicite du corps peut également être utilisée pour renseigner dynamiquement les valeurs de la plupart des paramètres de cible ou d’enrichissement du canal. Pour plus d’informations, consultez Paramètres de chemin dynamiques.

Problèmes courants liés à la transformation d’entrée

Voici quelques problèmes courants lors de la transformation des entrées en EventBridge tubes :