Warteschlangenanbieter
In ThingWorx ermöglicht ein Warteschlangenanbieter die Konnektivität zu einem externen Messaging-System. Dies kann für folgende Zwecke verwendet werden:
• Externes Routing von Daten (off ramp) – Dies kann durch die Verwendung eines IoT-Streams erreicht werden, mit dem Sie Daten in ein externes System extrahieren können, um Daten zu archivieren oder Analysen durchzuführen.
ThingWorx 10.0 unterstützt das externe Routing für Eigenschaftswerte.
• Persistente Warteschlangen – Zur Verbesserung der Skalierbarkeit und Zuverlässigkeit interner ThingWorx Meldungen – Dies kann erreicht werden, indem eine vom System bereitgestellte persistente Warteschlange (ThingworxQueueProvider) aktiviert wird.
ThingworxQueueProvider verwaltet die das Einstellen von Ereignissen und Daten innerhalb der Plattform in die Warteschlange. Damit wird sichergestellt, dass Ereignisse in geordneter Weise verarbeitet werden, und Aufgaben wie Ereignisabonnements, Datenströme und Wert-Streams werden verarbeitet.
Durch Verwendung der Systementität ThingworxQueueProvider wird der Puffer interner Warteschlangen im Arbeitsspeicher reduziert, die für Ereignisse und persistente ThingWorx Warteschlangen verwendet werden. Die Arbeitsspeicherbelastung auf dem ThingWorx Server wird dadurch verringert und Datenverluste bei Auftreten eines Serverabsturzes werden minimiert.
 |
Sie können eine vom System bereitgestellte Warteschlangenanbieter-Instanz (ThingworxQueueProvider) so konfigurieren, dass sie sowohl interne als auch externe Meldungen unterstützt.
|
Die anfängliche Implementierung basiert auf dem Open-Source-Client Kafka. Die folgenden Konfigurationen wurden getestet:
• Open-Source-Kafka-Broker
• Microsoft Azure Event Hubs
Da die Implementierung das Kafka-Protokoll verwendet, sollten andere kommerziell erhältliche, mit dem Kafka-Protokoll kompatible Broker funktionieren.
Zugehörige Themen