Creando una EventBridge pipa de Amazon - Amazon EventBridge
Especificación de un origenConfiguración del filtradoDefinición del enriquecimientoConfiguración de un destinoConfiguración de los ajustes de la canalizaciónValidación de los parámetros de configuración

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.

Creando una EventBridge pipa de Amazon

EventBridge Pipes le permite crear point-to-point integraciones entre las fuentes y los destinos, incluidas las transformaciones y el enriquecimiento avanzados de los eventos. Para crear una EventBridge tubería, lleve a cabo los siguientes pasos:

  1. Especificación de un origen

  2. Configuración del filtrado de eventos (opcional)

  3. Definición del enriquecimiento de eventos (opcional)

  4. Configuración de un destino

  5. Configuración de los ajustes de la canalización

Para obtener información sobre cómo crear una tubería utilizando el AWS CLI, consulte create-pipe en la Referencia de AWS CLIcomandos.

Especificación de un origen

Para empezar, especifique el origen desde el que desea que la canalización reciba los eventos.

Para especificar un origen de la canalización mediante la consola

  1. Abre la EventBridge consola de Amazon en https://console.aws.amazon.com/events/.

  2. En el panel de navegación, seleccione Canalizaciones.

  3. Seleccione Crear canalización.

  4. Escriba un nombre para la canalización.

  5. (Opcional) Agregue una descripción de la canalización.

  6. En la pestaña Crear canalización, en Origen, seleccione el tipo de origen que desee especificar para esta canalización y configure el origen.

    Las propiedades de configuración difieren en función del tipo de origen que seleccione:

    Confluent
    Para configurar una transmisión de Confluent Cloud como fuente, mediante la consola

    1. En Source, elija Confluent Cloud.

    2. En Servidores de arranque, introduzca el par de direcciones host:port de sus agentes.

    3. En Nombre de tema, introduzca el nombre del tema desde donde leerá la canalización.

    4. (Opcional) Para VPC, elija el VPC que desee. A continuación, para VPClas subredes, elija las subredes que desee. Para los grupos VPC de seguridad, elija los grupos de seguridad.

    5. Para la autenticación (opcional), active Usar autenticación y haga lo siguiente:

      1. En Método de autenticación, seleccione el tipo de autenticación.

      2. En Clave secreta, seleccione la clave secreta.

      Para obtener más información, consulte Autenticarse en los recursos de Confluent Cloud en la documentación de Confluent.

    6. (Opcional) En Configuración adicional: opcional, haga lo siguiente:

      1. En Posición inicial, seleccione una de las siguientes opciones:

        • Última: comience a leer el flujo con el registro más reciente de la partición.

        • Recortar horizonte: comience a leer el flujo con el último registro sin recortar de la partición. Este es el registro más antiguo de la partición.

      2. En Tamaño de lote: opcional, introduzca un número máximo de registros para cada lote. El valor predeterminado es 100.

      3. En Ventana de lote: opcional, introduzca un número máximo de segundos para recopilar los registros antes de continuar.

    DynamoDB

    1. En Origen, seleccione DynamoDB.

    2. En flujo de DynamoDB, seleccione el flujo que desee usar como origen.

    3. En Posición inicial, seleccione una de las siguientes opciones:

      • Última: comience a leer el flujo con el registro más reciente de la partición.

      • Recortar horizonte: comience a leer el flujo con el último registro sin recortar de la partición. Este es el registro más antiguo de la partición.

    4. (Opcional) En Configuración adicional: opcional, haga lo siguiente:

      1. En Tamaño de lote: opcional, introduzca un número máximo de registros para cada lote. El valor predeterminado es 100.

      2. En Ventana de lote: opcional, introduzca un número máximo de segundos para recopilar los registros antes de continuar.

      3. En Lotes simultáneos por partición: opcional, introduzca el número de lotes de la misma partición que se pueden leer al mismo tiempo.

      4. En Fallo parcial de elementos del lote, seleccione lo siguiente:

        • AUTOMATIC_ BISECT — Reduzca cada lote a la mitad y vuelva a intentarlo cada mitad hasta que se hayan procesado todos los registros o quede un mensaje fallido en el lote.

        nota

        Si no selecciona AUTOMATIC_ BISECT, puede devolver determinados registros fallidos y solo se volverán a intentar esos registros.

    Kinesis
    Para configurar un origen de Kinesis con la consola

    1. En Origen, seleccione Kinesis.

    2. En Flujo de Kinesis, seleccione el flujo que desee usar como origen.

    3. En Posición inicial, seleccione una de las siguientes opciones:

      • Última: comience a leer el flujo con el registro más reciente de la partición.

      • Recortar horizonte: comience a leer el flujo con el último registro sin recortar de la partición. Este es el registro más antiguo de la partición.

      • En marca de tiempo: comience a leer el flujo a partir de una hora específica. En Timestamp, introduce un dato y una hora con los formatos YYYY /MM/DD y hh:mm:ss.

    4. (Opcional) En Configuración adicional: opcional, haga lo siguiente:

      1. En Tamaño de lote: opcional, introduzca un número máximo de registros para cada lote. El valor predeterminado es 100.

      2. (Opcional) En Ventana de lote: opcional, introduzca un número máximo de segundos para recopilar los registros antes de continuar.

      3. En Lotes simultáneos por partición: opcional, introduzca el número de lotes de la misma partición que se pueden leer al mismo tiempo.

      4. En Fallo parcial de elementos del lote, seleccione lo siguiente:

        • AUTOMATIC_ BISECT — Divida cada lote por la mitad y vuelva a intentarlo cada mitad hasta que se hayan procesado todos los registros o quede un mensaje de error en el lote.

        nota

        Si no selecciona AUTOMATIC_ BISECT, puede devolver determinados registros fallidos y solo se volverán a intentar esos registros.

    Amazon MQ
    Para configurar un origen de Amazon MQ con la consola

    1. En Tipo de origen, seleccione Amazon MQ.

    2. En agente de Amazon MQ, seleccione el flujo que desee usar como origen.

    3. En Nombre de cola, introduzca el nombre de la cola desde donde leerá la canalización.

    4. En Método de autenticación, elija BASIC_ AUTH.

    5. En Clave secreta, seleccione la clave secreta.

    6. (Opcional) En Configuración adicional: opcional, haga lo siguiente:

      1. En Tamaño de lote: opcional, introduzca un número máximo de mensajes para cada lote. El valor predeterminado es 100.

      2. En Ventana de lote: opcional, introduzca un número máximo de segundos para recopilar los registros antes de continuar.

    Amazon MSK
    Para configurar una MSK fuente de Amazon mediante la consola

    1. En Source, elige Amazon MSK.

    2. Para el MSKclúster de Amazon, elige el clúster que quieres usar.

    3. En Nombre de tema, introduzca el nombre del tema desde donde leerá la canalización.

    4. (Opcional) En ID del grupo de consumidores: opcional, introduzca el ID de un grupo de consumidores al que desea que se una la canalización.

    5. (Opcional) En Autenticación: opcional, active Usar autenticación y haga lo siguiente:

      1. En Método de autenticación, seleccione el tipo que desees.

      2. En Clave secreta, seleccione la clave secreta.

    6. (Opcional) En Configuración adicional: opcional, haga lo siguiente:

      1. En Tamaño de lote: opcional, introduzca un número máximo de registros para cada lote. El valor predeterminado es 100.

      2. En Ventana de lote: opcional, introduzca un número máximo de segundos para recopilar los registros antes de continuar.

      3. En Posición inicial, seleccione una de las siguientes opciones:

        • Última: comience a leer el tema con el registro más reciente de la partición.

        • Recortar horizonte: comience a leer el tema con el último registro sin recortar de la partición. Este es el registro más antiguo de la partición.

          nota

          Recortar horizonte es lo mismo que Primero para Apache Kafka.

    Self managed Apache Kafka
    Para configurar una origen de Apache Kafka autogestionado mediante la consola

    1. En Origen, seleccione Apache Kafka autogestionado.

    2. En Servidores de arranque, introduzca el par de direcciones host:port de sus agentes.

    3. En Nombre de tema, introduzca el nombre del tema desde donde leerá la canalización.

    4. (Opcional) Para VPC, elige el VPC que desees. A continuación, para VPClas subredes, elija las subredes que desee. Para los grupos VPC de seguridad, elija los grupos de seguridad.

    5. (Opcional) En Autenticación: opcional, active Usar autenticación y haga lo siguiente:

      1. En Método de autenticación, seleccione el tipo de autenticación.

      2. En Clave secreta, seleccione la clave secreta.

    6. (Opcional) En Configuración adicional: opcional, haga lo siguiente:

      1. En Posición inicial, seleccione una de las siguientes opciones:

        • Última: comience a leer el flujo con el registro más reciente de la partición.

        • Recortar horizonte: comience a leer el flujo con el último registro sin recortar de la partición. Este es el registro más antiguo de la partición.

      2. En Tamaño de lote: opcional, introduzca un número máximo de registros para cada lote. El valor predeterminado es 100.

      3. En Ventana de lote: opcional, introduzca un número máximo de segundos para recopilar los registros antes de continuar.

    Amazon SQS
    Para configurar una SQS fuente de Amazon mediante la consola

    1. En Source (Origen), elija SQS.

    2. Para la SQScola, elige la cola que quieres usar.

    3. (Opcional) En Configuración adicional: opcional, haga lo siguiente:

      1. En Tamaño de lote: opcional, introduzca un número máximo de registros para cada lote. El valor predeterminado es 100.

      2. En Ventana de lote: opcional, introduzca un número máximo de segundos para recopilar los registros antes de continuar.

Configuración del filtrado de eventos (opcional)

Puede añadir filtros a su canalización de forma que solo envíe un subconjunto de eventos del origen al destino.

Para configurar el filtrado mediante la consola

  1. Seleccione Filtrado.

  2. En Evento de muestra: opcional, verá un evento de muestra que puede usar para crear su patrón de eventos, o puede introducir su propio evento seleccionando Introduce el suyo.

  3. En Patrón de eventos, introduce el patrón de eventos que quiere usar para filtrar los eventos. Para obtener más información sobre la construcción de filtros, consulte. Filtrado de eventos en Amazon EventBridge Pipes

    A continuación se muestra un ejemplo de patrón de eventos que solo envía eventos con el valor Seattle en el campo Ciudad.

    {
  "data": {
    "City": ["Seattle"]
  }
}

Ahora que se están filtrando los eventos, puede añadir un enriquecimiento opcional y un destino para la canalización.

Definición del enriquecimiento de eventos (opcional)

Puede enviar los datos del evento para su enriquecimiento a una función Lambda, a una máquina de estado AWS Step Functions , a API Amazon Gateway o a un destino. API

Para seleccionar el enriquecimiento

  1. Seleccione Enriquecimiento.

  2. En Detalles, en Servicio, seleccione el servicio y la configuración relacionada que desee usar para el enriquecimiento.

También puede transformar los datos antes de enviarlos para su enriquecimiento.

(Opcional) Para definir el transformador de entrada

  1. Seleccione Transformador de entrada de enriquecimiento: opcional.

  2. En Eventos de muestra/Carga de evento, seleccione el tipo de evento de muestra.

  3. En Transformador, introduzca la sintaxis del transformador, por ejemplo "Event happened at <$.detail.field>.", donde <$.detail.field> es una referencia a un campo del evento de muestra. También puede hacer doble clic en un campo del evento de muestra para añadirlo al transformador.

  4. En Salida, compruebe que la salida tenga el aspecto que desea.

Ahora que los datos se han filtrado y enriquecido, debe definir un destino al que enviar los datos del evento.

Configuración de un destino

Para configurar un destino

  1. Seleccione Destino.

  2. En Detalles, en Servicio de destino, seleccione el destino. Los campos mostrados varían en función del destino que seleccione. Introduzca la información específica de este tipo de destino, según sea necesario.

También puede transformar los datos antes de enviarlos al destino.

(Opcional) Para definir el transformador de entrada

  1. Seleccione Transformador de entrada de destino: opcional.

  2. En Eventos de muestra/Carga de evento, seleccione el tipo de evento de muestra.

  3. En Transformador, introduzca la sintaxis del transformador, por ejemplo "Event happened at <$.detail.field>.", donde <$.detail.field> es una referencia a un campo del evento de muestra. También puede hacer doble clic en un campo del evento de muestra para añadirlo al transformador.

  4. En Salida, compruebe que la salida tenga el aspecto que desea.

Ahora que la canalización está configurada, asegúrese de que sus ajustes estén configurados correctamente.

Configuración de los ajustes de la canalización

Una canalización está activa por defecto, pero puede desactivarla. También puede especificar los permisos de la canalización, configurar el registro de la canalización y añadir etiquetas.

Para configurar los ajustes de la canalización

  1. Seleccione la pestaña Ajustes de la canalización.

  2. Por defecto, las canalizaciones recién creadas están activas desde su creación. Si quiere crear una canalización inactiva, en Activación, en Activar canalización, desactive la opción Activa.

  3. En Permisos, en Rol de ejecución, realice una de las siguientes acciones:

    1. Para EventBridge crear una nueva función de ejecución para esta canalización, elija Crear una nueva función para este recurso específico. En Nombre del rol, si lo desea, puede editar el nombre del rol.

    2. Para usar un rol de ejecución existente, seleccione Usar un rol existente. En Nombre del rol, seleccione el rol.

  4. (Opcional) Si ha especificado un DynamoDB flujo Kinesis o como fuente de canalización, puede configurar una política de reintentos y una cola de mensajes sin salida (). DLQ

    En Política de reintentos y cola de mensajes fallidos: opcional, haga lo siguiente:

    En Política de reintentos, haga lo siguiente:

    1. Si quieres activar las políticas de reintentos, active Reintento. De forma predeterminada, las canalizaciones recién creadas no tienen activada la política de reintentos.

    2. En Antigüedad máxima del evento, introduzca un valor entre un minuto (00:01) y 24 horas (24:00).

    3. En Cantidad de reintentos, indique un número entre 0 y 185.

    4. Si quieres usar una cola de letras sin salida (DLQ), activa la cola de letras sin salida, elige el método que prefieras y elige la cola o el tema que quieres usar. De forma predeterminada, las canalizaciones recién creadas no utilizan un. DLQ

  5. Elija la forma KMS key EventBridge que desee utilizar al cifrar los datos de la tubería.

    Para obtener más información sobre cómo se EventBridge usa KMS keys, consulteCifrado en reposo.

    • Elija Usar Clave propiedad de AWS EventBridge para cifrar los datos mediante un Clave propiedad de AWS.

      Clave propiedad de AWS Es una KMS key que EventBridge posee y administra para su uso en varias AWS cuentas. En general, a menos que tenga que auditar o controlar la clave de cifrado que protege sus recursos, an Clave propiedad de AWS es una buena opción.

      Esta es la opción predeterminada.

    • Elija Usar clave administrada por el cliente EventBridge para cifrar los datos con la clave administrada por el cliente que especifique o cree.

      Claves administradas por el cliente están KMS keys en la AWS cuenta que usted crea, posee y administra. Tienes el control total sobre ellas KMS keys.

      1. Especifique uno existente clave administrada por el cliente o elija Crear uno nuevo KMS key.

        EventBridge muestra el estado de la clave y cualquier alias clave que se haya asociado a lo especificado clave administrada por el cliente.

  6. (Opcional) En Registros: opcional, puede configurar la forma en que las canalizaciones de EventBridge envían la información de registro a los servicios compatibles, incluida la forma de configurar esos registros.

    Para obtener más información sobre los registros de canalizaciones, consulte Registro del rendimiento de Amazon EventBridge Pipes.

    CloudWatch los registros se seleccionan como destino de registro de forma predeterminada, al igual que el nivel de ERROR registro. Por lo tanto, de forma predeterminada, EventBridge Pipes crea un nuevo grupo de CloudWatch registros al que envía los registros que contienen el ERROR nivel de detalle.

    Para que EventBridge Pipes envíe los registros de registro a cualquiera de los destinos de registro compatibles, haga lo siguiente:

    1. En Registros: opcional, seleccione los destinos a los que quiere que se envíen los registros.

    2. En Nivel de registro, elija el nivel de información EventBridge que desee incluir en los registros de registro. El nivel de registro de ERROR está seleccionado de forma predeterminada.

      Para obtener más información, consulte Especificar el nivel EventBridge de registro de Pipes.

    3. Seleccione Incluir datos de ejecución si EventBridge desea incluir la información de carga útil del evento y la información de solicitud y respuesta de servicio en los registros.

      Para obtener más información, consulte Incluir datos de ejecución en los registros EventBridge de Pipes.

    4. Configure cada destino de registro que haya seleccionado:

      En el CloudWatch Logs caso de los registros, en CloudWatch los registros, haga lo siguiente:

      • Para el grupo de CloudWatch registros, elija si desea EventBridge crear un nuevo grupo de registros o puede seleccionar un grupo de registros existente o especificar el ARN de un grupo de registros existente.

      • Para los grupos de registro nuevos, edite el nombre del grupo de registro según desee.

      CloudWatch los registros están seleccionados de forma predeterminada.

      Para los registros de Firehose transmisión, en registro de Firehose transmisión, seleccione la Firehose transmisión.

      En el Amazon S3 caso de los registros, en S3 logs, haga lo siguiente:

      • Introduzca el nombre del bucket que utilizará como destino del registro.

      • Introduzca el ID de AWS cuenta del propietario del bucket.

      • Introduzca el texto de prefijo que desee utilizar cuando EventBridge crea objetos S3.

        Para obtener más información, consulte Organizar objetos mediante prefijos en la Guía del usuario de Amazon Simple Storage Service .

      • Elige cómo quieres EventBridge formatear los registros de S3:

  7. (Opcional) En Etiquetas; opcional, seleccione Añadir etiqueta nueva e introduzca una o varias etiquetas para la regla. Para obtener más información, consulte Recursos de etiquetado en Amazon EventBridge.

  8. Seleccione Crear canalización.

Validación de los parámetros de configuración

Tras crear una tubería, EventBridge valida los siguientes parámetros de configuración:

  • IAMrol: dado que la fuente de una tubería no se puede cambiar una vez creada la tubería, EventBridge verifica que la IAM función proporcionada pueda acceder a la fuente.

    nota

    EventBridge no realiza la misma validación para los enriquecimientos o los objetivos, ya que se pueden actualizar una vez creada la canalización.

  • Procesamiento por lotes: EventBridge valida que el tamaño del lote de la fuente no supere el tamaño máximo del lote del objetivo. Si lo hace, EventBridge requiere un tamaño de lote inferior. Además, si un destino no admite el procesamiento por lotes, no puede configurar el procesamiento por lotes EventBridge para el origen.

  • Enriquecimientos: EventBridge valida que el tamaño de lote para los enriquecimientos de API Gateway y API destino sea 1, ya que solo se admiten lotes de 1.