¿Qué es un suscriptor de eventos?

En la arquitectura basada en eventos (EDA), un suscriptor de eventos es una aplicación, servicio, dispositivo o persona que decide recibir información sobre un evento específico o una clase de eventos. También conocidos como "consumidores de eventos", los suscriptores de eventos reciben mensajes sobre eventos "escuchando" y sondeando continuamente en busca de cambios relacionados con determinados temas, áreas o mensajes de eventos. Cuando un suscriptor de eventos recibe información sobre un evento, puede procesar y responder a la información de varias maneras, por ejemplo, actualizar una base de datos, enviar un correo electrónico, añadir un objeto a un depósito de almacenamiento o indicar un flujo de trabajo.

La arquitectura basada en eventos (EDA) es un patrón de diseño de software que permite a los sistemas detectar, procesar y organizar eventos, además de reaccionar a ellos, en tiempo real a medida que se producen. Un evento es un cambio en el estado de cualquier sistema o proceso empresarial en particular. En la arquitectura basada en eventos, los suscriptores de eventos pueden obtener información sobre un evento en el instante en que se produce, lo que permite que las aplicaciones, los sistemas, las personas y las organizaciones reaccionen en tiempo real. Esta arquitectura a menudo utiliza espacios de nombres para organizar clases de eventos y métodos de suscriptores de eventos, lo que garantiza una base de código limpia y que se puede mantener.

Un evento es algo que ha sucedido. Hay un cambio de estado. Entre los eventos se incluye, por ejemplo, una compra de un cliente, una solicitud de información, actualizaciones de inventario, lecturas de sensores que pueden indicar una filtración de seguridad, un artículo eliminado de un carrito de la compra, la creación de una nueva cuenta de usuario o la notificación de que los precios de unas acciones alcanzan un determinado umbral.

La arquitectura basada en eventos comprende varios componentes de hardware y software que están conectados y organizados para permitir la comunicación en tiempo real sobre los eventos.

Los editores de eventos, también conocidos como productores de eventos, son sistemas que detectan o generan un evento y publican la información en un bus o canal de eventos. Los editores de eventos están diseñados para reconocer cuándo cambia un estado. Los editores de eventos incluyen sistemas como bases de datos que publican eventos cuando los datos cambian, microservicios que indican la finalización de acciones, dispositivos del Internet de las cosas (IoT) que indican cuándo se han producido acciones o las condiciones han cambiado, y sistemas de CRM que envían notificaciones cuando se cumplen pedidos o se registran nuevos usuarios.

Los buses de eventos, también conocidos como canales de eventos o agentes de eventos, es el lugar donde se carga y descarga la información sobre eventos. Los buses de eventos reciben datos en tiempo real de los editores de eventos y ponen la información a disposición de los suscriptores de eventos que escuchan eventos específicos. Los buses de eventos también se conocen como streams de eventos o colas de mensajes e incluyen plataformas como Apache Kafka, Amazon Kinesis y Google Pub/Sub.

Los suscriptores de eventos, también conocidos como oyentes de eventos o consumidores de eventos, son aplicaciones, servicios, dispositivos o personas que reciben mensajes sobre eventos. Las diferentes clases de suscriptores están diseñadas para recibir información sobre eventos específicos o clases de eventos. Los suscriptores de eventos suelen configurarse para recibir datos de eventos tan pronto como estén disponibles.

Los eventos afectan a todos los aspectos de una organización, así como a sus procesos y operaciones. Cuando las empresas y sus empleados, aplicaciones y sistemas pueden reaccionar a los eventos con mayor rapidez, la productividad, la eficiencia y la competitividad pueden aumentar. Al configurar a los suscriptores de eventos para que reciban información sobre una amplia gama de eventos críticos para el negocio, las organizaciones pueden operar de forma más eficaz y satisfactoria.

Los suscriptores de eventos reciben, procesan y responden a los eventos de diversas formas.

• Notificación directa: en algunos casos, los editores de eventos envían eventos directamente a los suscriptores sin el uso de un bus de eventos o un agente.
• Modelo de extracción: los suscriptores también pueden optar por comprobar o extraer periódicamente eventos nuevos de una cola en la que estén interesados, lo que permite el procesamiento por lotes y el balanceo de carga. Sin embargo, este modelo puede introducir retrasos en el procesamiento de eventos.
• Pub/sub: En una infraestructura de publicación/suscripción, la mensajería se envía a los consumidores de eventos que se han suscrito a canales de eventos específicos a través de un agente de mensajes. Los agentes reciben mensajes de eventos, los traducen cuando es necesario, mantienen los mensajes organizados, envían mensajes a los suscriptores para que los consuman y eliminan mensajes. En este modelo, los eventos no se pueden reproducir, por lo que los suscriptores de eventos no pueden acceder a los eventos de forma retroactiva.
• Streaming de eventos: con un enfoque de streaming de eventos, los eventos se escriben en un registro, y todos los suscriptores de eventos pueden acceder a los eventos desde cualquier parte del streaming, incluidos los eventos anteriores. El streaming de eventos suele gestionarse mediante una plataforma de streaming que puede gestionar el registro y la transmisión de grandes volúmenes de eventos con un rendimiento muy alto, a menudo hasta billones de eventos al día. Las plataformas de streaming permiten la persistencia de eventos, en la que se conservan los registros durante un periodo de tiempo específico. Las plataformas de streaming también gestionan el procesamiento de eventos complejos, en el que los suscriptores consumen y procesan una serie de eventos para identificar tendencias o condiciones específicas.

Un suscriptor de eventos puede consumir una amplia variedad de eventos que van desde muy simples hasta muy complejos. Estos pueden incluir:

• Transacciones empresariales: estos eventos están relacionados con procesos empresariales, como un cliente que se registra en Internet, realiza un pedido, completa un pago o cambia el estado de un pedido.
• Acciones del usuario: generadas por los usuarios con una aplicación o sistema, estas acciones incluyen clics, envíos de formularios, actividades de inicio de sesión/cierre de sesión o navegación en la página.
• Notificaciones: ciertos eventos se generan para notificar a otras partes del sistema o a sistemas externos y pueden incluir acciones como enviar un correo electrónico, activar alertas o generar informes.
• Eventos del sistema: estos eventos se producen dentro del sistema y se activan por cosas como la finalización de un proceso, las actualizaciones de los datos, los errores del sistema o el inicio de tareas programadas.
• Entradas de sensores: en las aplicaciones del IoT, los eventos pueden generarse mediante datos de sensores relacionados con cosas como cambios de temperatura, detección de movimiento o actualizaciones de ubicación.
• Fuentes de datos: estos eventos se originan a partir de actualizaciones de datos, como cambios en una base de datos, nuevas entradas en un archivo de registro o actualizaciones de fuentes de datos externas, como API o feeds.
• Procesamiento de streaming: el procesamiento de flujos de datos en tiempo real puede generar eventos relacionados con la supervisión de los precios de las acciones, el análisis de publicaciones en redes sociales o el seguimiento de análisis en tiempo real.
• Cambios de estado: algunos eventos se generan por cambios en el estado de los objetos o entidades dentro del sistema, por ejemplo, cambiar un pedido de "pendiente" a "enviado" o actualizar el estado de un ticket en un sistema de seguimiento.
• Eventos del ciclo de vida: estos eventos se refieren al ciclo de vida de los componentes del sistema, como el inicio o el cierre de los servicios, la implementación de nuevas versiones o las comprobaciones de estado.
• Eventos de integración: las interacciones de diferentes sistemas o servicios pueden generar eventos que se utilizan para sincronizar datos o activar acciones a través de los límites del sistema.