Activator 규칙에서 여러 스트림을 결합하는 방법

이 문서에서는 다음 방법을 보여줍니다.

활성화기 규칙을 정의하여 여러 이벤트 스트림의 데이터를 모니터링하고 작업을 자동화합니다.
Activator 모델링 기능을 사용하여 데이터 속성의 평균, 최대값 또는 최소값과 같은 여러 고급 조건을 설정합니다.

Scenario

이 예제에서는 컴퓨터의 흐름 속도 및 진동 을 모니터링하여 물 펌프(컴퓨터)의 상태를 추적할 수 있습니다. 목표는 머신이 실행되는 동안 진동이 비정상적이고 상당한 양의 물(FlowRate)을 이동하는 경우 경고를 보내거나 비즈니스 프로세스를 시작하는 것과 같은 조치를 자동으로 수행하는 것입니다. 물 펌프 진동이 높으면 근본적인 문제를 알릴 수 있지만 FlowRate가 중요하지 않은 한 예상됩니다.

데이터의 흐름을 모니터링하는 기계는 두 개의 이벤트 스트림으로 데이터를 보냅니다.

MachineHeartbeat eventstream에는 기계를 식별하는 MachineId 열과 기기가 실행 중인지 여부를 나타내는 MachineRunning 열이 포함되어 있으며 실행 중인 경우 1, 실행 중이 아닌 경우 0입니다. 컴퓨터 상태가 변경될 때마다 이벤트가 내보내집니다.
MachineSensorsReadings eventstream에는 FlowRate 및 Vibration 열과 함께 MachineId 열이 포함되어 있습니다. 모든 컴퓨터는 몇 초마다 센서 판독값을 내보낸다.

이 시나리오에서는 이러한 모든 조건이 true인 경우 경고를 발생하려고 합니다.

지난 1시간 동안의 최대 진동 은 18보다 높습니다.
지난 10분 동안의 평균 흐름 속도 는 185를 초과합니다.
컴퓨터가 실행 중입니다.

활성화자 규칙은 여러 이벤트 스트림을 기반으로 복잡한 조건을 지원합니다. 이벤트 열을 기반으로 계산된 속성을 만들고 규칙 조건에서 결합할 수 있습니다.

이 시나리오에서는 두 스트림에서 피드하는 개체 를 만들어 두 개의 eventstream을 함께 가져옵니다. 개체에 eventstream을 추가할 때 개체의 인스턴스를 고유하게 식별하는 이벤트의 열을 지정합니다.

그런 다음 평균(FlowRate)을 계산하는 속성과 max(Vibration)을 위한 속성을 각각 만들고, 그런 다음 이러한 속성을 IsRunning 속성과 결합합니다. 규칙을 평가할 때 Activator는 정의에 따라 속성 값을 계산하고 모든 속성의 마지막 계산 값을 유지 관리합니다. 이러한 값은 조건을 평가할 때 사용됩니다.

활성화기 규칙에서 하나의 조건을 설정해야 하며, 예를 들어 max(Vibration) > 18과 같은 조건을 설정하고 avg(FlowRate) > 185 및 MachineRunning 같은 선택적 필터를 추가해야 합니다. 필터도 true인 경우 조건이 충족될 때 규칙이 실행됩니다.

조건은 다음 그림과 같이 규칙을 구동합니다.

해결 방법

두 이벤트 스트림 모두에 Activator 대상을 추가합니다. 두 이벤트 스트림이 동일한 Activator 인스턴스를 사용하는지 확인합니다.

두 이벤트 스트림은 동일한 Activator 대상으로 구성됩니다.
활성화자 항목을 엽니다. 이제 두 이벤트 스트림을 개체에 결합하고 규칙을 설정할 수 있습니다.
이러한 두 스트림을 결합하려면 스트림을 선택하고 새 개체를 선택합니다.
규칙에 필요한 개체 및 열의 인스턴스를 식별하는 데 사용되는 열 이름을 선택한 다음 만들기를 선택합니다. 각 이벤트의 MachineId 열 값은 이벤트를 내보낸 컴퓨터를 식별하는 키입니다.
다른 이벤트 스트림을 선택하고 새 개체를 선택한 다음 빌드 개체 창에서 기존 개체에 추가를 선택합니다. MachineId 열을 고유 식별자로 선택합니다. 할당을 선택합니다. 이제 두 스트림이 하나의 개체로 결합됩니다.
이제 계산된 속성을 정의할 수 있습니다. 지난 10분 동안 FlowRate 의 컴퓨팅 평균에 대한 특성을 만듭니다. FlowRate 특성을 선택하고 세부 정보 편집을 선택합니다.
정의 창에서 요약 추가를 선택하고, 평균을 선택하고, 10분을 창 크기로 설정합니다. 저장을 선택합니다.
진동 특성을 선택하고 세부 정보 편집을 선택합니다. 정의 창에서 요약 추가를 선택하고, 최대값을 선택하고, 1시간을 창 크기로 설정합니다. 저장을 선택합니다.
이제 규칙을 만듭니다. 진동 속성을 선택하고 새 규칙을 선택합니다.
정의 창에서 18을 임계값으로 사용하여 위의 증가 조건을 설정합니다.
FlowRate 속성에 대한 필터와 MachineRunning 속성에 대한 필터를 추가합니다.
전자 메일 또는 Teams 메시지 보내기, 파이프라인, 전자 필기장 또는 함수와 같은 비즈니스 프로세스 실행 또는 Power Automate를 사용하여 코드 없는 사용자 지정 작업 실행 등 원하는 작업을 선택합니다. 저장 후 시작을 선택합니다.