StreamInsight 예제

  • 아티클

 

이 섹션은 StreamInsight 프로그램 작성과 관련된 다양한 구성 요소 및 단계에 대한 예제로 이루어져 있습니다. 각각의 예제는 이벤트 처리 시나리오 구현을 위해 이벤트 원본, 이벤트 싱크 및 쿼리가 조합된 전체 StreamInsight 프로그램입니다. StreamInsight API는 이벤트 처리 응용 프로그램을 만들고 유지 관리하는 과정을 다양한 방식으로 제어하고 복잡한 작업을 진행할 수 있도록 다수의 인터페이스를 제공합니다. 이 섹션에서 제공되는 예제에서는 간단한 원본, 싱크 및 쿼리와 함께 이러한 인터페이스 사용에 대한 내용을 설명합니다.

이 섹션의 예제에서는 나열된 어셈블리 참조의 다음 네임스페이스를 사용합니다.

어셈블리 참조

  • System.Reactive.dll

  • System.Reactive.Providers.dll

  • System.ServiceModel.dll

  • Microsoft.ComplexEventProcessing.dll

  • Microsoft.ComplexEventProcessing.ManagementService.dll

  • Microsoft.ComplexEventProcessing.Observable.dll

네임스페이스

  • using System.Reactive;

  • using System.Reactive.Linq;

  • using System.Reactive.Subjects;

  • using System.ServiceModel;

  • using Microsoft.ComplexEventProcessing;

  • using Microsoft.ComplexEventProcessing.Linq;

  • using Microsoft.ComplexEventProcessing.ManagementService;

섹션 내용

이 섹션의 첫 번째 예에서는 다른 예에서 사용되는 서버를 만듭니다. 인터페이스를 설명하는 데 간단한 원본이나 싱크 및 쿼리가 사용됩니다. 이러한 동일한 기본 원칙에 따라 매우 복합적인 이벤트 처리 시나리오를 만들 수 있습니다.

StreamInsight 예제: 서버 - 포함된 서버 표시
이 예에서는 포함된 StreamInsight 서버를 만든 다음 StreamInsight 클라이언트가 원격 서버에 연결할 수 있도록 끝점을 노출합니다.

StreamInsight 예제: 클라이언트 A - 원격 서버 사용
이 예제에서는 이전 예제의 서버에 연결하고 서버에 정의된 엔터티를 사용하여 CEP 프로세스를 만듭니다.

StreamInsight 예제: 클라이언트 B - 주체 만들기
이 예제에서는 첫 번째 예제의 원격 서버를 사용하며 두 원본에서 두 싱크로 데이터를 전달하는 주체를 만듭니다.