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:
-
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 datos de clústeres de Redshift API
-
SageMaker Canalización
-
SNSTema de Amazon (SNSFIFOtemas no admitidos)
-
SQSCola de Amazon
-
Máquina de estado de Step Functions
-
Flujos de trabajo exprés (SYNCoASYNC)
-
Flujos de trabajo estándar (ASYNC)
-
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 PipeTargetParameters
para 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
InputTemplate
objeto para asegurarse de que los datos están estructurados correctamente. Si desea incluir la carga útil del evento original, haga referencia a ella enInputTemplate
.) -
APIPuerta de enlace (los datos enviados a API Gateway deben coincidir con la estructura de. API Debe usar el
InputTemplate
objeto para asegurarse de que los datos estén estructurados correctamente. Si desea incluir la carga útil del evento original, haga referencia a ella enInputTemplate
.) -
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:
-
"$.data.
para un origen de KinesissomeKey
" -
"$.body.
para una SQS fuente de AmazonsomeKey
"
Entonces, si la carga útil del evento es una JSON cadena válida, por ejemplo{"
, EventBridge extrae el valor de la JSON ruta y lo usa como parámetro de destino. En este ejemplo, EventBridge configuraría Kinesis someKey
":"someValue
"}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 en
REQUEST_RESPONSE
): EventBridge espera una respuesta del objetivo 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 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.