Fabric Eventstream의 콘텐츠를 기반으로 데이터 스트림 라우팅(미리 보기)
이 문서에서는 Microsoft Fabric Eventstream의 콘텐츠를 기반으로 이벤트를 라우팅하는 방법을 보여줍니다.
이제 Fabric Eventstream 기본 캔버스에서 노코드 편집기를 사용하여 코드를 작성하지 않고 복잡한 스트림 처리 논리를 만들 수 있습니다. 이 기능을 사용하면 데이터 스트림을 보다 쉽게 조정, 변환 및 관리할 수 있습니다. 스트림 처리 작업을 설정한 후에는 특정 스키마 및 스트림 데이터에 따라 데이터 스트림을 다른 목적지로 원활하게 보낼 수 있습니다.
Important
Fabric Eventstream의 향상된 기능은 현재 미리 보기에서 제공됩니다.
지원되는 작업
다음은 실시간 데이터 처리에 지원되는 작업 목록입니다.
집계: 값 열에서 계산을 수행하고 단일 결과를 반환하는 SUM, AVG, MIN 및 MAX 함수를 지원합니다.
확장: 배열 값을 확장하고 배열 내 각 값에 대해 새 행을 만듭니다.
필터: 조건에 따라 데이터 스트림에서 특정 행을 선택하거나 필터링합니다.
그룹화(기준별): 하나 이상의 열을 그룹화하는 옵션을 사용하여 특정 기간의 모든 이벤트 데이터를 집계합니다.
필드 관리: 데이터 스트림의 필드 또는 열의 데이터 형식을 추가, 제거 또는 변경합니다.
합집합: 이름과 데이터 형식이 동일한 공유 필드가 있는 둘 이상의 데이터 스트림을 하나의 데이터 스트림에 연결합니다. 일치하지 않는 필드는 삭제됩니다.
조인: 두 스트림 간의 일치 조건을 기반으로 두 스트림의 데이터를 결합합니다.
지원되는 목적지
지원되는 목적지는 다음과 같습니다.
레이크하우스: 이 목적지는 레이크하우스로 수집하기 전에 실시간 이벤트를 변환하는 기능을 제공합니다. 실시간 이벤트는 Delta Lake 형식으로 변환된 다음, 지정된 레이크하우스 테이블에 저장됩니다. 이 목적지는 데이터 웨어하우징 시나리오에 유용합니다.
KQL 데이터베이스: 이 목적지를 사용하면 강력한 KQL(Kusto 쿼리 언어)을 사용하여 데이터를 쿼리하고 분석할 수 있는 KQL 데이터베이스로 실시간 이벤트 데이터를 수집할 수 있습니다. KQL 데이터베이스의 데이터를 사용하여 이벤트 데이터에 대한 심층적인 인사이트를 얻고 풍부한 보고서 및 대시보드를 만들 수 있습니다.
Reflex: 이 목적지를 사용하면 실시간 이벤트 데이터를 Reflex에 직접 연결할 수 있습니다. Reflex는 데이터에 연결하고, 조건을 모니터링하며, 작업을 수행하는 데 필요한 모든 정보를 포함하는 지능형 에이전트 유형입니다. 데이터가 특정 임계치에 도달하거나 다른 패턴과 일치하면 Reflex는 사용자 경고 전송 또는 Power Automate 워크플로 시작 등 적절한 작업을 자동으로 수행합니다.
사용자 지정 엔드포인트(이전의 사용자 지정 앱): 이 목적지를 사용하면 실시간 이벤트를 사용자 지정 애플리케이션으로 쉽게 라우팅할 수 있습니다. 이 목적지를 사용하면 자체 애플리케이션을 Eventstream에 연결하고 이벤트 데이터를 실시간으로 사용할 수 있습니다. 실시간 데이터를 Microsoft Fabric 외부의 외부 시스템으로 송신하려는 경우에 유용합니다.
스트림: 이 목적지는 파생 스트림이라고도 하는 일련의 작업으로 변환되는 기본 원시 Eventstream을 나타냅니다. 만든 후에는 실시간 허브에서 스트림을 볼 수 있습니다.
다음 예제에서는 세 개의 개별 Fabric Eventstream 목적지가 단일 데이터 스트림 원본에 대해 별도의 함수 역할을 수행하는 방법을 보여줍니다. 하나의 KQL 데이터베이스는 원시 데이터를 저장하기 위해 지정되고, 두 번째 KQL 데이터베이스는 필터링된 데이터 스트림을 보존하기 위해 지정되며, 레이크하우스는 집계된 값을 저장하는 데 사용됩니다.
콘텐츠를 기반으로 데이터 스트림을 변환하고 라우팅하려면 Eventstream 편집 및 게시의 단계를 수행하고 데이터 스트림에 대한 스트림 처리 논리 디자인을 시작합니다.