Stream Analytics 사용하여 데이터 이동

  • 3분

Azure Stream Analytics는 여러 원본의 빠른 스트리밍 데이터를 동시에 처리하도록 설계된 실시간 이벤트 처리 엔진입니다. 더 많은 작업과 추가 분석을 위해 데이터를 집계, 분석, 변환할 수 있으며 다른 데이터 저장소로 이동할 수도 있습니다.

설정

Azure Stream Analytics는 Azure Cosmos DB for NoSQL을 포함한 여러 출력 싱크를 지원합니다.

참고

현재는 NoSQL API만 지원됩니다.

구성

Azure Cosmos DB for NoSQL 출력에 대한 구성은 구독 내에서 계정을 선택하거나 일반적으로 자격 증명을 제공하는 것으로 구성됩니다. 자격 증명에는 다음이 포함됩니다.

속성 설명
Output alias 쿼리에서 이 출력을 참조하는 별칭
Account ID 계정 엔드포인트 URI
Account Key 계정 키
Database 데이터베이스 리소스 이름
Container name 컨테이너 이름

출력 싱크를 사용하기 전 Azure Cosmos DB for NoSQL 계정에 데이터베이스와 컨테이너가 이미 있어야 합니다.

Azure Cosmos DB에 쓰기

Azure Stream Analytics의 쿼리 결과는 Azure Cosmos DB for NoSQL에 기록될 때 JSON 출력으로 처리됩니다.

또한 항목은 id 필드의 값에 따라 Azure Cosmos DB for NoSQL에 upsert됩니다. 항목은 일반적으로 Azure Cosmos DB for NoSQL에 삽입됩니다. 동일한 고유 ID를 가진 항목이 이미 있는 경우 작업은 삽입 작업 대신 업데이트 작업으로 간주합니다.