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