Visual Studio Code를 사용하여 라이브 스트림 입력에 대해 로컬로 Stream Analytics 쿼리 테스트

라이브 스트림 입력에 대해 로컬에서 Stream Analytics 쿼리를 테스트하는 것은 쿼리 논리의 정확도와 효율성을 보장하는 중요한 단계입니다. VS Code(Visual Studio Code)용 ASA(Azure Stream Analytics) 확장을 사용하면 이 테스트를 원활하게 수행하는 데 필요한 도구가 있습니다. 이 문서에서는 환경을 설정하고, 라이브 스트림 입력을 구성하고, 철저한 테스트를 위해 로컬에서 쿼리를 실행하는 단계를 안내합니다.

필수 조건

• .NET Core SDK를 설치하고 Visual Studio Code를 다시 시작합니다.
• Visual Studio Code를 사용하여 Stream Analytics 작업을 설치하고 만들려면 이 빠른 시작을 따릅니다.

라이브 스트림 입력 정의

1. Stream Analytics 프로젝트에서 Inputs 폴더를 마우스 오른쪽 단추로 클릭하고 ASA: 입력 추가를 선택합니다. 또는 Ctrl+Shift+P를 눌러 명령 팔레트를 열고, ASA: Add Input을 입력합니다. 그런 다음 입력 스트림을 처리하기 위한 쿼리 스크립트를 선택합니다.

2. 드롭다운 목록에서 라이브 입력 원본 형식을 선택하고 Azure 구독에서 선택하고 입력 원본의 이름을 입력합니다.

3. Input 폴더 아래에 만들어진 새 JSON 파일이 표시됩니다. 파일을 열고 구독에서 선택하면 Event Hubs 입력을 구성하는 데 도움이 됩니다.

4. 실시간 입력이 성공적으로 구성되었는지 유효성을 검사하려면 데이터 미리 보기를 선택합니다.

로컬에서 쿼리 실행

쿼리 파일을 열고 로컬 실행 또는 메뉴 모음의 재생 단추를 선택하여 로컬 실행 모드를 구성하기 위한 로컬 실행 옵션 창을 엽니다.

라이브 입력 스트림에 대해 로컬로 작업을 실행하고 로컬 폴더에 출력 결과를 생성하려면 라이브 입력 및 로컬 출력 사용을 선택합니다. 그런 다음 실행을 선택하여 로컬에서 작업 실행을 시작합니다.

로컬 테스트 창이 열리고 3초마다 새로 고쳐지는 것을 볼 수 있습니다. 출력 결과는 LocalRunOutputs 폴더에 JSON 형식으로 저장됩니다.

로컬 테스트를 위한 입력 파티션 지정

Event Hubs에서 모든 데이터를 수집하지 않으려면 로컬 테스트 중에 Event Hubs에 대한 특정 파티션을 지정할 수 있습니다.

1. 로컬 실행을 선택하여 로컬 실행 옵션 창을 엽니다.
2. 입력 파티션 선택 섹션에서 사용자 지정을 선택합니다.
3. 로컬 테스트를 위해 데이터를 수집하려는 특정 파티션 번호를 입력합니다.

파티션을 지정하면 대량의 데이터에 대해 걱정하지 않고 쿼리 논리 테스트에 집중할 수 있습니다. 이 기능을 사용하면 Stream Analytics 작업을 보다 효율적이고 대상별로 테스트할 수 있습니다.

Azure에 작업 제출

로컬에서 쿼리 테스트를 완료한 후에는 Stream Analytics 프로젝트를 Azure에 제출하고 클라우드에서 작업 실행을 시작할 수 있습니다.

1. Azure에 제출 옵션을 선택하거나 쿼리 파일에서 업로드 단추를 선택합니다.
2. 제출 옵션 창에서 Azure의 기존 작업을 업데이트하거나 업로드를 위한 새 작업을 만들 수 있습니다.
3. 구독, 리소스 그룹 및 배포 지역을 포함하여 필요한 세부 정보를 제공합니다.

제출 프로세스가 완료되면 새 창에서 클라우드 작업을 볼 수 있습니다. 여기에서 성능을 모니터링하고 필요에 따라 구성을 관리할 수 있습니다. 출력 패널에 제공된 링크를 클릭하여 브라우저에서 작업을 열 수도 있습니다.

다음 단계

• Visual Studio Code 확장을 사용하여 Stream Analytics 작업 내보내기 및 관리
• 로컬에서 Stream Analytics 작업 실행 개요
• 샘플 데이터를 사용하여 로컬에서 Stream Analytics 쿼리 테스트
• ASA npm 패키지를 사용하여 CI/CD 파이프라인 설정