2017-09-07 13 views
0

kafka의 메시지를 수신 대기하도록 구성된 esperprocesser가 있습니다.주어진 시간 동안 들어오는 이벤트가없는 경우 esper를 트리거하는 방법

보통 select * from events.win:time(2 min)은 지난 2 분간 모든 이벤트를 트리거합니다. 지난 2 분 동안 카프카에 메시지가없는 경우 알림을 실행하고 싶습니다.

select * from events(Ip='1.1.1.1').win:time(2 min) 과 같은 메시지를 쓸 때 어떻게 처리해야합니까?이 메시지/이벤트는 일치하지 않으며 esper는 트리거되지 않습니다. "이벤트 이벤트를 호출하지 않는 : 이벤트가

감사합니다 사전에 주어진 시간에 결석 한 경우

는 어떻게

답변

1

당신이

select * from pattern [every (timer:interval(2 min) and not MyEvent)] 

// 팁을 할 수 에스퍼 트리거해야 "라고 말하면서 유용하다고 생각하고 대문자를 사용합니다.

+0

감사합니다! 이전에 실제로''select count (*) from myEvents.win:time(1 min) '과 같은 것을 시도해 보았습니다. 실제로는 작동하지 않습니다. –

+0

실제 코드에서는 이벤트가 아니므로 커뮤니티 회원이 내 질문을 이해하기 쉽기 때문에 "이벤트"를 사용했습니다. 그것을 가리켜 주셔서 감사합니다. –