Files d'attente durables
Les files d'attente durables sont des files d'attente dans ThingWorx Platform qui utilisent Apache Kafka (pour les déploiements sur site) ou Azure Event Hubs (pour les déploiements dans le Cloud PTC) comme plateforme de streaming d'événements distribuée. Ces plates-formes servent de courtiers de messages et de pipelines de données. Elles externalisent et transfèrent les files d'attente en mémoire des noeuds ThingWorx vers un stockage sur disque sous la forme de files d'attente durables. Ce processus améliore la messagerie interne dans ThingWorx Platform des manières suivantes :
• Amélioration de la stabilité de ThingWorx avec une garantie d'exécution en mode AMO (au maximum une fois : chaque message est remis une fois ou pas du tout) pour le traitement en état stable. Des files d'attente durables garantissent l'absence de perte de données due à un débordement.
• Fiabilité accrue du traitement des événements et des données en cas de défaillance des noeuds ThingWorx. Pour plus d'informations, consultez la rubrique Traitement par lots avec des files d'attente durables.
• Réduction de moitié de la latence de traitement des événements par rapport aux files d'attente en mémoire.
ThingWorx prend en charge les files d'attente durables pour les éléments suivants :
• Evénements non ordonnés (événements souscrits par des abonnements sans état)
• Propriétés persistantes
• Propriétés journalisées
Le diagramme suivant illustre le flux fonctionnel des files d'attente en mémoire par rapport aux files d'attente durables. Pour plus d'informations sur les files d'attente en mémoire, consultez la rubrique Files d'attente en mémoire.
Après l'activation des files d'attente durables pour les événements, les propriétés persistantes ou les propriétés journalisées, les écritures de propriétés sont traitées dans la file d'attente durable, puis dans la file d'attente en mémoire.
Files d'attente durables dans les configurations haute disponibilité
Les files d'attente durables prennent également en charge les configurations haute disponibilité. Une instance d'Apache Kafka ou Azure Event Hubs doit être configurée avec une configuration haute disponibilité. Pour plus d'informations sur les configurations haute disponibilité, consultez la rubrique Dimensionnement de files d'attente durables.
Le diagramme suivant illustre des flux IoT via Apache Kafka dans un environnement haute disponibilité :
Aspects importants
• Seuls les événements non ordonnés (souscrits par des abonnements sans état) sont envoyés à Kafka ou à Event Hubs. Les événements avec état sont routés vers les flux Akka existants.
• Les événements et les propriétés persistantes ou journalisées sont consommés au maximum une fois.
• Pour Kafka et Event Hubs, la conservation des données est de 24 heures par défaut.
• La plateforme peut se connecter à Kafka, créer des rubriques, et envoyer et recevoir des messages. Si des files d'attente durables sont activées, Kafka est considéré comme une infrastructure critique. Si des problèmes surviennent lors de la tentative de connexion à Kafka (tels que des informations d'identification incohérentes), ThingWorx Platform ne démarrera pas.