Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Transformación EventBridge de entradas de Amazon Pipes

Amazon EventBridge Pipes admite transformadores de entrada opcionales al pasar datos al enriquecimiento y al destino. Puede utilizar transformadores de entrada para cambiar la forma de la carga útil de entrada del JSON evento y adaptarla a las necesidades del servicio de enriquecimiento o de destino. Para Amazon API Gateway y API los destinos, así es como adaptas el evento de entrada al RESTful modelo de tuAPI. Los transformadores de entrada se modelan como un parámetro InputTemplate. Pueden ser texto libre, una JSON ruta a la carga útil del evento o un JSON objeto que incluya JSON rutas en línea a la carga útil del evento. Para el enriquecimiento, la carga del evento proviene del origen. En el caso de los destinos, la carga del evento es la que se devuelve desde el enriquecimiento, si hay alguna configurada en la canalización. Además de los datos específicos del servicio en la carga del evento, puede usar variables reservadas en su InputTemplate para hacer referencia a datos para la canalización.

Para acceder a los elementos de una matriz, use la notación entre corchetes.

Los siguientes son ejemplos de InputTemplate parámetros que hacen referencia a una carga útil de SQS eventos de Amazon:

Cadena estática

InputTemplate: "Hello, sender"

JSONRuta

InputTemplate: <$.attributes.SenderId>

Cadena dinámica

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

Estático JSON

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

Dinámico JSON

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

Uso de la notación entre corchetes para acceder a los elementos de una matriz:

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

Variables reservadas

Las plantillas de entrada pueden utilizar las siguientes variables reservadas:

Ejemplos de transformación de entrada

El siguiente es un ejemplo de un EC2 evento de Amazon que podemos usar como nuestro evento de muestra.

{
  "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"
  }
}
		

Usemos lo siguiente JSON como nuestro transformador.

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

Se generará la siguiente salida:

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

Análisis implícito de datos del cuerpo

Los siguientes campos de la carga útil entrante pueden estar en modo de JSON escape, como el objeto de Amazon, o codificados en base64, como el SQS body objeto de Kinesis. data Tanto para el filtrado como para la transformación de entradas, EventBridge transforma estos campos en campos válidos para que se JSON pueda hacer referencia directamente a los subvalores. Por ejemplo, <$.data.someKey> para Kinesis.

Para que el destino reciba la carga original sin ningún metadato adicional, utilice un transformador de entrada con estos datos del cuerpo, específicos del origen. Por ejemplo, <$.body> para Amazon SQS o <$.data> Kinesis. Si la carga útil original es una JSON cadena válida (por ejemplo{"key": "value"}), el uso del transformador de entrada con datos del cuerpo específicos de la fuente hará que se eliminen las comillas de la carga útil de origen original. Por ejemplo, {"key": "value"} se convertirá en "{key: value}" cuando se entregue al destino. Si su destino requiere JSON cargas útiles válidas (por ejemplo, EventBridge Lambda o Step Functions), se producirá un error en la entrega. Para que el destino reciba los datos de origen originales sin generar datos no válidosJSON, inserte el transformador de entrada de los datos del cuerpo de la fuente. JSON Por ejemplo, {"data": <$.data>}.

El análisis del cuerpo implícito también se puede utilizar para rellenar dinámicamente los valores de la mayoría de los parámetros de enriquecimiento o de destino de la canalización. Para obtener más información, consulte Parámetros de ruta dinámicos

Problemas comunes con la transformación de entradas

Estos son algunos de los problemas más comunes al transformar la entrada en EventBridge tuberías: