다음을 통해 공유

Visual Studio 도구를 사용하여 Stream Analytics Edge 작업 개발

  • 아티클

이 자습서에서 Visual Studio용 Stream Analytics 도구를 사용하는 방법을 알아봅니다. Stream Analytics Edge 작업을 작성하고 디버깅하고 만드는 방법을 알아봅니다. 작업을 만들고 테스트한 후에는 Azure Portal로 이동하여 디바이스에 배포할 수 있습니다.

필수 조건

이 자습서를 완료하려면 다음 필수 구성 요소가 필요합니다.

Stream Analytics Edge 프로젝트 만들기

Visual Studio에서 파일>새로 만들기>프로젝트를 차례로 선택합니다. 왼쪽의 템플릿 목록으로 이동하고, Azure Stream Analytics>Stream Analytics Edge>Azure Stream Analytics Edge Application을 차례로 펼칩니다. 프로젝트에 대한 이름, 위치 및 솔루션 이름을 제공하고 확인을 선택합니다.

New Stream Analytics Edge project in Visual Studio

프로젝트가 만들어지면 솔루션 탐색기로 이동하여 폴더 계층 구조를 봅니다.

Solution explorer view of Stream Analytics Edge job

올바른 구독 선택

  1. Visual Studio 보기 메뉴에서 서버 탐색기를 선택합니다.

  2. Azure를 마우스 오른쪽 단추로 클릭하고 Microsoft Azure 구독에 연결을 선택한 다음 Azure 계정으로 로그인합니다.

입력 정의

  1. 솔루션 탐색기에서 입력 노드를 펼치면 EdgeInput.json이라는 입력이 표시됩니다. 두 번 클릭하여 해당 설정을 봅니다.

  2. 원본 형식은 데이터 스트림으로 설정합니다. 그런 다음, 원본을 Edge Hub로, 이벤트 직렬화 형식을 Json으로, 인코딩을 UTF8로 설정합니다. 필요에 따라 입력 별칭의 이름을 바꿀 수 있으며, 이 예제에서는 그대로 두겠습니다. 입력 별칭의 이름을 바꾸는 경우 쿼리를 정의할 때 지정한 이름을 사용합니다. 저장을 선택하여 설정을 저장합니다.
    Stream Analytics job input configuration

출력 정의

  1. 솔루션 탐색기에서 출력 노드를 펼치면 EdgeOutput.json이라는 출력이 표시됩니다. 두 번 클릭하여 해당 설정을 봅니다.

  2. 싱크를 설정하여 Edge Hub를 선택하고, 이벤트 serialization 형식을 Json으로 설정하고, 인코딩을 UTF8로 설정하고, 형식을 배열로 설정해야 합니다. 필요에 따라 출력 별칭의 이름을 바꿀 수 있으며, 이 예제에서는 그대로 두겠습니다. 출력 별칭의 이름을 바꾸는 경우 쿼리를 정의할 때 지정한 이름을 사용합니다. 저장을 선택하여 설정을 저장합니다. Stream Analytics job output configuration

변환 쿼리 정의

Stream Analytics IoT Edge 환경에 배포된 Stream Analytics 작업은 대부분의 Stream Analytics 쿼리 언어 참조를 지원합니다. 그러나 Stream Analytics Edge 작업에는 다음 작업이 아직 지원되지 않습니다.

범주 Command
기타 연산자
  • PARTITION BY
  • TIMESTAMP BY OVER
  • JavaScript UDF
  • UDA(사용자 정의 집계)
  • GetMetadataPropertyValue
  • 한 번에 15개 이상의 집계 사용

포털에서 Stream Analytics Edge 작업을 만들 때 지원되는 연산자를 사용하지 않는 경우 컴파일러에서 자동으로 경고합니다.

Visual Studio의 쿼리 편집기(script.asaql 파일)에서 다음 변환 쿼리를 정의합니다.

SELECT * INTO EdgeOutput
FROM EdgeInput

로컬로 작업 테스트

쿼리를 로컬로 테스트하려면 샘플 데이터를 업로드해야 합니다. GitHub 리포지토리에서 등록 데이터를 다운로드하여 샘플 데이터를 가져오고 로컬 컴퓨터에 저장할 수 있습니다.

  1. 샘플 데이터를 업로드하려면 EdgeInput.json 파일을 마우스 오른쪽 단추로 클릭하고, 로컬 입력 추가를 선택합니다.

  2. 팝업 창의 로컬 경로에서 샘플 데이터를 찾아보고 저장을 선택합니다. Local input configuration in Visual Studio

  3. local_EdgeInput.json 파일이 입력 폴더에 자동으로 추가됩니다.

  4. 로컬로 실행하거나 Azure에 제출할 수 있습니다. 쿼리를 테스트하려면 로컬로 실행을 선택합니다.
    Stream Analytics job run options in Visual Studio

  5. 명령 프롬프트 창에 작업의 상태가 표시됩니다. 작업이 성공적으로 실행되면 프로젝트 폴더 경로(“Visual Studio 2015\Projects\MyASAEdgejob\MyASAEdgejob\ASALocalRun\2018-02-23-11-31-42”)에 “2018-02-23-11-31-42”와 같은 폴더가 만들어집니다. 폴더 경로로 이동하여 로컬 폴더의 결과를 봅니다.

    또한 Azure Portal에 로그인하여 작업이 만들어졌는지 확인할 수도 있습니다.

    Stream Analytics job result folder

Azure에 작업 제출

  1. Azure에 작업을 제출하기 전에 먼저 Azure 구독에 연결해야 합니다. 서버 탐색기를 열고, Azure 및 Microsoft Azure 구독에 연결을 마우스 오른쪽 단추로 클릭한 다음 Azure 구독에 로그인합니다.

  2. Azure에 작업을 제출하려면 쿼리 편집기로 이동하고, Azure에 제출을 선택합니다.

  3. 팝업 창이 열립니다. 기존 Stream Analytics Edge 작업을 업데이트하거나 새 작업을 만들도록 선택합니다. 기존 작업을 업데이트하면 모든 작업 구성이 대체되며, 이 시나리오에서는 새 작업을 게시합니다. 새 Azure Stream Analytics 작업 만들기를 선택하고, MyASAEdgeJob과 같은 작업 이름을 입력하고, 필요한 구독, 리소스 그룹 및 위치를 선택하고, 제출을 선택합니다.

    Submit Stream Analytics job to Azure from Visual Studio

    이제 Stream Analytics Edge 작업이 만들어졌습니다. IoT Edge에서 작업 실행 자습서를 참조하여 디바이스에 배포하는 방법을 알아볼 수 있습니다.

작업 관리

서버 탐색기에서 작업 및 작업 다이어그램의 상태를 볼 수 있습니다. 서버 탐색기의 Stream Analytics에서 Stream Analytics Edge 작업을 배포한 구독 및 리소스 그룹을 확장합니다. MyASAEdgejob의 상태가 생성됨인 것을 확인할 수 있습니다. 작업 노드를 펼치고, 해당 작업 노드를 두 번 클릭하여 작업 보기를 엽니다.

Server explorer job management options

작업 보기 창에서는 Azure Portal의 작업 새로 고침, 작업 삭제, 작업 열기와 같은 작업을 제공합니다.

Job diagram and other options in Visual Studio

다음 단계