Jarian Event BusIntégrationZS023000

Bus d'événements et plateforme de streaming

Jarian est le bus d'événements et la plateforme de streaming de Niadad, qui capture, achemine et rejoue les événements entre les systèmes en temps réel.

Famille
Intégration
Propriétaire
Niadad
Statut
En développement

Problématique

Les changements importants (une transaction, une mise à jour du statut d'un client, un relevé de capteur) restent enfermés dans le système source, et les autres n'en sont informés que tardivement par interrogation périodique. Les données parviennent à l'analytique avec des heures de retard, et toute réaction en temps réel est impossible.

Vue d'ensemble de la plateforme

Jarian est la colonne vertébrale événementielle de Niadad : chaque système publie ses événements, et les consommateurs, de Darya à Bina et Bidar, s'y abonnent indépendamment. Les événements sont conservés selon un schéma défini et peuvent être rejoués depuis le début, si bien qu'un nouveau consommateur ou une reconstruction des données reste toujours possible.

Capacités clés

Publication et abonnement

Découple producteurs et consommateurs au moyen de topics nommés.

Journal durable et rejeu

Stocke les événements avec une rétention configurable et permet de les rejouer depuis n'importe quel point.

Registre de schémas

Versionne la structure de chaque événement afin que les modifications ne cassent pas les consommateurs.

Traitement de flux

Filtrage, enrichissement, agrégation par fenêtres et détection de motifs sur les flux d'événements.

Ingestion depuis les capteurs et les équipements

Reçoit les données IoT via des protocoles légers et les normalise en flux standard.

Connecteurs

Connecteurs prêts à l'emploi pour les bases de données (CDC), Darya, les systèmes cibles et les API.

Architecture

01

Courtier d'événements avec journal distribué

02

Registre de schémas et contrats d'événements

03

Moteur de traitement de flux

04

Passerelle d'équipements et protocoles IoT

05

Connecteurs source et destination

06

Supervision des flux et retard des consommateurs

Intégrations

Darya (ingestion en flux)
Payam (files de travail)
Bina (événements de vision)
Bidar (incidents et supervision)
Capteurs et contrôleurs IoT (MQTT)
Bases de données via CDC

Cas d'usage

Streaming des données des capteurs agricoles
Événements de vision issus du stationnement intelligent
Synchronisation des modifications client entre les systèmes
Alimentation en temps réel du data lake
Détection de motifs et alertes en temps réel

Exemples de projets

Plateformes associées

Solutions

Perspectives associées

Construisons ensemble.

Si votre organisation, votre banque ou votre secteur est prêt à transformer les données en décisions, engagez la conversation ici.