SQL 코드 편집기를 사용하여 이벤트 처리(미리 보기)

SQL 코드 편집기 일명 SQL 연산자(미리 보기)는 Fabric Eventstream 내의 새로운 데이터 변환 기능입니다. SQL 연산자는 간단한 SQL 식을 사용하여 사용자 지정 데이터 변환 논리를 쉽게 정의할 수 있는 코드 편집 환경을 제공합니다. 이 문서에서는 Eventstream에서 데이터 변환에 SQL 코드 편집기를 사용하는 방법을 설명합니다.

Prerequisites

시작하기 전에 다음 전제 조건을 완료해야 합니다.

• Fabric의 용량 라이선스 모드 또는 평가판 라이선스 모드에서 참가자 이상의 권한으로 작업 공간에 액세스합니다.

Eventstream에 SQL 코드 편집기 추가

SQL 연산자를 사용하여 데이터 스트림에서 스트림 처리 작업을 수행하려면 다음 지침을 사용하여 이벤트 스트림에 SQL 연산자를 추가합니다.

1. 다음 옵션 중 하나를 사용하여 새 eventstream을 만들고 이벤트 스트림에 SQL 연산자를 추가합니다.

   • 위쪽 리본의 이벤트 변환 단추를 사용하여 SQL 연산자를 추가합니다.

     

   • 캔버스의 대상 추가 단추를 통해 SQL 연산자를 추가합니다.

     

2. 선택되면 새 SQL 노드가 eventstream에 추가됩니다. 연필 아이콘을 선택하여 SQL 연산자 설정을 완료합니다.

   

3. SQL Code 창에서 eventstream에서 SQL 연산자 노드의 고유한 이름을 지정합니다.

4. 쿼리 창에서 쿼리를 편집하거나 쿼리 편집 을 선택하여 전체 화면 코드 편집기 보기를 입력합니다.

   

5. 전체 화면 코드 편집기 모드는 왼쪽에 입력/출력 탐색기 패널을 제공합니다. 코드 편집기 섹션을 조정할 수 있으므로 기본 설정에 따라 크기를 조정할 수 있습니다. 아래쪽의 미리 보기 섹션을 사용하면 입력 데이터와 쿼리 테스트 결과를 모두 볼 수 있습니다.

   

6. 출력 섹션에서 텍스트를 선택하고 대상 노드의 이름을 입력합니다. SQL 연산자는 Eventhouse, Lakehouse, Activator, Stream 등 모든 Real-Time 인텔리전스 대상을 지원합니다.

   

7. SQL 연산자를 통해 처리된 데이터가 기록되는 출력 대상의 별칭 또는 이름을 지정합니다.

   

8. 다음으로 필요한 데이터 변환에 대한 SQL 쿼리 를 추가합니다.

   Eventstream은 Azure Stream Analytics를 기반으로 하며 Stream Analytics 쿼리 언어의 동일한 쿼리 의미 체계를 지원합니다. 구문 및 사용에 대한 자세한 내용은 Stream Analytics 쿼리 언어 참조 - Stream Analytics 쿼리 | Microsoft Learn.

   기본 쿼리 구조:

   SELECT 
   
       column1, column2, ... 
   
   INTO 
   
       [output alias] 
   
   FROM 
   
       [input alias] 
   

   Query examples:

   1분마다 실내에서 고온 감지:

   
       SELECT 
       System.Timestamp AS WindowEnd, 
       roomId, 
       AVG(temperature) AS AvgTemp 
   INTO 
       output 
   FROM 
       input 
   GROUP BY 
       roomId, 
       TumblingWindow(minute, 1) 
   HAVING 
       AVG(temperature) > 75 
   

   CASE 문을 사용하여 온도를 분류합니다.

   SELECT
       deviceId, 
       temperature, 
       CASE  
           WHEN temperature > 85 THEN 'High' 
           WHEN temperature BETWEEN 60 AND 85 THEN 'Normal' 
           ELSE 'Low' 
       END AS TempCategory 
   INTO 
       CategorizedTempOutput 
   FROM 
       SensorInput 
   

9. 위쪽 리본의 쿼리 테스트 단추를 사용하여 변환 논리의 유효성을 검사합니다. 테스트 쿼리 결과는 아래쪽의 테스트 결과 섹션 아래에 표시됩니다.

   

10. 완료되면 맨 위에 있는 리본에서 저장 을 선택하여 eventstream 캔버스로 돌아갑니다.

    

11. SQL Code 창에서 저장 단추를 사용하도록 설정한 경우 이 단추를 선택하여 설정을 저장합니다.

    

12. 목적지를 구성합니다.

    

Limitations

1. SQL 연산자는 모든 변환 논리를 한 곳에서 중앙 집중화하도록 설계되었습니다. 따라서 동일한 처리 경로 내의 다른 기본 제공 연산자와 함께 사용할 수 없습니다. 단일 경로에 여러 SQL 연산자를 연결하는 것도 지원되지 않습니다. 또한 SQL 연산자는 토폴로지의 대상 노드에만 데이터를 출력할 수 있습니다.

2. 현재 Eventstream 토폴로지 작성은 UX(사용자 인터페이스)를 통해서만 지원됩니다. SQL 운영자에 대한 REST API 지원이 계획되어 있으며 향후 릴리스에서 사용할 수 있습니다.

Related content

• Eventstream에서 목적지 추가 및 관리.