03. Fabric 실시간 분석

이전 포스팅에서 로드한 스트리밍 데이터를 KQL 및 SQL 쿼리를 사용하여 살펴 보겠습니다. 

2024.03.07 - [Microsoft Fabric/Fabric 실습 5 - 실시간 분석] - 02. Fabric 실시간 분석

 

Kusto 쿼리의 기본적인 함수를 사용해 봅니다. 

• take
• getschema
• summarize
• count

 

이전 포스팅에서 구성한 KQL 데이터베이스로 이동합니다. 

Eventstream으로 가져온 데이터 테이블 끝의 더보기 아이콘(...)을 클릭하여 Query table을 선택하고 Show any 100 records를 클릭합니다. 

 

상위 100개의 레코드를 확인하는 Kusto 쿼리 take 100이 실행되고 상위 100개 레코드가 표시됩니다. 

nyctaxitrips3
| take 100

 

테이블 스키마를 검색할 때는 getschema 연산자를 사용합니다. 

nyctaxitrips3
| getschema

 

summarize 함수를 사용하여 마지막 레코드 수집일을 확인해 봅니다. 

쿼리 편집기에서는 자동 완성 기능이 제공됩니다. 

nyctaxitrips3
| summarize LastIngestionTime = max(ingestion_time())

 

count 연산자를 사용하여 테이블 레코드 수를 확인해 봅니다. 

nyctaxitrips3
| count

 

함수를 조합하여 시간당 수집 수를 반환하는 쿼리를 실행해 봅니다. 

nyctaxitrips3
| summarize IngestionCount = count() by bin(ingestion_time(), 1h)

 

쿼리 편집기에서는 기본 쿼리 언어인 KQL(Kusto 쿼리 언어) 외에도 T-SQL 사용을 지원합니다.

 

Eventstream으로 가져온 데이터 테이블 끝의 더보기 아이콘(...)을 클릭하여 Query table을 선택하고 SQL클릭, Show any 100 records를 클릭합니다. 

 

SQL 쿼리도 작성해서 실행해 볼 수 있습니다.