Streaming et événements

Aucun événement ne doit se perdre.

Une commande, un état de machine ou une variation de stock doit déclencher d'autres processus. Nous concevons des contrats d'événements et mettons en œuvre la plateforme et les connexions, afin que les destinataires puissent réagir de manière fiable, y compris en cas de pics de charge ou de pannes temporaires.

Ce que nous prenons en charge Discuter du projet

Catalogue d'événements avec schémas et responsables · Planification et mise en œuvre par OTOKO®

Ce que vous confiez à OTOKO®

Ce que nous prenons en charge pour vous.

Un événement décrit un changement survenu ; une instruction demande une action. Cette distinction aide à ne pas mélanger les responsabilités. Nous définissons les identifiants, l'horodatage, le schéma et le contexte nécessaire. L'ordre est considéré au niveau de l'unité pertinente sur le plan métier, par exemple une commande, plutôt que de promettre d'emblée un ordre global. Pour la connexion de machines, les protocoles, les limites réseau et les interventions autorisées sont convenus avec les responsables de l'exploitation.

L'étendue possible des prestations

Catalogue d'événements avec schémas AsyncAPI et registre de schémas
Mise en place de clusters Kafka ou RabbitMQ avec chiffrement, contrôle d'accès et séparation des locataires
Connexion des sources via Debezium, Kafka Connect et des ponts MQTT pour les données machines
Modèles de traitement pour l'ordre, l'idempotence, les nouvelles tentatives et l'event sourcing
Exploitation avec supervision du décalage, du débit et des groupes de consommateurs

Nous définissons le périmètre concret, votre implication et les critères de recette avant le début.

La technique expliquée clairement

Voici comment nous mettons en œuvre la mission.

Prévoir les messages en double et tardifs

Des livraisons répétées peuvent survenir après des incidents. Les consommateurs reçoivent donc des règles pour reconnaître les événements déjà traités ou les retraiter sans conséquence sur le plan métier. Les événements tardifs et les corrections ultérieures sont pris en compte séparément. Nous planifions la conservation, le rejeu et la protection des accès. Une plateforme d'événements n'est pas automatiquement une archive immuable ; les exigences de conservation et de suppression doivent être mises en œuvre de manière délibérée. La compatibilité des changements de schéma avec les consommateurs existants est vérifiée.

Tester l'arriéré et le rattrapage

La recette comprend la panne d'un consommateur, un arriéré croissant et un redémarrage contrôlé. Les tableaux de bord montrent le retard et les erreurs, pas seulement le nombre de messages reçus. Pour démarrer, nous avons besoin des types d'événements, des volumes attendus, du retard maximal et du traitement métier de l'ordre ou du traitement en double.

Salle de réunion dans les bureaux d'OTOKO® à Cologne

Un résultat vérifiable

La base pour poursuivre votre travail.

Catalogue d'événements avec schémas et responsables
Plateforme d'événements opérationnelle sous forme de code
Directive de traitement avec modèles et exemples

Le transfert relie la mise en œuvre et la documentation. Nous vérifions ensemble les cas convenus et consignons les tâches restantes.

Votre projet en détail

Diffuser et analyser les événements métier de façon fiable.

Nous développons des connexions événementielles pour les processus devant réagir à des changements. Nous planifions non seulement le transport, mais aussi la signification, l'ordre et le retraitement des événements.

Décrire les événements comme des énoncés métier

Un événement indique que quelque chose s'est produit, par exemple une commande confirmée. Nous convenons d'un identifiant, d'un horodatage, d'un contexte métier et de règles de version. Les consommateurs doivent pouvoir reconnaître s'ils ont déjà traité le même message et si un événement contient suffisamment d'informations pour leur usage.

L'ordre n'est souvent requis qu'au sein d'un objet métier déterminé. Cette exigence influence le partitionnement et le parallélisme. Nous évitons les promesses générales d'un ordre global ou d'un traitement métier effectué une seule fois, et vérifions à la place les garanties de l'ensemble de la chaîne, y compris le système cible.

Maîtriser l'arriéré, les nouvelles tentatives et la conservation des données

Un consommateur lent ne doit pas prendre du retard indéfiniment sans être détecté. Nous surveillons les retards et planifions comment augmenter la capacité ou prioriser le traitement. Les messages en erreur disposent d'une voie de résolution, afin qu'un seul enregistrement problématique ne bloque pas durablement l'ensemble du traitement.

La possibilité de retraiter les événements est précieuse pour les corrections et les nouveaux consommateurs, mais nécessite des règles de conservation et de protection des données. Nous définissons quels événements historiques restent disponibles et comment reconstruire l'ensemble de données cible. La recette examine explicitement les interruptions, la livraison en double et le redémarrage d'un consommateur.

Scénario de projet illustratif

Comment le service aide au quotidien.

Exemple : une commande confirmée déclenche la préparation de l'expédition et une notification au client. Les deux consommateurs traitent l'événement indépendamment. Si la notification échoue, la commande est conservée ; après la reprise, l'identifiant de l'opération empêche que le même message soit envoyé plusieurs fois de façon non contrôlée.

Cet exemple explique un déroulement possible et ne constitue pas une référence client.

Avant la première étape

Vos questions sur Streaming et événements.

Un broker garantit-il qu'un message n'est traité qu'une seule fois sur le plan métier ?

Pas à lui seul. Les garanties de la plateforme s'appliquent dans certaines limites. Dès que des systèmes externes sont modifiés, l'application doit traiter de manière appropriée les traitements en double et les nouvelles tentatives.

Peut-on connecter les données machine sans accès direct à la production ?

Des passerelles ou des voies d'exportation existantes sont souvent possibles. La voie retenue est examinée et validée avec les responsables de l'environnement de production.

Votre projet

Quelle problématique souhaitez-vous résoudre ?

Décrivez votre situation de départ et le résultat souhaité. Le service sélectionné est repris dans votre demande de contact.

Demander ce service

Menu

Aucun événement ne doit se perdre.