자습서: Azure Stream Analytics를 IoT Edge 모듈로 배포

아티클
01/28/2023
읽는 데 19분 걸림

적용 대상: IoT Edge 1.4

많은 IoT 솔루션에서 분석 서비스를 사용하여 IoT 디바이스에서 클라우드에 도착하는 대로 데이터에 대한 인사이트를 가져옵니다. Azure IoT Edge를 사용하면 Azure Stream Analytics 논리를 가져와서 디바이스 자체로 이동할 수 있습니다. 에지 장치에서 원격 분석 스트림을 처리함으로써 업로드되는 데이터의 양을 줄이고 실행 가능한 인사이트에 대응하는 데 걸리는 시간을 단축할 수 있습니다.

Azure IoT Edge 및 Azure Stream Analytics가 통합되어 워크로드 개발을 간소화합니다. Azure Portal에서 Azure Stream Analytics 작업을 만든 다음, 추가 코드 없이 IoT Edge 모듈로 배포할 수 있습니다.

Azure Stream Analytics는 클라우드와 IoT Edge 디바이스 모두에서 데이터 분석을 위한 다양한 정형 쿼리 구문을 제공합니다. 자세한 내용은 Azure Stream Analytics 설명서를 참조하세요.

이 자습서의 Stream Analytics 모듈은 순환하는 30초 시간 범위에 걸친 평균 온도를 계산합니다. 이 평균 온도가 70에 도달하면 모듈은 디바이스에서 조치를 취하도록 경고를 보냅니다. 이 경우, 그 동작은 시뮬레이션된 온도 센서를 다시 설정하는 것입니다. 프로덕션 환경에서 이 기능을 사용하여 온도가 위험 수준에 도달하면 컴퓨터를 종료하거나 예방 조치를 취할 수 있습니다.

이 자습서에서는 다음 작업 방법을 알아봅니다.

에지에서 데이터를 처리하는 Azure Stream Analytics 작업을 만듭니다.
새 Azure Stream Analytics 작업을 다른 IoT Edge 모듈에 연결합니다.
Azure Portal에서 Azure Stream Analytics 작업을 IoT Edge 디바이스에 배포합니다.

! [다이어그램 - 자습서 아키텍처: ASA 작업 단계 및 배포] (./media/tutorial-deploy-stream-analytics/asa-architecture.png)

Azure를 구독하고 있지 않다면 시작하기 전에 Azure 체험 계정을 만듭니다.

필수 구성 요소

Azure IoT Edge 디바이스:

Linux 또는 Windows 디바이스의 빠른 시작에 설명된 단계에 따라 Azure 가상 머신을 IoT Edge 디바이스로 사용할 수 있습니다.

클라우드 리소스:

Azure의 무료 또는 표준 계층 IoT Hub.

Azure Stream Analytics 작업 만들기

이 섹션에서는 다음 단계를 수행하는 Azure Stream Analytics 작업을 만듭니다.

IoT Edge 디바이스에서 데이터를 받습니다.
설정된 범위를 벗어난 값에 대한 원격 분석 데이터를 쿼리합니다.
쿼리 결과에 따라 IoT Edge 디바이스에 대한 작업을 수행합니다.

스토리지 계정 만들기

IoT Edge 디바이스에서 실행되는 Azure Stream Analytics 작업을 만들 때 디바이스에서 호출할 수 있는 방식으로 작업을 저장해야 합니다. 기존 Azure Storage 계정을 사용하거나 지금 새로 만들 수 있습니다.

Azure Portal에서 리소스 만들기>스토리지>스토리지 계정을 차례로 클릭합니다.

다음 값을 입력하여 스토리지 계정을 만듭니다.

필드	값
Subscription	IoT Hub와 동일한 구독을 선택합니다.
Resource group	IoT Edge 빠른 시작 및 자습서에 대한 모든 테스트 리소스에 동일한 리소스 그룹을 사용하는 것이 좋습니다. 예를 들어 IoTEdgeResources를 사용합니다.
Name	스토리지 계정의 고유한 이름을 입력합니다.
위치	가까운 위치를 선택합니다.

다른 필드는 기본값으로 유지하고, 검토 + 만들기를 선택합니다.
설정을 검토한 다음, 만들기를 선택합니다.

새 작업 만들기

Azure Portal에서 리소스 만들기>사물 인터넷>Stream Analytics 작업으로 차례로 이동합니다.

다음 값을 입력하여 작업을 만듭니다.

필드	값
작업 이름	작업의 이름을 입력합니다. 예: IoTEdgeJob
Subscription	IoT Hub와 동일한 구독을 선택합니다.
Resource group	IoT Edge 빠른 시작 및 자습서에서 만드는 모든 테스트 리소스에 동일한 리소스 그룹을 사용하는 것이 좋습니다. 예를 들어 IoTEdgeResources를 사용합니다.
위치	가까운 위치를 선택합니다.
호스팅 환경	Edge를 선택합니다. 이 옵션은 작업이 클라우드에서 호스팅되는 대신 IoT Edge 디바이스에 배포될 것임을 나타냅니다.

만들기를 선택합니다.

작업 구성

Azure Portal에서 Stream Analytics 작업을 만든 후에는 통과하는 데이터에 대해 실행되는 입력, 출력 및 쿼리를 사용하여 작업을 구성할 수 있습니다.

이 섹션에서는 입력, 출력, 쿼리의 세 가지 요소를 사용하여 IoT Edge 디바이스에서 온도 데이터를 수신하는 작업을 만듭니다. 이 작업은 순환하는 30초 동안의 데이터를 분석합니다. 이 시간의 평균 온도가 70도를 초과하면 IoT Edge 디바이스로 경고가 전송됩니다. 그 다음 섹션에서는 작업을 배포할 때 데이터가 들어오고 나오는 위치를 정확하게 지정할 것입니다.

Azure Portal에서 Stream Analytics 작업으로 이동합니다.
작업 토폴로지에서 입력, 스트림 입력 추가를 차례로 선택합니다.
드롭다운 목록에서 Edge Hub를 선택합니다.

목록에 Edge Hub 옵션이 표시되지 않으면 클라우드 호스팅 작업으로 Stream Analytics 작업을 만들었을 수 있습니다. 새 작업을 만들고 Edge를 호스팅 환경으로 선택해야 합니다.
새 입력 창에 입력 별칭으로 온도를 입력합니다.
다른 필드는 기본값을 유지하고 저장을 선택합니다.
작업 토폴로지에서 출력을 열고 추가를 선택합니다.
드롭다운 목록에서 Edge Hub를 선택합니다.
새 출력 창에서 출력 별칭으로 경고를 입력합니다.
다른 필드는 기본값을 유지하고 저장을 선택합니다.
작업 토폴로지에서 쿼리를 선택합니다.
기본 텍스트를 다음 쿼리로 바꿉니다. 30초 시간의 평균 머신 온도가 70도에 도달하면 SQL 코드는 출력 경고에 다시 설정 명령을 보냅니다. 다시 설정 명령은 센서에 수행 가능한 작업으로 미리 프로그래밍되어 있습니다.
```
SELECT  
    'reset' AS command
INTO
   alert
FROM
   temperature TIMESTAMP BY timeCreated
GROUP BY TumblingWindow(second,30)
HAVING Avg(machine.temperature) > 70
```
쿼리 저장을 선택합니다.

IoT Edge 설정 구성

IoT Edge 디바이스에 배포할 Stream Analytics 작업을 준비하려면 작업을 스토리지 계정에 연결해야 합니다. 작업 배포로 이동하면 작업 정의가 컨테이너 형식의 스토리지 계정으로 내보내집니다.

구성 아래에서 스토리지 계정 설정을 선택한 다음, 스토리지 계정 추가를 선택합니다.
구독에서 Blob 스토리지/ADLS Gen 2 선택 옵션을 선택합니다.
드롭다운 메뉴를 사용하여 이 자습서의 시작 부분에서 설정한 구독 및 스토리지 계정을 선택합니다.
저장을 선택합니다.

작업 배포

이제 IoT Edge 디바이스에 Azure Stream Analytics 작업을 배포할 준비가 되었습니다.

이 섹션에서는 Azure Portal의 모듈 설정 마법사를 사용하여 배포 매니페스트를 만듭니다. 배포 매니페스트는 디바이스에 배포될 모든 모듈, 모듈 이미지를 저장하는 컨테이너 레지스트리, 모듈을 관리하는 방법, 모듈이 서로 통신하는 방법을 설명하는 JSON 파일입니다. IoT Edge 디바이스는 IoT Hub에서 배포 매니페스트를 수신한 다음, 그 안에 들어 있는 정보를 사용하여 할당된 모든 모듈을 배포하고 구성합니다.

이 자습서에서는 두 개의 모듈을 배포합니다. 첫 번째는 온도 및 습도 센서를 시뮬레이션하는 SimulatedTemperatureSensor 모듈입니다. 두 번째는 Stream Analytics 작업입니다. 센서 모듈은 작업 쿼리에서 분석할 데이터 스트림을 제공합니다.

Azure Portal에서 IoT Hub로 이동합니다.
디바이스 관리 메뉴에서 디바이스를 선택한 다음, IoT Edge 디바이스에 대한 세부 정보 페이지를 엽니다.
모듈 설정을 선택합니다.
이전에 SimulatedTemperatureSensor 모듈을 이 디바이스에 배포한 경우 자동으로 채워질 수 있습니다. 자동으로 입력되지 않으면 다음 단계에 따라 모듈을 추가합니다.
1. 추가를 클릭하고 IoT Edge 모듈을 선택합니다.
2. 이름에 대해 SimulatedTemperatureSensor를 입력합니다.
3. 이미지 URI에 대해 mcr.microsoft.com/azureiotedge-simulated-temperature-sensor:1.0을 입력합니다.
4. 다른 설정은 변경하지 않고 추가를 선택합니다.
다음 단계에 따라 Azure Stream Analytics Edge 작업을 추가합니다.
1. 추가를 클릭하고 Azure Stream Analytics 모듈을 선택합니다.
2. 구독 및 사용자가 만든 Azure Stream Analytics Edge 작업을 선택합니다.
3. 저장을 선택합니다.
변경 내용이 저장되면 Stream Analytics 작업의 세부 정보가 생성된 스토리지 컨테이너에 게시됩니다.
모듈 목록에 Stream Analytics 모듈이 추가되면 해당 이름을 선택하여 구성된 방식을 확인하고 IoT Edge 모듈 업데이트 페이지에서 해당 설정을 업데이트합니다.

모듈 설정 탭에는 표준 Azure Stream Analytics 이미지를 가리키는 이미지 URI가 있습니다. 이 하나의 이미지는 IoT Edge 디바이스에 배포되는 모든 Stream Analytics 모듈에 사용됩니다.

모듈 쌍 설정 탭에서는 ASAJobInfo라는 ASA(Azure Stream Analytics) 속성을 정의하는 JSON을 보여 줍니다. 이 속성의 값은 스토리지 컨테이너의 작업 정의를 가리킵니다. 이 속성은 특정 작업 세부 정보를 사용하여 Stream Analytics 이미지가 구성되는 방법입니다.

기본적으로 Stream Analytics 모듈은 기반이 되는 작업과 동일한 이름을 사용합니다. 원하는 경우 이 페이지에서 모듈 이름을 변경할 수 있지만 반드시 필요한 것은 아닙니다.
적용 또는 취소를 선택합니다.
그 다음 단계에서 필요하므로 Stream Analytics 모듈 이름을 적어 둡니다.
다음: 경로를 선택합니다.

경로 탭에서 모듈과 IoT Hub 사이에서 메시지가 전달되는 방식을 정의합니다. 메시지는 이름 및 값 쌍을 사용하여 생성됩니다. 기본 경로 이름 및 값을 다음 표에 표시된 쌍으로 바꿉니다. {moduleName}_의 인스턴스를 Azure Stream Analytics 모듈의 이름으로 바꿉니다.

이름	값
`telemetryToCloud`	`FROM /messages/modules/SimulatedTemperatureSensor/* INTO $upstream`
`alertsToCloud`	`FROM /messages/modules/{moduleName}/* INTO $upstream`
`alertsToReset`	`FROM /messages/modules/{moduleName}/* INTO BrokeredEndpoint("/modules/SimulatedTemperatureSensor/inputs/control")`
`telemetryToAsa`	`FROM /messages/modules/SimulatedTemperatureSensor/* INTO BrokeredEndpoint("/modules/{moduleName}/inputs/temperature")`

여기에 선언하는 경로는 IoT Edge 디바이스를 통과하는 데이터 흐름을 정의합니다. SimulatedTemperatureSensor의 원격 분석 데이터는 IoT Hub 및 Stream Analytics 작업에서 구성된 온도 입력으로 보내집니다. 경고 출력 메시지는 IoT Hub 및 SimulatedTemperatureSensor 모듈로 보내져 reset(다시 설정) 명령을 트리거합니다.

완료되면 다음: 검토 + 만들기를 선택합니다.
검토 + 만들기 탭에서 마법사에서 제공한 정보가 JSON 배포 매니페스트로 변환되는 방법을 확인할 수 있습니다. 매니페스트 검토가 완료되면 만들기를 선택합니다.
디바이스 세부 정보 페이지로 돌아갑니다. 새로 고침을 선택합니다.

IoT Edge 에이전트 및 IoT Edge Hub 모듈과 함께 실행되는 새 Stream Analytics 모듈이 표시됩니다. 정보가 IoT Edge 디바이스에 도달한 후 새 모듈을 시작하는 데 몇 분 정도 걸릴 수 있습니다. 실행되는 모듈이 바로 표시되지 않으면 해당 페이지를 계속 새로 고칩니다.

데이터 보기

이제 IoT Edge 디바이스로 이동하여 Azure Stream Analytics 모듈과 SimulatedTemperatureSensor 모듈 간의 상호 작용을 확인할 수 있습니다.

Docker에서 모든 모듈이 실행되는지 확인합니다.
```
iotedge list  
```
모든 시스템 로그 및 메트릭 데이터를 봅니다. {moduleName}을 Azure Stream Analytics 모듈의 이름으로 바꿉니다.
```
iotedge logs -f {moduleName}  
```
센서 로그를 확인하여 Reset 명령이 SimulatedTemperatureSensor에 미치는 영향을 확인합니다.
```
iotedge logs SimulatedTemperatureSensor
```
머신의 온도가 30초 동안 70도에 도달할 때까지 점차적으로 상승하는 것을 볼 수 있습니다. 그러면 Stream Analytics 모듈이 재설정을 트리거하고 컴퓨터 온도가 21도로 떨어집니다.

리소스 정리

권장되는 다음 문서를 계속 진행하려는 경우 만든 리소스와 구성을 그대로 유지하고 다시 사용할 수 있습니다. 테스트 디바이스와 동일한 IoT Edge 디바이스를 계속 사용해도 됩니다.

그렇지 않은 경우 요금이 발생하지 않도록 이 문서에서 사용한 로컬 구성 및 Azure 리소스를 삭제할 수 있습니다.

Azure 리소스 삭제

Azure 리소스와 리소스 그룹을 삭제하면 되돌릴 수 없습니다. 잘못된 리소스 그룹 또는 리소스를 자동으로 삭제하지 않도록 해야 합니다. 보관하려는 리소스가 있는 기존 리소스 그룹 내에 IoT 허브를 만든 경우 리소스 그룹이 아닌 IoT 허브 리소스만 삭제해야 합니다.

리소스를 삭제하려면:

Azure Portal에 로그인한 다음, 리소스 그룹을 선택합니다.
IoT Hub 테스트 리소스가 포함된 리소스 그룹 이름을 선택합니다.
리소스 그룹에 포함된 리소스의 목록을 검토합니다. 모든 항목을 삭제하려는 경우리소스 그룹 삭제를 선택할 수 있습니다. 일부만 삭제하려는 경우 각 리소스를 클릭하여 개별적으로 삭제할 수 있습니다.

다음 단계

이 자습서에서는 IoT Edge 디바이스의 데이터를 분석하도록 Azure Stream Analytics 작업을 구성했습니다. 그런 다음, 이 Azure Stream Analytics 모듈을 IoT Edge 디바이스에 로드하여 온도 상승을 로컬에서 처리하고, 이에 대응하며, 집계된 데이터 스트림을 클라우드로 보냈습니다. Azure IoT Edge에서 추가 업무용 솔루션을 만드는 방법을 확인하려는 경우 다른 자습서를 계속 진행할 수 있습니다.

Azure Machine Learning 모델을 모듈로 배포