Event bus e piattaforma di streaming
Jarian è l'event bus e piattaforma di streaming di Niadad che acquisisce, instrada e riproduce gli eventi tra i sistemi in tempo reale.
- Integrazione
- Niadad
- In sviluppo
Problema
Le modifiche importanti (una transazione, un aggiornamento dello stato di un cliente, la lettura di un sensore) restano all'interno del sistema di origine, e gli altri ne vengono a conoscenza in ritardo tramite interrogazioni periodiche. I dati arrivano all'analisi con ore di ritardo e una reazione in tempo reale è impossibile.
Panoramica della piattaforma
Jarian è la spina dorsale event-driven di Niadad: ogni sistema pubblica i propri eventi e i consumatori, da Darya a Bina e Bidar, vi si iscrivono in modo indipendente. Gli eventi sono conservati con uno schema definito e possono essere riprodotti dall'inizio, così che un nuovo consumatore o una ricostruzione dei dati siano sempre possibili.
Capacità chiave
Pubblicazione e sottoscrizione
Disaccoppia produttori e consumatori tramite topic denominati.
Log persistente e riproduzione
Archivia gli eventi con conservazione configurabile e consente la riproduzione da qualsiasi punto.
Schema registry
Versiona la struttura di ogni evento affinché le modifiche non compromettano i consumatori.
Stream processing
Filtraggio, arricchimento, aggregazione a finestre e rilevamento di pattern sui flussi di eventi.
Acquisizione da sensori e dispositivi
Riceve i dati IoT tramite protocolli leggeri e li normalizza in flussi standard.
Connettori
Connettori pronti all'uso per database (CDC), Darya, sistemi di destinazione e API.
Architettura
Event broker con log distribuito
Schema registry e contratti degli eventi
Motore di stream processing
Gateway dei dispositivi e protocolli IoT
Connettori di origine e destinazione
Monitoraggio dei flussi e ritardo dei consumatori
Integrazioni
Casi d'uso
Piattaforme correlate
Soluzioni
Approfondimenti correlati
Costruiamo insieme.
Se la vostra organizzazione, banca o settore è pronto a trasformare i dati in decisioni, avviate qui la conversazione.