siddhi

0열

1답변

WSO2 DAS로 작업하고 있습니다. 나는 2 개의 스트림을 가지고있다. (S1과 S2로 2 개의 스트림을 호출하자.) 나는 SQL Left Join과 같이 그것들에 합류하고 싶습니다. 더 많은 정보를 원하면, S1과 S2를 합치면 S1의 모든 데이터와 S2의 관련 데이터로 출력을 구성합니다. WSO2 Siddhi가 Left Join에 대한 스포츠가 아니기

0열

1답변

DAS 스트림에서 NULL 값을 선택하십시오.

여러 속성이있는 스트림이 있습니다. 스트림의 이름이 "MyStream"이라고 가정하고 실행 계획에 "my"으로 가져옵니다. 속성 이름은 "A"및 "B"입니다. "B"속성은 NULL 값을 가질 수 있습니다. 나는 ""와 "B"모두를 선택하려는 "B"NULL입니다. 벨로우즈 코드를 시험해 봅니다. FROM my[B is null] SELECT A as A,

0열

1답변

siddhi 스냅 샷 개념의 이해

쿼리 및 실행 계획을 가지고 있으므로 스냅 샷을 찍어서 수신 측에서 복원하고 다시 실행하기를 원합니다. 수신자에게 어떤 형식으로 보내야합니까? 수신자 측에서 복원하는 방법은 무엇입니까? 다음은 Siddhi 저장소에서 가져온 일부 코드입니다. SiddhiManager siddhiManager = new SiddhiManager(); String qu

1열

1답변

Siddhi : 일괄 처리 창에서 지정된 기간 동안 조건을 만족하는 이벤트를 확인하는 방법

Siddhi에서 지정된 기간 동안 이벤트 조건이 충족되는지 확인하는 쿼리를 작성하려고했습니다. , 내가 사용하는 5 분 의 배치 시간 쿼리를 사용하여 출력 스트림에 밀어 시간의 지정된 기간 동안 20보다 항상 커야 온도를 필요 온도 이벤트 스트림 : 다음은 요구 사항입니다 했다 : 위 쿼리에서 이벤트 스트림 sensorStream=[tempID1,190.8

0열

1답변

선택 이벤트

나는이 스트림이 있습니다 define stream locationStream (cell string, device string, power long); 나는 '셀의 모든 장치에 대한 값 10 초 슬라이딩 창으로,이 스트림에 선택합니다 '속성이 가장 큰 속성입니다. Siddhi에서이 결과를 얻으려면 어떤 쿼리를 사용해야합니까? from locationSt

1열

1답변

WSO2 CEP Siddhi의 단일 인스턴스에서 여러 개의 코어를 사용할 수 있습니까?

8 코어가있는 Linux 컴퓨터에서 실행되는 WSO2 CEP의 인스턴스가 있습니다. 거의 200 개의 실행 계획이있는 30-40 개의 입력 스트림이 있습니다. 내 문제는 이벤트를 삽입 할 때 한 번에 하나의 CPU 만 사용 중입니다. 바쁜 핵심 변경 사항이지만 동시에 성능과 확장성에 영향을 미치는 8 개의 코어를 동시에 작동시킬 수는 없습니다. 누락 된 구

0열

1답변

timeserie에서 값 목록의 비율 변화를 찾을 수있는 가장 좋은 방법은 어느

나는 시계열 데이터의 일련의 delay(10) espData=[value,100,1513298528793] delay(10) espData=[value,110,1513298528803] delay(10) espData=[value,120,1513298528813] delay(10) espData=[value,130,1513298528823]

0열

1답변

이 실행 계획은 필요한 것을 수행합니까?

저는 실제로 Wso2와 Siddhi가 처음입니다. 먼저, 내가 뭘하려고하는지 설명하겠습니다. 두 개의 스트림 (RG 및 MW)을 조인하고 쿼리 결과를 (OutStream)에 삽입하려고합니다. 판독 값> 임계 값을 갖는 센서의 이름을 얻으려고합니다. 아래는 나의 예심이다. 내가 (OutStream) UI 퍼블리셔를 정의하려고 시도했을 때 내가하려고하는 일이

0열

1답변

Siddhi - 특정 시간 내에 업데이트되지 않는 이벤트 테이블에서 가져 오기

Siddhi 쿼리에서 두 개의 스트림 S1과 S2를 가져옵니다. S1 스트림을 수신하면 이벤트 테이블 T1에 삽입하고 S2를 수신하면 ID를 기반으로 T1 테이블을 업데이트하고 테이블의 업데이트 된 값을 출력 스트림 O1에 보냅니다. 요구 사항의 일부로 5 분 전에 삽입되는 테이블 T1 (즉, 레코드가 5 분 이상있는 경우)을 가져 와서 다른 출력 스트림

0열

1답변

wso2 cep Siddhiql

여러 센서가 측정 이벤트를 스트림으로 보냅니다. 이벤트는 {매개 변수, 값, 시간 소인}으로 구성됩니다. 며칠 동안이 값을 관찰하고 추세를 확인하고 이러한 여러 센서로 모니터링되는 장비에 대한 진단을하고 싶습니다. 스트림을 매개 변수로 나눕니다. from inputStream[parameter='A'] select * inser