대기열 공급자
ThingWorx에서 대기열 공급자는 외부 메시징 시스템과의 연결을 가능하게 합니다. 이는 다음과 같은 용도로 사용할 수 있습니다.
ThingWorx 10.0은 속성 값에 대한 외부 라우팅을 지원합니다.
• 내구성 대기열 - ThingWorx 내부 메시지의 확장성과 신뢰성을 개선하기 위한 기능입니다. 이는 시스템 제공 내구성 대기열(ThingworxQueueProvider)을 활성화하여 달성할 수 있습니다.
ThingworxQueueProvider는 플랫폼 내에서 이벤트 및 데이터의 대기열을 관리합니다. 이를 통해 이벤트가 순차적으로 처리되며, 이벤트 구독, 데이터 스트림, 가치 스트림과 같은 작업이 원활하게 수행됩니다.
ThingworxQueueProvider 시스템 엔티티를 사용하면 이벤트 및 지속성 ThingWorx 대기열에 사용되는 내부 메모리 내 대기열의 버퍼가 줄어듭니다. 이를 통해 ThingWorx 서버의 메모리 부담이 줄어들고 서버 장애 발생 시 데이터 손실이 최소화됩니다.
 |
내부 메시지와 외부 메시지를 모두 지원하도록 하나의 시스템 제공 대기열 공급자 인스턴스(ThingworxQueueProvider)를 구성할 수 있습니다.
|
초기 구현은 오픈 소스 Kafka 클라이언트를 기반으로 합니다. 다음 구성이 테스트되었습니다.
• 오픈 소스 Kafka 브로커
• Microsoft Azure Event Hubs
구현에 Kafka 프로토콜을 사용하므로 다른 상용 Kafka 프로토콜 호환 브로커도 작동해야 합니다.
관련 항목
• IoT 스트림