에스퍼 예제

에스퍼 예제
2 Agosto, 2019 fabio

이 예제에서 명령줄에서 실행할 수 있는 시뮬레이터도 사용할 수 있습니다. 시뮬레이터는 명령줄 인수에 의해 지정된 대로 다수의 XML 문서를 생성하고 센서당 합계를 출력합니다. “run_autoid.bat”(Windows) 또는 “run_autoid.sh”(유닉스)를 실행하여 AutoID 시뮬레이터를 시작합니다. 빌드 지침 및 명령줄 매개 변수는 동일한 폴더에 있는 readme 파일을 참조하십시오. 주문된 이벤트 스트림을 처리하는 이벤트 스트림 처리(ESP)와 여러 스트림을 처리하는 CEP 간에 구분되는 경우가 많습니다. 전자는 고속 처리 및 수학적 알고리즘에 중점을 두고, 후자는 이벤트 패턴을 감지하는 데 중점을 둡니다. 그러나 많은 제품(Esper 포함)이 두 기능을 모두 제공하므로 여기에서만 CEP 약어를 사용합니다. 용어의 공식적인 정의는 CEP 용어에서 찾을 수 있습니다. 이 예제에서는 SLA(서비스 수준 계약)와 같은 서비스 품질 수준을 측정하기 위한 몇 가지 코드를 개발합니다. 또한 변수 또는 새 필터 매개 변수를 포함하는 이벤트를 사용하여 즉석 필터링을 지원하기 위해 동적 쿼리 /필터를 빌드하는 데 관심이 있습니다. 나는 당신의 생각을 듣고 당신이 하나가있는 경우 예를보고 싶습니다. 나는 당신이 준 예와 그 일을 시도! 나는 한 시간 정도 걸렸지만.

하지만 지금은 5 분 에 처음부터 모든 것을 할 수 있습니다. 이 예제는 원시 시장 데이터 피드를 처리합니다. 처리량 통계를 보고하고 피드의 데이터 속도가 예기치 않게 떨어지는 시기를 감지합니다. 속도 하락은 데이터가 부실하다는 것을 의미할 수 있으며 피드에 문제가 있을 때 경고하려고 합니다. 이 예제에서는 집계된 데이터의 패턴을 집계하고 감지하는 문을 연결하여 자산 그룹 제약 조건이 위반되는 시기를 결정합니다. MatchMaker 예제에서 모든 모바일 사용자는 X 및 Y 위치를 가지며 이 예제에서 만든 이벤트 패턴의 작업은 특정 범위가 주어진 근접 내에 있고 특정 속성이 기본 설정과 일치하는 모바일 사용자를 검색하는 것입니다. 시뮬레이터는 2개의 피드, 피드 A 및 피드 B에 대한 시장 데이터 이벤트를 생성합니다. 시뮬레이터의 첫 번째 매개 변수는 여러 스레드입니다. 각 스레드는 무한 루프에서 각 피드에 대한 이벤트를 보냅니다. Java VM 가비지 수집이 시작되면 이러한 일시 중지 중에 속도 드롭오프가 생성됩니다.

조건은 이벤트 스트림에 적용할 수 있으며, 이로 인해 이벤트가 데이터 창을 입력하기 전에 필터링될 수 있습니다(이벤트를 발생하지 도 않습니다). 예를 들어 쿼리: 전체 예제 코드는 “퀴즈”에서 분포의 “예제” 폴더에서 찾을 수 있습니다. “etc” 폴더에는 요구 사항 문서, 테스트 사양 및 EPL 솔루션 파일이 포함되어 있습니다. “src” 폴더에는 시뮬레이션 코드, 테스트 사양 및 단위 테스트 코드구문 분석이 포함되어 있습니다. 가장 최근 순서에 대한 대기 시간은 다소 유용하지만 기간 동안의 일부 통계 측정은 더 대표적일 수 있습니다. 이렇게 하면 창 보기에 대한 Esper의 지원이 소개됩니다.