TecTop
|
|
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 particular 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 general, 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 reduce 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 simple, 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 simple consta de una fuente y un destino. Un paso de filtrado opcional permite que solo los eventos de origen específicos fluyan a la canalización y un paso de enriquecimiento opcional que utiliza AWS Lambda, AWS Step Functions, Amazon EventBridge API Destinations o Amazon API Gateway enriquece o transforma los eventos 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 simple, confiable, consistente y rentable.
Amazon EventBridge Pipes ofrece las características más populares de Amazon EventBridge Event Bus, como el filtrado de eventos, la integración con más de 14 servicios de AWS y los 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, Amazon Kinesis Data Streams, Amazon SQS, Amazon Managed Streaming para Apache Kafka y 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 AWS Lambda, AWS Step Functions, Amazon API Gateway o EventBridge API Destinations para realizar transformaciones y enriquecimientos más avanzados.
- Elija un destino objetivo entre más de 14 servicios de AWS, incluidos Amazon Step Functions, Kinesis Data 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 Functions 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 Functions. 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 Functions 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 Identity and Access Management (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 Functions 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",
"value":100
}Entonces, en el patrón de evento sección, puedo definir el patrón consultando el filtrado de contenido en la documentación de patrones de eventos de Amazon EventBridge. Defino el patrón de evento de la siguiente manera:
{
"event-type": ["RETURN_PURCHASE"],
"value": [{
"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 final 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 Functions existente, llamada pipes-statemachine.
Además, también puedo usar Transformador de entrada objetivo consultando la documentación de entrada de destino de Transformación de Amazon EventBridge. 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 priority: HIGH en el Transformador sección. Entonces en el Producción sección, puedo ver el evento final 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 Functions procesa correctamente mi evento, puedo consultar mi máquina de estado en Step Functions. 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 Functions. Para entregar eventos a cualquier punto final HTTPS, los desarrolladores pueden usar destinos API como destino.
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 mediante AWS Command Line Interface (CLI), AWS CloudFormation y AWS Cloud Development Kit (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 general en todas las regiones comerciales de AWS, con la excepción de Asia Pacífico (Hyderabad) y Europa (Zúrich).
Visite la página de Amazon EventBridge Pipes para obtener más información sobre esta función y comprender los precios. También puede visitar la página de documentación para obtener más información sobre cómo comenzar.
¡Feliz edificio!
— Donnie
