Jarian Event BusIntegraciónZS023000

Bus de eventos y plataforma de streaming

Jarian es el bus de eventos y la plataforma de streaming de Niadad que captura, enruta y reproduce eventos entre sistemas en tiempo real.

Familia
Integración
Propietario
Niadad
Estado
En desarrollo

Problema

Los cambios importantes (una transacción, una actualización del estado de un cliente, una lectura de sensor) se quedan dentro del sistema de origen, y los demás se enteran tarde mediante consultas periódicas. Los datos llegan a la analítica con horas de retraso y reaccionar en tiempo real resulta imposible.

Visión general de la plataforma

Jarian es la columna vertebral orientada a eventos de Niadad: cada sistema publica sus eventos y los consumidores, desde Darya hasta Bina y Bidar, se suscriben de forma independiente. Los eventos se conservan con un esquema definido y pueden reproducirse desde el principio, de modo que siempre es posible incorporar un nuevo consumidor o reconstruir los datos.

Capacidades clave

Publicación y suscripción

Desacopla productores y consumidores mediante temas con nombre.

Registro persistente y reproducción

Almacena los eventos con una retención configurable y permite reproducirlos desde cualquier punto.

Registro de esquemas

Versiona la estructura de cada evento para que los cambios no rompan a los consumidores.

Procesamiento de flujos

Filtrado, enriquecimiento, agregación por ventanas y detección de patrones en flujos de eventos.

Ingesta desde sensores y dispositivos

Recibe datos IoT mediante protocolos ligeros y los normaliza en flujos estándar.

Conectores

Conectores predefinidos para bases de datos (CDC), Darya, sistemas de destino y API.

Arquitectura

01

Bróker de eventos con registro distribuido

02

Registro de esquemas y contratos de eventos

03

Motor de procesamiento de flujos

04

Pasarela de dispositivos y protocolos IoT

05

Conectores de origen y destino

06

Monitorización de flujos y retraso de los consumidores

Integraciones

Darya (ingesta en streaming)
Payam (colas de trabajo)
Bina (eventos de visión)
Bidar (incidentes y monitorización)
Sensores y controladores IoT (MQTT)
Bases de datos mediante CDC

Casos de uso

Streaming de datos de sensores agrícolas
Eventos de visión del aparcamiento inteligente
Sincronización de los cambios de clientes entre sistemas
Alimentación en tiempo real del data lake
Detección de patrones y alertas en tiempo real

Construyamos juntos.

Si su organización, banco o sector está preparado para convertir los datos en decisiones, inicie la conversación aquí.