이 문장에서 시도하다

'Azure Stream Analytics'는 Azure Event Hubs에 대량의 데이터를 수신할 수 있지만 실시간으로 후속 가공 처리를 하려면 매우 유용하다.이 글은 "흐름 분석"을 사용하여 간단한 저장 계정에 데이터를 보내는 방법과 Power BI를 설정하여 실시간으로 데이터를 시각화하는 방법을 소개한다.
Azure Event Hubs가 설정되지 않은 경우 여기 에서 웹 API를 사용하여 Event Hubs를 설정하는 방법을 확인합니다.

미리 준비한 물건

Azure 가입

열린 데이터에 대한 액세스 권한 (필요한 경우)

Event Hubs(설정하지 않은 경우 보기이 문장

단계 설정

공기 흐름 분석 준비

우선 Azure Stream Analytics를 준비하세요.
※ 2016년 6월 발표된 새로운 Azure Portal의 Azure Stream Analytics 구축 방법을 기록합니다.

Azure 포털에서 새로 만들기 > Intelligence + Analytics > Stream Analytics 작업을 클릭합니다.

작업 이름을 작성하고 구독, 자원 그룹, 위치 등을 선택한 다음 "만들기"를 누르십시오.

이 생성되면 다음과 같이 목록에 추가됩니다.생성된 흐름 분석 작업을 클릭합니다.

현재 Stream Analytics 작업은 끝났지만 감시를 활성화하고 싶습니다.

생성 후 모니터링이 활성화되지 않았지만, 생성 후 Event Hubs에서 메시지를 수신해도 쉽게 메시지를 수신하거나 오류를 발견했는지 확인하기 어렵습니다.

모니터링을 사용하려면 진단을 사용하십시오.상태를 열고 진단 결과를 저장할 스토리지 계정을 선택합니다.

이 올바르게 설정되면 다음과 같은 알림이 표시됩니다.이 설정을 완료합니다.그런 다음 생성된 Azure Stream Analytics를 Event Hubs 및 스토리지 계정에 연결합니다.

흐름 분석에 Azure Event Hubs 연결

를 클릭하여 입력합니다.

추가를 클릭하여 각 매개변수를 입력합니다.

올바르게 입력하면 다음 알림이 표시됩니다.

이 설정을 입력하면 끝납니다.

Azure Stream Analytics에서 Azure 스토리지 계정 출력 설정

그리고 출력을 설정합니다.이번에는 Event Hubs에서 받은 데이터를 먼저 BLOB 저장소에 저장하고 싶습니다.내보내기를 클릭합니다.

숙에서 BLOB 스토리지를 선택합니다.

매개변수를 입력합니다.스토리지 계정이 이미 있는 경우 기존 스토리지 계정을 선택하거나 새 스토리지 계정을 생성할 수 있습니다.저장할 때의 폴더 차원 구조는 경로 모드로 정의됩니다.{date}에서 받은 날짜, {time}에서 받은 시간 (1시간 단위) 은 폴더를 분리합니다.

이 올바르게 설정되면 다음과 같은 알림이 표시됩니다.

이로써 출력 설정이 완료됩니다.

질의 설정

입력과 출력이 설정되어 있지만 흐름 분석 프로그램은 이 조작만 할 수 없습니다.입력한 데이터를 출력에 전달할 수 있도록 조회를 설정해야 합니다.이번에도 기본편이 있는데 가장 간단한 조회를 설정합니다.다음에, 우리는 더욱 고급 조회를 소개할 것이다.

조회를 클릭합니다.

질의를 (으)로 설정합니다.

설정이 올바르면 다음과 같이 알려 줍니다.

"시작"을 누르면 흐름 분석이 시작되고 설정된 조회 처리를 통해 수신된 이벤트(이곳은 이벤트 Hubs에서 온 데이터)를 대상(BLOB 저장소)에 전송합니다.

실제 저장 여부를 확인합니다.Azure Portal을 통해서만 확인할 수 있지만 Azure Store Explorer를 사용하면 GUI가 매우 충실하고 편리합니다.이번에는 Azure 포털에서 확인하겠습니다.스토리지 계정에 액세스하고 블로그를 클릭합니다.

컨테이너를 선택하여 만든 폴더를 엽니다.맨 아래에 들어가면 JSON 형식의 파일이 저장됩니다.파일 이름은 자동으로 흐름 분석에 의해 생성됩니다.

그럼 다운로드해 볼게요.

이 JSON 형식으로 올바르게 수신되었습니다.