설명서 및 소스 코드에서 읽은 내용을 토대로 WSO2CEP는 수동 소프트웨어로 작동하므로 스트림 이벤트가 도착한 경우에만 작동합니다. 따라서 스트림에서 "상태 확인"을 개발하고 싶다면 직접 구현해야합니다. 내 질문은, 누구든지 그것을하는 방법에 대한 첫 걸음을 밟았습니까? 나는 어디서부터 시작 해야할지 모르겠다. InputEventAdapterFactory
WSO2 CEP 4.2.0을 배우려고합니다. Siddhi 쿼리에 문제가 있습니다. 이벤트 처리에 다른 시스템 rdbms 테이블의 데이터를 사용하여 가져올 수 있습니까? WSO2 CEP 문서에서 이벤트 테이블에 대해 알아 냈지만 필요한 것은 아닙니다. 시나리오는 다음과 같습니다. 차량에서 추적 데이터를 받기 위해 WSO2 CEP를 사용합니다. 지리 정보 분석
내 질문은 이와 같습니다. 저는 초당 실시간 데이터에 대한 데이터 소스 액세스를 정의합니다. 평균 계산을 위해이 일괄 처리 데이터를 시간당 평균으로 계산하고 평균 시간당 데이터 그룹을 갖습니다. 누적 합계, 마지막으로 한 시간의 누적 값을 다른 데이터 원본에 저장합니다. 평균 값은 10 시간이고 데이터 원본에 10을 부여하고 두 번째 시간 평균은 20이며
사용자 가이드에 따르면 externalTime 창 (타임 스탬프, 시간 값)은 타임 스탬프에서 타임 스탬프 + 시간 값까지 범위 내에서만 이벤트를 유지해야한다고 가정합니다. 실행 계획 from input
select time:timestampInMilliseconds(time:dateAdd("2016-11-14 19:40:00", 5, 'minute',"
Siddhi CEP 3.1.2를 독립 실행 형 라이브러리로 사용하여 여러 조건에서 콜백 처리기를 올바르게 트리거하는 방법을 시도합니다. 논리 합류 두 이벤트 및 내가 두 이벤트를 제공하는 경우, 다음 내가 콜백 핸들러를 트리거 할 수있는 위로 찾을 수 a AND b 그러나 나는 또한했습니다 이후에 a 또는 b 중 하나를 제공하면 핸들러도 트리거되는 것을 볼
이벤트의 부재 일치 5 분부터 define stream statusStream (id string, success bool);
나는 "실패"하는 모든 오브젝트를 조회 할 (성공 = 거짓 일) : statusStream의 모든 이벤트를 (, false) 이벤트가없는 곳 (같은 id, true). 이러한 종류의 작업에 가장 간단한 siddhi 쿼리는 무엇입
"비즈니스"사용자가 입력 스트림에서 처리 된 데이터에 대한 규칙을 만들고 편집 할 수 있도록 허용해야한다는 요구 사항이 있습니다. 규칙은 비즈니스 친화적이어야하며 개발주기가 없어야합니다. 여기에 내가 생각하고 무엇의 예입니다 : 날씨 스테이션과 연결된 차량 데이터 스트리밍으로 "if weatherStation.id == 100 and weatherStati