|
Cada vez es más común utilizar múltiples servicios en la nube como elementos básicos para ensamblar una aplicación moderna basada en eventos. El uso de servicios creados específicamente para realizar una tarea en specific garantiza que los desarrolladores obtengan las mejores capacidades para su caso de uso. Sin embargo, la comunicación entre servicios puede ser difícil si utilizan diferentes tecnologías para comunicarse, lo que significa que debe aprender los matices de cada servicio y cómo integrarlos entre sí. Por lo basic, necesitamos crear un código de integración (o código de “pegamento”) para conectar y unir la comunicación entre los servicios. Escribir código adhesivo cut back nuestra velocidad, aumenta el riesgo de errores y significa que dedicamos nuestro tiempo a escribir código indiferenciado en lugar de crear mejores experiencias para nuestros clientes.
Presentamos las canalizaciones de Amazon EventBridge
Hoy, estoy emocionado de anunciar Tuberías Amazon EventBridgeuna nueva característica de Amazon EventBridge que le facilita la creación de aplicaciones basadas en eventos al proporcionar una manera easy, consistente y rentable de crear integraciones punto a punto entre productores de eventos y consumidores, eliminando la necesidad de escribir código de cola indiferenciado.
La tubería más easy consta de una fuente y un destino. Un paso de filtrado opcional permite que solo los eventos de origen específicos fluyan a la tubería y un paso de enriquecimiento opcional usando AWSLambda, Funciones de pasos de AWS, Destinos de la API de Amazon EventBridgeo Puerta de enlace API de Amazon enriquece o transforma los acontecimientos antes de que alcancen el objetivo. Con Amazon EventBridge Pipes, puede integrar AWS compatibles y servicios autogestionados como productores de eventos y consumidores de eventos en su aplicación de una manera easy, confiable, consistente y rentable.
Amazon EventBridge Pipes trae las características más populares de Autobús de eventos de Amazon EventBridgecomo filtrado de eventos, integración con más de 14 servicios de AWS y reintentos de entrega automáticos.
Cómo funcionan las canalizaciones de Amazon EventBridge
Amazon EventBridge Pipes le brinda un medio perfecto para integrar AWS admitido y servicios autoadministrados, favoreciendo la configuración sobre el código. Para comenzar a integrar servicios con EventBridge Pipes, debe seguir los siguientes pasos:
- Elija una fuente que esté produciendo sus eventos. Las fuentes admitidas incluyen: Amazon DynamoDB, Flujos de datos de Amazon Kinesis, Amazon SQS, Amazon Managed Streaming para Apache Kafkay Amazon MQ (tanto ActiveMQ como RabbitMQ).
- (Opcional) Especifique un filtro de eventos para procesar solo los eventos que coincidan con su filtro (no se le cobra por los eventos que se filtran).
- (Opcional) Transforme y enriquezca sus eventos utilizando transformaciones gratuitas integradas, o AWSLambda, Funciones de pasos de AWS, Puerta de enlace API de Amazono Destinos de la API de EventBridge para realizar transformaciones y enriquecimientos más avanzados.
- Elija un destino objetivo entre más de 14 servicios de AWS, incluidos Amazon Step Features, Kinesis Information Streams, AWS Lambda y API de terceros mediante destinos de API de EventBridge.
Amazon EventBridge Pipes brinda simplicidad para acelerar la velocidad de desarrollo al reducir el tiempo necesario para aprender los servicios y escribir el código de integración, para obtener una integración confiable y consistente.
EventBridge Pipes también viene con funciones adicionales que pueden ayudar a crear aplicaciones basadas en eventos. Por ejemplo, con el filtrado de eventos, Pipes ayuda a que las aplicaciones basadas en eventos sean más rentables al procesar solo los eventos de interés.
Introducción a las tuberías de Amazon EventBridge
Veamos cómo comenzar con Amazon EventBridge Pipes. En esta publicación, mostraré cómo integrar una cola de Amazon SQS con AWS Step Features utilizando Amazon EventBridge Pipes.
La siguiente captura de pantalla es mi cola de Amazon SQS existente y la máquina de estado de AWS Step Features. En mi caso, necesito ejecutar la máquina de estado para cada evento en la cola. Para hacerlo, necesito conectar mi cola de SQS y la máquina de estado de Step Features con EventBridge Pipes.
Primero, abro la consola de Amazon EventBridge. En la sección de navegación, selecciono Tubería. luego selecciono Crear tubería.
En esta página, puedo comenzar a configurar una canalización y establecer el permiso de AWS Id and Entry Administration (IAM), y puedo navegar a la Configuración de tubería pestaña.
En el permisos sección, puedo definir un nuevo rol de IAM para esta tubería o usar un rol existente. Para mejorar la experiencia del desarrollador, la consola de EventBridge Pipes determinará el rol de IAM por mí, por lo que no necesito configurar manualmente los permisos requeridos y dejar que EventBridge Pipes configure los permisos de privilegio mínimo para el rol de IAM. Dado que es la primera vez que creo una tubería, selecciono Crear un nuevo rol para este recurso específico.
Entonces, vuelvo a la tubo de construcción sección. En esta página, puedo ver las fuentes de eventos disponibles compatibles con EventBridge Pipes.
Yo selecciono SQS y seleccione mi cola SQS existente. Si necesito hacer un procesamiento por lotes, puedo seleccionar Ajustes adicionales para empezar a definir Tamaño del lote y Ventana de lote. Luego, selecciono Próximo.
En la página siguiente, las cosas se ponen aún más interesantes porque puedo definir Filtrado de eventos del origen del evento que acabo de seleccionar. Este paso es opcional, pero la función de filtrado de eventos me facilita el procesamiento de eventos que solo necesitan ser procesados por mi aplicación basada en eventos. Además, esta función de filtrado de eventos también me ayuda a ser más rentable, ya que esta canalización no procesará eventos innecesarios. Por ejemplo, si uso Step Features como objetivoel filtrado de eventos solo ejecutará eventos que coincidan con el filtro.
Puedo usar eventos de muestra de Eventos de AWS o definir eventos personalizados. Por ejemplo, quiero procesar eventos para artículos comprados devueltos con un valor de 100 o más. El siguiente es el evento de muestra en formato JSON:
{
"event-type":"RETURN_PURCHASE",
"worth":100
}Entonces, en el patrón de evento sección, puedo definir el patrón haciendo referencia a la Filtrado de contenido en patrones de eventos de Amazon EventBridge documentación. Defino el patrón de evento de la siguiente manera:
{
"event-type": ("RETURN_PURCHASE"),
"worth": ({
"numeric": (">=", 100)
})
}También puedo probar seleccionando patrón de prueba para asegurarme de que este patrón de eventos coincida con el evento personalizado que voy a usar. Una vez que estoy seguro de que este es el patrón de eventos que quiero, selecciono Próximo.
En el siguiente paso opcional, puedo usar un Enriquecimiento que aumentará, transformará o expandirá el evento antes de enviar el evento al destino de destino. Este enriquecimiento es útil cuando necesito enriquecer el evento utilizando una función de AWS Lambda existente o una API de SaaS externa mediante la API de destino. Además, puedo dar forma al evento usando el Transformador de entrada de enriquecimiento.
El paso last es definir un objetivo para procesar los eventos entregados por esta canalización.
Aquí, puedo seleccionar varios servicios de AWS compatibles con EventBridge Pipes.
Selecciono mi máquina de estado de AWS Step Features existente, llamada pipes-statemachine.
Además, también puedo usar Transformador de entrada objetivo al referirse a la Transformación de la entrada de destino de Amazon EventBridge documentación. Para mi caso, necesito definir una alta prioridad para los eventos que se dirigen a este objetivo. Para hacer eso, defino un evento personalizado de muestra en Ejemplos de eventos/Carga de eventos y agrega el precedence: HIGH en el Transformador sección. Luego en el Producción sección, puedo ver el evento last que se pasará al servicio de destino de destino. Luego, selecciono Crear tubería.
En menos de un minuto, mi tubería se creó con éxito.
Para probar esta tubería, necesito poner un evento en la cola de Amaon SQS.
Para comprobar si Step Features procesa correctamente mi evento, puedo consultar mi máquina de estado en Step Features. En esta página, veo que mi evento se procesó con éxito.
También puedo ir a Amazon CloudWatch Logs para obtener registros más detallados.
Cosas que saber
Orígenes de eventos – En el momento del lanzamiento, Amazon EventBridge Pipes admite los siguientes servicios como orígenes de eventos: Amazon DynamoDB, Amazon Kinesis, Amazon Managed Streaming for Apache Kafka (Amazon MSK) junto con Apache Kafka autogestionado, Amazon SQS (estándar y FIFO) y Amazon MQ ( tanto para ActiveMQ como para RabbitMQ).
Objetivos de eventos – Amazon EventBridge Pipes admite 15 destinos de Amazon EventBridge, incluidos AWS Lambda, Amazon API Gateway, Amazon SNS, Amazon SQS y AWS Step Features. Para entregar eventos a cualquier punto last HTTPS, los desarrolladores pueden usar Destinos de la API como el objetivo.
Pedido de eventos – EventBridge Pipes mantiene el orden de los eventos recibidos de un origen de eventos que admite el orden al enviar esos eventos a un servicio de destino.
Acceso programático – También puede interactuar con Amazon EventBridge Pipes y crear una tubería usando Interfaz de línea de comandos (CLI) de AWS, Formación en la nube de AWSy Package de desarrollo de la nube de AWS (AWS CDK).
Uso independiente – EventBridge Pipes se puede usar por separado del bus de Amazon EventBridge y del programador de Amazon EventBridge. Esta flexibilidad ayuda a los desarrolladores a definir eventos de origen de servicios autogestionados y de AWS admitidos como orígenes de eventos sin el bus de eventos de Amazon EventBridge.
Disponibilidad – Amazon EventBridge Pipes ya está disponible de forma basic en todas las regiones comerciales de AWS, con la excepción de Asia Pacífico (Hyderabad) y Europa (Zúrich).
Visita el Tuberías Amazon EventBridge página para obtener más información sobre esta función y comprender los precios. Tú también puedes visita la página de documentación para obtener más información sobre cómo empezar.
¡Feliz edificio!
— Donnie
