Colas duraderas
Las colas duraderas son colas de ThingWorx Platform que utilizan Apache Kafka (para implementaciones locales) o Azure Event Hubs (para implementaciones en la nube de PTC) como plataforma de transmisión de eventos distribuidos. Estas plataformas sirven como agentes de mensajes y canalizaciones de datos. Externalizan y transfieren las colas en memoria de los nodos de ThingWorx al almacenamiento basado en disco en forma de colas duraderas. Con este proceso, se mejora la mensajería interna en ThingWorx Platform de las siguientes maneras:
• Estabilidad mejorada de ThingWorx con ejecución garantizada como máximo una vez (cada mensaje se entrega una vez o no se entrega) para el procesamiento de estado estable. Con colas duraderas, se garantiza que no haya pérdida de datos debido al desbordamiento.
• Fiabilidad mejorada del procesamiento de eventos y datos si fallan los nodos de ThingWorx. Para obtener más información, consulte Procesamiento por lotes con colas duraderas.
• Reducción a la mitad de la latencia de procesamiento de eventos en comparación con las colas en memoria.
ThingWorx soporta la activación de colas duraderas para lo siguiente:
• Eventos desordenados (eventos suscritos por suscripciones sin estado)
• Propiedades persistentes
• Propiedades registradas
En el siguiente diagrama se muestra el flujo funcional de las colas en memoria frente a las colas duraderas. Para obtener más información acerca de las colas en memoria, consulte Colas en memoria.
Después de activar colas duraderas para eventos, propiedades persistentes o propiedades registradas, las escrituras de propiedades se procesan en la cola duradera y, a continuación, en la cola en memoria.
Colas duraderas en configuraciones de alta disponibilidad
Las colas duraderas también soportan configuraciones de alta disponibilidad (HA). Debe haber una instancia de Apache Kafka o Azure Event Hubs configurada con una configuración de alta disponibilidad. Para obtener más información sobre las configuraciones de alta disponibilidad, consulte Tamaño de colas duraderas.
En el siguiente diagrama se muestra el flujo de flujos de IoT a través de Apache Kafka en un entorno de alta disponibilidad:
Consideraciones importantes
• Solo los eventos sin orden (eventos suscritos por suscripciones sin estado) se insertan en Kafka o Event Hubs. Los eventos con estado se enrutan a los flujos Akka existentes.
• Los eventos y las propiedades persistentes o registrados se consumen como máximo una vez.
• Para Kafka y Event Hubs, la retención de datos es de 24 horas por defecto.
• La plataforma puede conectarse a Kafka, crear temas y enviar y recibir mensajes. Si las colas duraderas están habilitadas, Kafka se considera infraestructura crítica. Si se producen problemas al intentar conectarse a Kafka (por ejemplo, credenciales no coincidentes), ThingWorx Platform no se iniciará.