Objetivos de Amazon EventBridge Pipes - Amazon EventBridge

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.

Objetivos de Amazon EventBridge Pipes

Puede enviar los datos de la canalización a un destino específico. Puede configurar los siguientes objetivos al configurar una tubería en EventBridge:

Parámetros de destino

Algunos servicios de destino no envían la carga útil del evento al destino, sino que tratan el evento como un desencadenante para invocar algo específico. API EventBridge usa el PipeTargetParameterspara especificar qué información se envía a ese destino. API Estos incluyen los siguientes:

  • APIdestinos (los datos enviados a un API destino deben coincidir con la estructura delAPI. Debe usar el InputTemplateobjeto para asegurarse de que los datos están estructurados correctamente. Si desea incluir la carga útil del evento original, haga referencia a ella en InputTemplate.)

  • APIPuerta de enlace (los datos enviados a API Gateway deben coincidir con la estructura de. API Debe usar el InputTemplateobjeto para asegurarse de que los datos estén estructurados correctamente. Si desea incluir la carga útil del evento original, haga referencia a ella en InputTemplate.)

  • PipeTargetRedshiftDataParameters(clústeres de datos API de Amazon Redshift)

  • PipeTargetSageMakerPipelineParameters(Amazon SageMaker Runtime Model Building Pipelines)

  • PipeTargetBatchJobParameters (AWS Batch)

nota

EventBridge no admite toda la sintaxis de JSON Path y la evalúa en tiempo de ejecución. La sintaxis admitida incluye:

  • notación de puntos (por ejemplo, $.detail)

  • guiones

  • guiones bajos

  • Caracteres alfanuméricos

  • índices de matrices

  • caracteres comodín (*)

Parámetros de ruta dinámicos

EventBridge Los parámetros de destino de Pipes admiten la sintaxis de JSON ruta dinámica opcional. Puede usar esta sintaxis para especificar JSON rutas en lugar de valores estáticos (por ejemplo$.detail.state). El valor completo debe ser una JSON ruta, no solo una parte de ella. Por ejemplo, RedshiftParameters.Sql puede ser $.detail.state, pero no puede ser "SELECT * FROM $.detail.state". Estas rutas se sustituyen dinámicamente en tiempo de ejecución por datos de la propia carga del evento en la ruta especificada. Los parámetros de ruta dinámicos no pueden hacer referencia a valores nuevos o transformados que resulten de la transformación de entrada. La sintaxis admitida para las JSON rutas de parámetros dinámicos es la misma que cuando se transforma la entrada. Para obtener más información, consulte Transformación EventBridge de entradas de Amazon Pipes.

La sintaxis dinámica se puede utilizar en todos los campos de cadena y sin enumeración de todos los parámetros de enriquecimiento y destino de EventBridge Pipes, excepto:

Por ejemplo, para establecer el objetivo PartitionKey de un canal de Kinesis en una clave personalizada del evento de origen, defina el. KinesisTargetParameter PartitionKeypara:

  • "$.data.someKey" para un origen de Kinesis

  • "$.body.someKey"para una SQS fuente de Amazon

Entonces, si la carga útil del evento es una JSON cadena válida, por ejemplo{"someKey":"someValue"}, EventBridge extrae el valor de la JSON ruta y lo usa como parámetro de destino. En este ejemplo, EventBridge configuraría Kinesis PartitionKey en»someValue".

Permisos

Para realizar API llamadas a los recursos de su propiedad, EventBridge Pipes necesita el permiso adecuado. EventBridge PIpesusa el IAM rol que especifiques en el proceso de enriquecimiento y dirige las llamadas utilizando el IAM principalpipes.amazonaws.com.

Invocación de destinos

EventBridge tiene las siguientes formas de invocar un objetivo:

  • Sincrónicamente (tipo de invocación establecido enREQUEST_RESPONSE): EventBridge espera una respuesta del objetivo antes de continuar.

  • De forma asíncrona (tipo de invocación establecido enFIRE_AND_FORGET): EventBridge no espera una respuesta para continuar.

De forma predeterminada, en el caso de las canalizaciones con fuentes ordenadas, EventBridge invoca los destinos de forma sincrónica, ya que se necesita una respuesta del destino antes de pasar al siguiente evento.

Si una fuente no hace cumplir el orden, como una SQS cola estándar de Amazon, EventBridge puede invocar un destino compatible de forma sincrónica o asíncrona.

Con las funciones de Lambda y las máquinas de estado Step Functions, puede configurar el tipo de invocación.

nota

Para las máquinas de estado Step Functions, los flujos de trabajo estándar se deben invocar de forma asíncrona.

AWS Batch las colas de trabajos se centran en aspectos específicos

Todos los AWS Batch submitJob parámetros se configuran de forma explícita yBatchParameters, como ocurre con todos los parámetros de Pipe, pueden ser dinámicos mediante una JSON ruta a la carga útil del evento entrante.

CloudWatch Registra las especificaciones del objetivo del grupo

Tanto si utiliza un transformador de entrada como si no, la carga del evento se utiliza como mensaje de registro. Puede configurar el Timestamp (o el LogStreamName explícito del destino) mediante CloudWatchLogsParameters en PipeTarget. Como ocurre con todos los parámetros de canalización, estos parámetros pueden ser dinámicos cuando se utiliza una JSON ruta a la carga útil del evento entrante.

Detalles específicos del objetivo de ECS tareas de Amazon

Todos los ECS runTask parámetros de Amazon se configuran de forma explícita medianteEcsParameters. Como ocurre con todos los parámetros de canalización, estos parámetros pueden ser dinámicos cuando se utiliza una JSON ruta a la carga útil del evento entrante.

Características específicas del objetivo del flujo de trabajo de las funciones Lambda y Step Functions

Lambda y Step Functions no tienen un lote. API Para procesar lotes de eventos de una fuente canalizada, el lote se convierte en una JSON matriz y se pasa como entrada al destino de Lambda o Step Functions. Para obtener más información, consulte Procesamiento por lotes y simultaneidad de Amazon EventBridge Pipes.

Timestream para obtener información específica sobre los objetivos LiveAnalytics de la tabla

A la hora de especificar una LiveAnalytics tabla Timestream de formulario como objetivo de tubería, se incluyen las siguientes:

  • Actualmente, las transmisiones de Apache Kafka (incluidas las de proveedores externos Amazon MSK o de terceros) no se admiten como fuente canalizada.

  • Si ha especificado una DynamoDB transmisión Kinesis o como fuente de canalización, debe especificar el número de reintentos.

    Para obtener más información, consulte Configuración de los ajustes de la canalización.