Jarian Event BusIntegrationZS023000

Event-Bus und Streaming-Plattform

Jarian ist der Event-Bus und die Streaming-Plattform von Niadad, die Ereignisse systemübergreifend in Echtzeit erfasst, weiterleitet und wiedergibt.

Familie
Integration
Eigentümer
Niadad
Status
In Entwicklung

Problemstellung

Wichtige Änderungen (eine Transaktion, eine Statusänderung eines Kunden, ein Sensorwert) bleiben im Quellsystem, und andere erfahren davon erst verspätet durch periodisches Abfragen. Daten erreichen die Analytik mit Stunden Verzögerung, und eine Reaktion in Echtzeit ist unmöglich.

Plattformübersicht

Jarian ist das ereignisgesteuerte Rückgrat von Niadad: Jedes System veröffentlicht seine Ereignisse, und Konsumenten von Darya bis Bina und Bidar abonnieren sie unabhängig voneinander. Ereignisse werden mit definiertem Schema gespeichert und können von Anfang an wiedergegeben werden, sodass ein neuer Konsument oder ein Neuaufbau der Daten jederzeit möglich ist.

Kernfunktionen

Publish and Subscribe

Entkoppelt Produzenten und Konsumenten über benannte Topics.

Dauerhaftes Log und Wiedergabe

Speichert Ereignisse mit konfigurierbarer Aufbewahrungsdauer und ermöglicht die Wiedergabe ab jedem beliebigen Punkt.

Schema Registry

Versioniert die Struktur jedes Events, damit Änderungen Konsumenten nicht beeinträchtigen.

Stream-Verarbeitung

Filterung, Anreicherung, fensterbasierte Aggregation und Mustererkennung auf Event-Streams.

Erfassung von Sensoren und Geräten

Empfängt IoT-Daten über leichtgewichtige Protokolle und normalisiert sie in Standard-Streams.

Konnektoren

Vorgefertigte Konnektoren für Datenbanken (CDC), Darya, Zielsysteme und APIs.

Architektur

01

Event-Broker mit verteiltem Log

02

Schema Registry und Event-Verträge

03

Stream-Processing-Engine

04

Geräte-Gateway und IoT-Protokolle

05

Quell- und Ziel-Konnektoren

06

Stream-Monitoring und Consumer-Lag

Integrationen

Darya (Streaming-Erfassung)
Payam (Arbeitswarteschlangen)
Bina (Vision-Ereignisse)
Bidar (Vorfälle und Monitoring)
IoT-Sensoren und -Controller (MQTT)
Datenbanken per CDC

Anwendungsfälle

Streaming von Sensordaten aus landwirtschaftlichen Betrieben
Vision-Ereignisse aus dem Smart Parking
Synchronisierung von Kundenänderungen über Systeme hinweg
Echtzeit-Einspeisung in den Data Lake
Mustererkennung und Alarme in Echtzeit

Lassen Sie uns gemeinsam bauen.

Wenn Ihre Organisation, Ihre Bank oder Ihre Branche bereit ist, Daten in Entscheidungen zu verwandeln, beginnen Sie das Gespräch hier.