제 이해가 맞으면 한 번에 하나의 스트림 분석 작업 인스턴스 만 실행됩니다. 현재 이벤트 세트로 끝나면 다음 이벤트 세트가 이벤트 허브에서 가져옵니다. 그래서 순차적입니다.Azure Stream Analytics에서 병렬 처리를 수행하는 방법
처리에 20 밀리 초가 걸리면 다른 이벤트가 해당 밀리 초 동안 대기해야합니다. 이 순차 작업으로 생산로드가 충분할 지 궁금한가요?
저는 PartitionBy 절을 알고 있지만 IoT 허브를 사용하고 있으므로 partitionId/PartitionKey를 사용할 수 없습니다. 사전
같은의 DeviceID 모든 메시지에서
덕분에 같은 PartitionID에 전송됩니다. 쿼리가 한 번에 하나의 deviceId 만 보는 경우에도 partitionId를 사용하고 각 파티션을 독립적으로 처리 할 수 있습니다. 예를 들어 Select, Filter only 쿼리 및 키에 deviceid가 포함 된 집계 등이 있습니다.
검색어가 한 번에 여러 개의 기기 ID (예 : 전체 메시지 수를 계산)를 조회 할 경우 두 가지 옵션이 있습니다. 먼저 부분 집계를 병렬로 처리 한 다음이를 결합하여 전역 집계를 얻을 수 있습니다. 또는 파티션없이 쿼리를 사용하십시오.
또한 Azure 스트림 분석에서는 메시지에서 하나씩 메시지를 가져 와서 질문에서 언급 한 지연이 발생하지 않습니다.