complex-event-processing

0열

1답변

소스가 24 시간 이상 시스템에 이벤트를 보내지 않았을 때를 감지하고 싶습니다. 이 패턴이 인식되면, 소스가 무언가를 보낸 마지막 알 수있는 이벤트 (일 수 있음)를 검색 할 수 있기를 원합니다. 나는이 수표가 24 시간마다하고 싶다. 나는 'ATM'유형 예제를 따라 갔고 다음과 같이 간단하게 만들었다. 패턴 [모든에서 선택 a.value (시간 : 간격

2열

1답변

이벤트 처리 프레임 워크 권장 사항

이벤트 처리 도메인을 처음 사용했습니다. 내 요구 사항에 대한 자바 기반 이벤트 처리 프레임 워크를 찾고있다. 아파치 스톰 (Apache Storm), 아파치 카프카 (Apache Kafka), 래빗 맥스 (RabbitMQ)와 같은 전통적인 이벤트 중개인들과 같은 Myriad 프레임 워크에서 문서 및 튜토리얼 미로를 살펴 보았습니다. 나는 더 현명하지 않다

0열

1답변

Esper는 적절한 쿼리와 이벤트를 어떻게 일치합니까?

스트리밍 이벤트 처리에 ESPER를 사용하고 있습니다. 다음과 같이 명세서를 작성한 다음 CEP 엔진에 추가합니다. 대량의 데이터 (분당 백만 건의 이벤트)를 처리하는 데 적합한 방법입니까? cepRT.sendEvent() 어떻게 에스퍼 그것을 평가해야 쿼리에 이벤트를지도 않습니다 Configuration cepConfig = new Configurat

0열

3답변

복잡한 이벤트 처리

최근에는 이벤트 기반 시스템을 살펴보고 Apache Storm과 같은 프레임 워크를 사용하여 복잡한 이벤트 처리에 대해 배웠습니다. CEP는 대규모 데이터 스트림을 처리하고 데이터 중 특정 이벤트를 감지하고 CEP 엔진에 쿼리를 제공하여 이벤트를 감지 할 때 이상적이라는 것을 알고 있습니다. 매분마다 생성되는 데이터 스트림이 그리 크지 않지만 대신 CEP에

0열

1답변

ESPER에서 값이 100 회 이상 증가하면 시작 및 정지 값 찾기

ESPER에 문제가 있습니다. 많은 정보를 제공하는 시뮬레이트 된 주식 파일이 있습니다. BTC 주식의 가중 가격이 100 배 이상 증가한 모든 시작 및 종료 날짜를 지정하고 싶습니다. 파일의 모습입니다. 2010-07-18,0.04951,0.08585,0.05941,0.08584,75.01,0.07 2010-07-19,0.08584,0.09307,0.07

0열

1답변

Esper : 이벤트가 두 번 전송됩니까?

다음 코드로 이벤트를 보내려고하지만 등록 된 리스너에서 두 번 계속 수신하려고합니다. 리스너 등록에서 쿼리에 문제가 있거나 다른 실수가 있습니까? 조언 해 주셔서 감사합니다. System.out.println("test1"); TestEvent event = new TestEvent(foo); System.out.println("test 1.5");

0열

1답변

Oracle CQL - 창 완료 후 튜플 수 계산하기

JDeveloper을 사용하여 Oracle Stream Analytics에서 Oracle Event Processing Project로 작업하고 있습니다. 내가의 형태로 20 개 튜플의 데이터 스트림이 있습니다 (attr1,attr2,attr3) 1,1,1 2,2,2 .... 20,20,20 내가 각각의 창에서 튜플의 수를 계산하려면을 (

0열

1답변

복잡한 이벤트 처리 시스템을위한 표준 언어 또는 모델 이론

복잡한 이벤트 처리를위한 라이브러리를 개발 중입니다. 우리가 기반으로 할 수있는 명확한 의미론을 가진 표준 또는 널리 받아 들여지는 언어가 있습니까? 일부 연구를 한 후에는 사용 가능한 모든 옵션이 공급 업체/플랫폼에 따라 다릅니다.

0열

1답변

LAN에서 CEP 엔진과 스트림 데이터 생성기간에 데이터를 전송하는 가장 좋은 방법은 무엇입니까?

저는 CEP 엔진 중 하나 인 Esper를 사용하여 스마트 건물에서 이벤트 패턴을 감지하는 CEP (Complex Event Processing) 시스템을 처음 사용했습니다. 서로 다른 센서가 데이터 생성기를 가정하고 구현했습니다. 시스템 성능을 측정하고 싶습니다. 전체 구현은 Java로 이루어져 있으므로 서로 다른 데이터 생성기에서 LAN에있는 CEP 시

1열

1답변

Esper는 스팸없이 데이터가 손실되었을 때 알림을받습니다.

10 초마다 패킷을 보내는 데이터 스트림이 있습니다. 장치가 다운되었을 때 마지막 패킷을받은 이벤트를 생성하는 Esper에 대한 쿼리가 필요합니다. 나는 데이터가 30 초를 위해 도착하지 않는 경우 장치가 분실 가정하지만 장치가 스팸 메일을 여기 을 피하기 위해 다시 올 때까지 나는 단지 1마다 5 시간을 통지받을 필요가 나의 기본 쿼리입니다 : selec