direct-lake-operations

작성자: microsoft

Direct Lake 의미 모델 작업을 위한 가이드입니다. Direct Lake 관련 기능을 구현하거나 문제를 해결할 때 사용하세요.

npx skills add https://github.com/microsoft/semantic-link-labs --skill direct-lake-operations

Direct Lake Operations

This skill covers working with Direct Lake semantic models in Semantic Link Labs.

When to Use This Skill

Use this skill when you need to:

  • Migrate models to Direct Lake
  • Check and fix Direct Lake fallback issues
  • Sync schema between lakehouse and model
  • Work with Direct Lake guardrails
  • Warm Direct Lake cache

Overview

Direct Lake is a storage mode for Power BI semantic models that reads data directly from Delta tables in OneLake, providing fast query performance without data import.

Key Files

FilePurpose
src/sempy_labs/directlake/Direct Lake submodule
_dl_helper.pyCore Direct Lake utilities
_guardrails.pyGuardrail checking
_directlake_schema_sync.pySchema synchronization
_warm_cache.pyCache warming utilities

Direct Lake Functions

Core Functions

FunctionPurpose
check_fallback_reasonCheck why model falls back to DirectQuery
get_direct_lake_lakehouseGet lakehouse connected to model
get_direct_lake_sourceGet SQL endpoint and lakehouse info
generate_direct_lake_semantic_modelCreate new Direct Lake model

Schema Management

FunctionPurpose
direct_lake_schema_compareCompare model schema with lakehouse
direct_lake_schema_syncSync model schema from lakehouse

Guardrails

FunctionPurpose
get_direct_lake_guardrailsGet guardrail limits for model
get_sku_sizeGet SKU capacity info
get_directlake_guardrails_for_skuGet guardrails for specific SKU

Cache Management

FunctionPurpose
warm_direct_lake_cache_isresidentWarm cache using IsResident
warm_direct_lake_cache_perspectiveWarm cache using perspective

Connection Updates

FunctionPurpose
update_direct_lake_model_connectionUpdate lakehouse connection
update_direct_lake_model_lakehouse_connectionLegacy connection update

Checking Fallback Reasons

Direct Lake models can fall back to DirectQuery mode. Use check_fallback_reason to diagnose:

from sempy_labs.directlake import check_fallback_reason

# Check specific model
result = check_fallback_reason(
    dataset="My Direct Lake Model",
    workspace="My Workspace"
)

# Returns DataFrame with fallback reasons per table
print(result)

Common Fallback Reasons

ReasonCauseSolution
ColumnNotInPartitionColumn missing from Delta tableAdd column to lakehouse table
ParquetTypeMismatchData type mismatchUpdate lakehouse table schema
UnsupportedFilterDAX filter not supportedModify DAX query
GuardrailExceeded capacity limitsUpgrade capacity or reduce data

Schema Synchronization

Compare Schemas

from sempy_labs.directlake import direct_lake_schema_compare

# Compare model schema with lakehouse tables
comparison = direct_lake_schema_compare(
    dataset="My Direct Lake Model",
    workspace="My Workspace"
)

# Shows differences between model and lakehouse
print(comparison)

Sync Schema

from sempy_labs.directlake import direct_lake_schema_sync

# Sync model schema from lakehouse
direct_lake_schema_sync(
    dataset="My Direct Lake Model",
    workspace="My Workspace",
    add_columns=True,      # Add new columns
    remove_columns=False,  # Keep columns not in lakehouse
)

Guardrails

Direct Lake has limits based on capacity SKU:

from sempy_labs.directlake import get_direct_lake_guardrails

# Get guardrails for a model
guardrails = get_direct_lake_guardrails(
    dataset="My Direct Lake Model",
    workspace="My Workspace"
)

# Shows limits vs current values
print(guardrails)

Guardrail Limits

GuardrailDescription
Max Rows Per TableMaximum rows per table
Max Size Per TableMaximum table size in GB
Max Columns Per TableMaximum columns per table
Max Model SizeMaximum total model size

Generating Direct Lake Models

Create a new Direct Lake model from lakehouse tables:

from sempy_labs.directlake import generate_direct_lake_semantic_model

# Generate model from lakehouse
generate_direct_lake_semantic_model(
    dataset="New Direct Lake Model",
    lakehouse="My Lakehouse",
    workspace="My Workspace",
    lakehouse_workspace="Lakehouse Workspace",  # Optional
)

Updating Connections

Change the lakehouse a Direct Lake model points to:

from sempy_labs.directlake import update_direct_lake_model_connection

# Update to different lakehouse
update_direct_lake_model_connection(
    dataset="My Direct Lake Model",
    workspace="My Workspace",
    target_lakehouse="New Lakehouse",
    target_workspace="Target Workspace",
)

Cache Warming

Warm the Direct Lake cache after model refresh:

Using IsResident

from sempy_labs.directlake import warm_direct_lake_cache_isresident

# Warm columns that were previously in memory
warm_direct_lake_cache_isresident(
    dataset="My Direct Lake Model",
    workspace="My Workspace"
)

Using Perspective

from sempy_labs.directlake import warm_direct_lake_cache_perspective

# Warm columns defined in a perspective
warm_direct_lake_cache_perspective(
    dataset="My Direct Lake Model",
    perspective="Cache Warming",
    workspace="My Workspace"
)

Migration to Direct Lake

The library provides migration tools in src/sempy_labs/migration/:

Migration Workflow

  1. Migrate calculated tables to lakehouse as Delta tables
  2. Create Direct Lake model with same structure
  3. Migrate measures and other objects
  4. Validate and test

Example Migration

from sempy_labs.migration import (
    migrate_calctables_to_lakehouse,
    migrate_model_objects_to_semantic_model,
)

# Step 1: Migrate calculated tables to lakehouse
migrate_calctables_to_lakehouse(
    dataset="Source Import Model",
    workspace="My Workspace",
    lakehouse="Target Lakehouse",
    lakehouse_workspace="Lakehouse Workspace",
)

# Step 2: Migrate other objects (measures, etc.)
migrate_model_objects_to_semantic_model(
    source_dataset="Source Import Model",
    target_dataset="Target Direct Lake Model",
    source_workspace="My Workspace",
    target_workspace="My Workspace",
)

Best Practices

Do's

  • ✅ Always check guardrails before deploying
  • ✅ Use schema sync after lakehouse changes
  • ✅ Warm cache after scheduled refreshes
  • ✅ Monitor fallback reasons regularly

Don'ts

  • ❌ Don't ignore fallback warnings
  • ❌ Don't exceed guardrail limits
  • ❌ Don't modify lakehouse schema without syncing model
  • ❌ Don't use unsupported DAX patterns

Troubleshooting

Model Falls Back to DirectQuery

  1. Run check_fallback_reason() to identify cause
  2. Check column mappings with direct_lake_schema_compare()
  3. Verify data types match between model and lakehouse
  4. Check guardrails with get_direct_lake_guardrails()

Schema Mismatch

  1. Run direct_lake_schema_compare() to see differences
  2. Run direct_lake_schema_sync() to fix mismatches
  3. Verify partition entity mappings

Performance Issues

  1. Check cache state with warm_direct_lake_cache_isresident()
  2. Verify partitions are properly configured
  3. Review query patterns for unsupported filters

Related Resources

ResourceURL
Direct Lake OverviewMicrosoft Docs
GuardrailsMicrosoft Docs
Migration NotebookNotebook
API DocsReadTheDocs

microsoft의 다른 스킬

oss-growth
microsoft
OSS 성장 해커 페르소나
agent-framework-azure-ai-py
microsoft
Microsoft Agent Framework Python SDK(agent-framework-azure-ai)를 사용하여 Azure AI Foundry 에이전트를 구축합니다. AzureAIAgentsProvider로 지속적 에이전트를 만들 때, 호스팅 도구(코드 인터프리터, 파일 검색, 웹 검색)를 사용할 때, MCP 서버를 통합할 때, 대화 스레드를 관리할 때, 또는 스트리밍 응답을 구현할 때 사용합니다. 함수 도구, 구조화된 출력, 다중 도구 에이전트를 다룹니다.
development
airunway-aks-setup
microsoft
AKS에서 AI Runway 설정 — 빈 클러스터에서 실행 중인 모델까지. 클러스터 검증, 컨트롤러 설치, GPU 평가, 공급자 설정, 첫 배포를 다룹니다. 시기: "AI Runway 설정", "AKS 클러스터 온보딩", "AI Runway 설치", "airunway 설정", "AKS에 모델 배포", "AKS에서 GPU 추론", "AKS에서 KAITO 설정", "AKS에서 LLM 실행", "AKS에서 vLLM", "AKS에서 모델 서빙 설정", "AI Runway 컨트롤러".
devops
appinsights-instrumentation
microsoft
Azure Application Insights로 웹앱을 계측하기 위한 지침입니다. 원격 분석 패턴, SDK 설정, 구성 참조를 제공합니다. WHEN: 앱 계측 방법, App Insights SDK, 원격 분석 패턴, App Insights란 무엇인가, Application Insights 지침, 계측 예시, APM 모범 사례.
devops
applicationinsights-web-ts
microsoft
브라우저/웹 앱을 Application Insights JavaScript SDK(@microsoft/applicationinsights-web)로 계측합니다. Real User Monitoring(RUM) — 페이지 뷰, 클릭, AJAX/fetch 종속성, 예외, 사용자 지정 이벤트, 백엔드 OpenTelemetry 트레이스와 상관관계가 있는 브라우저 측 GenAI 에이전트 트레이스에 사용합니다. SDK Loader Script 및 npm 설정, 프레임워크 확장(React, React Native, Angular), Click Analytics, 텔레메트리 이니셜라이저, 브라우저에서 생성된 에이전트/도구/모델 스팬에 대한 OTel GenAI 의미론적 규칙을 다룹니다.
devops
azure-ai-anomalydetector-java
microsoft
Azure AI Anomaly Detector SDK for Java로 이상 탐지 애플리케이션을 구축하세요. 단변량/다변량 이상 탐지, 시계열 분석 또는 AI 기반 모니터링을 구현할 때 사용하세요.
development
azure-ai-language-conversations-py
microsoft
azure-ai-language-conversations Python SDK를 사용하여 대화형 언어 이해(CLU)를 구현합니다. ConversationAnalysisClient로 대화 의도와 엔터티를 분석하거나, NLP 기능을 구축하거나, 애플리케이션에 언어 이해를 통합할 때 사용합니다.
development
azure-ai-ml-py
microsoft
Azure Machine Learning SDK v2 for Python. ML 작업 영역, 작업, 모델, 데이터 세트, 컴퓨팅 및 파이프라인에 사용합니다. 트리거: "azure-ai-ml", "MLClient", "workspace", "model registry", "training jobs", "datasets".
development