에서 스트림에 오브젝트를받습니다 나는 예를 들어 다음 정보를 돌려 Siddhi 락 확장이 : 나는 스트림에서이 정보를 저장 원하는 나는 atribute "clientPublicId"를 사용하여 정보를 필터링 할 {
"licenseKey": "WxyzChXjhJ-dgjfZfHnL9-bWd4e2vxjD-eIs5hDu0To-VOxL111BAj",
"siteU
2 분 동안 화이트리스트를 저장해야하지만 새 스트림이 도착하면 쿼리를 실행해야합니다 (내 화이트리스트 사용). 두 번째 스트림을 다음 코드와 함께 사용하고 있습니다. 2 분마다 업데이트되는 WHITELIST를 충전해야합니다. define trigger periodicalTriggerStream at every 2 min;
from DSB_TEMPORAL
사용자 정의 매핑 된 스트림을 가져 오기 만하면 간단한 siddhi 쿼리를 작성하려고합니다. 그러나 스트림을 가져오고 쿼리의 유효성을 검사하는 즉시 오류가 발생합니다. 내 전체 쿼리는하지만 내가 원하는 건 하나의 분 및 수출 시간 동안 로그 레코드의 수를 계산하고 출력 스트림을 계산하는 것입니다 @Import('bro.in.ssh.log:1.0.0')
d
쿼리로 내 그룹의 결과를 요약하는 데 문제가 있습니다. intermediateStream라는 이름의 내 소스 스트림 데이터있다 ts uid id_resp_h
2016-05-08 08:59 CLuCgz3HHzG7LpLwH9 172.30.26.119
2016-05-08 09:00 C3WnnK3TgUf2cSzxVa 172.30.26.127
를 사용하여 이벤트의 연속 값의 값을 선택할 수 있고, 그 데이터이다 : 하나 ID이다 1,1470732420000,0
2,1470732421000,0
3,1470732422000,0
4,1470732423000,86
5,1470732424000,87
6,1470732425000,88
7,1470732426000,84
8,147073242700
카프카 주제에서 발생한 이벤트를 처리하기 위해 WSO2 CEP를 사용하고 있습니다. 비슷한 형식으로 로그를 저장하는 여러 카프카 항목 (예 : 각 항목의 각 파티션마다 특정 사용자의 데이터가 저장 됨)에 일반화하고자합니다. 시나리오는 다음과 같습니다. 주제는 각 파티션이 해당 그룹에 속한 사람인 수퍼 그룹을 나타냅니다. 각 파티션에는 해당 사용자의 JSON
분당 이벤트 수를 얻기 위해 siddhi query 다음을 사용했습니다. ts는 timestamp (문자열)이고 ftp_requests는 count (int)입니다. from FTPInStream[command == 'USER']
select time:timestampInMilliseconds(time:dateAdd(str:replaceAll(ts,'T'
실행 계획에서 메모리 내장 테이블을 사용하고 있지만 컴파일러가 해당 정의를 묻습니다. 쿼리는 @Import('MAINInStream:1.0.0')
define stream MAINInStream (ts string, uid string, id_orig_h string, id_orig_p int, id_resp_h string, id_resp_p int,
를 사용하고 계십니까? 이미 도착한 이벤트를 기반으로 시간 창이 작동하고 있음을 이해했습니다. 은 GROUP BY 절과 window.timeBatch (2 분)를 사용하는 동안 내가 여러 결과를 얻고, 예를 들어 말. 주어진 2 분 동안 나는 주기적으로 50 개의 입력 이벤트를 통과시켰다. 예상 된 동작은 함께 모아서 하나의 결과로 주어진 모든 이벤트입니다
나는 queshion을 가지고있다. 쿼리를 만들고 "str : contains"함수를 두 가지 이벤트와 함께 사용할 수 있습니까? 예를 들어 교체 : from DSBStream[(str:contains(correlation_phr_incident_detail, '0.0.0.0')==FALSE)]
select *
insert into DSBFiltered