Dans une solution Internet des objets (IoT), les appareils IoT envoient des événements (notifications, accusés de réception, télémétrie) à l’application pour obtenir des insights. Les applications peuvent nécessiter des sous-ensembles spécifiques d’événements à des fins de traitement ou de stockage à des points de terminaison différents. Ces événements peuvent également avoir besoin d’être acheminés vers différents services pour un traitement ultérieur. À mesure que la solution IoT est mise à l’échelle, le nombre d’appareils, le volume d’événements, la diversité des événements et les différents services varient également. Une méthode flexible, évolutive, cohérente et fiable pour le routage des événements est nécessaire au traitement de ce modèle.
Cas d’usage potentiels
Une version commerciale surveille les réfrigérateurs pour la section des aliments surgelés :
- Une alerte est envoyée lorsque la température des réfrigérateurs dépasse un seuil prédéterminé. Une règle d’acheminement peut être créée avec la règle de seuil pour envoyer ces événements spécifiques à un système d’alerte.
- L’équipe de science des données crée un modèle de détection d’anomalies pour identifier les problèmes liés aux réfrigérateurs avant qu’ils ne soient interrompus. Une règle d’acheminement de messages peut envoyer toutes les données de télémétrie brutes à un compte de stockage, spécifiquement pour l’équipe de science des données à utiliser pour l’apprentissage et la modélisation.
Ce scénario s’applique aux secteurs de la vente au détail, de l’énergie et de l’environnement.
Architecture
Téléchargez un fichier Visio de cette architecture.
Dans une plateforme IoT, vous pouvez créer des règles pour le routage affiné des événements. Une ou plusieurs règles peuvent être configurées dans la plateforme IoT. Les règles seront appliquées aux événements d’entrée et sont routées vers le ou les points de terminaison spécifiques.
Caractéristiques
Voici quelques points à prendre en compte lors de l’utilisation de ce modèle.
Débit des points de terminaison : Les points de terminaison qui reçoivent des événements doivent être en mesure de gérer l’entrée des événements envoyés par le biais du routage. Assurez-vous que les services de point de terminaison ont la capacité d’ingérer et de stocker les données jusqu’à ce qu’elles soient consommées.
Format des événements : Pour que le routage soit évolutif et flexible, les événements doivent avoir un format commun pour garantir l’interopérabilité entre les protocoles.
Gestion des événements : Si un événement correspond à plusieurs routes qui pointent vers le même point de terminaison, il ne doit remettre ce message qu’une fois à ce point de terminaison. Il est également important de garantir l’ordonnancement des messages dans de telles situations.
Duplication des événements : Pour gérer les doublons, nous vous recommandons de marquer un identificateur unique dans les propriétés de l’application du message au point d’origine, qui est généralement un appareil ou un module. Le service consommant les messages peut alors gérer les messages en double à l’aide de cet identificateur.
Itinéraire de secours : Les événements qui ne correspondent à aucune règle doivent se trouver dans un itinéraire de secours afin de pouvoir être traités correctement et d’éviter la perte d’aucun événement.
Événements autres que les événements de télémétrie : Les solutions IoT présentent différents types d’événements tels que les modifications d’état des appareils et les événements de cycle de vie des appareils. La route des événements doit être en mesure de capturer et d’appliquer des règles à ces événements distincts des événements de télémétrie pour activer l’automatisation et la surveillance.
Quand utiliser ce modèle :
Envoi des messages de télémétrie de l’appareil, des événements de cycle de vie des appareils ou des événements de changement de représentation d’appareil à des points de terminaison spécifiques déterminés par les règles.
Filtrage des événements en appliquant des règles spécifiques.
Ce modèle n’est pas recommandé pour :
- Le routage basé sur l’analyse de données en temps réel complexe des données de série chronologique. Par exemple, lors de la comparaison des données de télémétrie moyennes de 15 minutes. Si l’analyse des données en temps réel est requise, utilisez un service d’analyse en temps réel pour les données du chemin réactif.