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.
Destinos de canalizaciones de Amazon EventBridge
Puede enviar los datos de la canalización a un destino específico. Puede configurar los siguientes destinos al configurar una canalización en EventBridge:
-
Bus de eventos en la misma cuenta y región
-
Flujo de entrega de Firehose
-
Plantilla de evaluación del inspector
-
Flujo de Kinesis
-
Consultas de API de datos de clústeres de Redshift
-
Canalización de SageMaker AI
-
Tema de Amazon SNS (no se admiten temas FIFO de Amazon SNS)
-
Cola de Amazon SQS
-
Máquina de estado de Step Functions
-
Flujos de trabajo rápido (SYNC o ASYNC)
-
Flujos de trabajo estándar (ASYNC)
-
Parámetros de destino
Algunos servicios de destino no envían la carga del evento al destino, sino que tratan el evento como un desencadenante para invocar una API específica. EventBridge utiliza los PipeTargetParameters para especificar qué información se envía a esa API. Estos incluyen los siguientes:
-
Destinos de la API (Los datos enviados a un destino de la API deben coincidir con la estructura de la API. Debe usar el objeto
InputTemplatepara asegurarse de que los datos estén estructurados correctamente. Si desea incluir la carga del evento original, haga referencia a ella en el objetoInputTemplate.) -
API Gateway (Los datos enviados a API Gateway deben coincidir con la estructura de la API. Debe usar el objeto
InputTemplatepara asegurarse de que los datos estén estructurados correctamente. Si desea incluir la carga del evento original, haga referencia a ella en el objetoInputTemplate.) -
PipeTargetRedshiftDataParameters(Clústeres de API de datos de Amazon Redshift) -
PipeTargetSageMakerPipelineParameters(Canalizaciones de creación de modelos de tiempo de ejecución de Amazon SageMaker) -
PipeTargetBatchJobParameters(AWS Batch)
nota
EventBridge no admite toda la sintaxis de ruta JSON 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
Los parámetros de destino de las canalizaciones de EventBridge admiten sintaxis de ruta JSON dinámica opcional. Puede usar esta sintaxis para especificar rutas JSON en lugar de valores estáticos (por ejemplo, $.detail.state). El valor completo debe ser una ruta JSON, 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 rutas JSON con parámetros dinámicos es la misma que cuando se transforma la entrada. Para obtener más información, consulte Transformación de entradas de canalizaciones de Amazon EventBridge.
La sintaxis dinámica se puede utilizar en todos los campos de cadena y no enumeración de todos los parámetros de enriquecimiento y destino de las canalizaciones de EventBridge, excepto:
Por ejemplo, para establecer la PartitionKey de un destino de Kinesis de canalización en una clave personalizada del evento de origen, defina KinesiTargetParameter.PartitionKey en:
-
"$.data.para un origen de KinesissomeKey" -
"$.body.para un origen de Amazon SQSsomeKey"
A continuación, si la carga del evento es una cadena JSON válida, por ejemplo, {", EventBridge extrae el valor de la ruta JSON y lo utiliza como parámetro de destino. En este ejemplo, EventBridge establecería la someKey":"someValue"}PartitionKey de Kinesis en "someValue».
Permisos
Para realizar llamadas a la API en los recursos que posee, las canalizaciones de EventBridge necesitan los permisos adecuados. Las canalizaciones de EventBridge utilizan el rol de IAM que usted especifique en la canalización para llamadas de enriquecimiento y destino utilizando la entidad principal de IAM pipes.amazonaws.com.
Invocación de destinos
EventBridge tiene las siguientes formas de invocar un destino:
-
De forma sincrónica (tipo de invocación establecido en
REQUEST_RESPONSE): EventBridge espera una respuesta del destino antes de continuar. -
De forma asíncrona (tipo de invocación establecido en
FIRE_AND_FORGET): EventBridge no espera una respuesta para continuar.
De forma predeterminada, en el caso de las canalizaciones con orígenes ordenados, EventBridge invoca los destinos de forma sincrónica, ya que se necesita una respuesta del destino antes de pasar al siguiente evento.
Si un origen no impone un orden, como una cola estándar de Amazon SQS, 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.
Aspectos específicos de los destinos de las colas de trabajo de AWS Batch
Todos los parámetros AWS Batch submitJob se configuran de forma explícita con BatchParameters y, como ocurre con todos los parámetros de canalización, pueden ser dinámicos usando una ruta JSON con la carga del evento entrante.
Aspectos específicos de los destinos del grupo de registro de CloudWatch
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 todos los parámetros de canalización, estos parámetros pueden ser dinámicos cuando se usa una ruta JSON con la carga del evento entrante.
Aspectos específicos de los destinos de la tarea de Amazon ECS
Todos los parámetros runTask e Amazon ECS se configuran de forma explícita mediante EcsParameters. Como todos los parámetros de canalización, estos parámetros pueden ser dinámicos cuando se usa una ruta JSON con la carga del evento entrante.
Aspectos específicos de los destinos de las funciones de Lambda y los flujos de trabajo de Step Functions
Lambda y Step Functions no tienen una API de lotes. Para procesar lotes de eventos de un origen de canalización, el lote se convierte en una matriz JSON y se transfiere como entrada al destino de Lambda o Step Functions. Para obtener más información, consulte Procesamiento por lotes y simultaneidad de canalizaciones de Amazon EventBridge.
Aspectos específicos de los destinos de la tabla de Timestream para análisis en tiempo real
Las consideraciones a la hora de especificar una tabla de Timestream para análisis en tiempo real como destino de canalización incluyen:
-
Actualmente, los flujos de Apache Kafka (incluidos los de proveedores de Amazon MSK o externos) no se admiten como origen de canalización.
-
Si ha especificado un flujo de Kinesis o DynamoDB como origen 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.