Convertir Direct Lake sobre SQL a OneLake

• 2025-06-20
• Daniel Otykier

Applies to:

• ✔ Tabular Editor 2
• ✔ Tabular Editor 3

Propósito del script

Este script convierte un modelo que usa Direct Lake en SQL (DL/SQL) a Direct Lake en OneLake (DL/OL). Tal como se indica en el artículo de directrices de Direct Lake, esto consiste simplemente en actualizar la consulta M de la Shared Expression que usan las particiones de Direct Lake del modelo para que use el conector AzureStorage.DataLake en lugar del conector Sql.Database.

Requisitos previos

Necesitarás el ID del Workspace y el ID del recurso de tu Warehouse o Lakehouse de Fabric. Ambos son GUID que aparecen en la URL cuando navegas al Warehouse o Lakehouse en el portal de Fabric:

En la captura de pantalla anterior, el ID del Workspace del Lakehouse está resaltado en azul, mientras que el ID de recurso está resaltado en verde.

Script

Convertir Direct Lake sobre SQL a OneLake

// ==================================================================
// Convertir Direct Lake en SQL a OneLake
// -------------------------------------
// 
// Este script detecta si el modelo actual usa Direct Lake sobre SQL
// y sugiere actualizar el modelo a Direct Lake en OneLake.
//
// Necesitarás el ID del Workspace y el ID de tu Fabric Warehouse
// o Lakehouse (ambos son GUID).
// ==================================================================

// Busca la Shared Expression que usan las EntityPartitions del modelo:
using System.Windows.Forms;
using System.Drawing;

var partition = Model.AllPartitions.OfType<EntityPartition>()
    .FirstOrDefault(e => e.Mode == ModeType.DirectLake && e.ExpressionSource != null);
var expressionSource = partition == null ? null : partition.ExpressionSource;

if (expressionSource == null)
{
    Warning("Parece que tu modelo no contiene ninguna tabla en modo Direct Lake.");
    return;
}

if (!expressionSource.Expression.Contains("Sql.Database"))
{
    Warning("Este modelo no está configurado para Direct Lake sobre SQL.");
    return;
}

WaitFormVisible = false;
Application.UseWaitCursor = false;
var promptDialog = new UrlNameDialog();
if(promptDialog.ShowDialog() == DialogResult.Cancel) return;

const string mTemplate = @"let
    Source = AzureStorage.DataLake(""https://onelake.dfs.fabric.microsoft.com/%workspaceId%/%resourceId%"", [HierarchicalNavigation=true])
in
    Source";

expressionSource.Expression = mTemplate.Replace("%workspaceId%", promptDialog.WorkspaceId.Text).Replace("%resourceId%", promptDialog.ResourceId.Text);

if(!string.IsNullOrEmpty(Model.Collation))
{
    Model.Collation = null;
    Info("El modelo se convirtió correctamente a Direct Lake en OneLake. Quizá tengas que implementarlo como un nuevo modelo semántico, ya que se modificó la intercalación del modelo.");
}
else
    Info("El modelo se convirtió correctamente a Direct Lake en OneLake.");

// Código de la interfaz de usuario a partir de aquí:
public class UrlNameDialog : Form
{
    public TextBox WorkspaceId { get; private set; }
    public TextBox ResourceId { get; private set; }
    private Button okButton;

    public UrlNameDialog()
    {
        Text = "Convertir Direct Lake en SQL a OneLake";
        AutoSize = true;
        AutoSizeMode = AutoSizeMode.GrowAndShrink;
        StartPosition = FormStartPosition.CenterParent;
        Padding = new Padding(20);

        var mainLayout = new TableLayoutPanel
        {
            ColumnCount = 1,
            RowCount = 3,
            Dock = DockStyle.Fill,
            AutoSize = true,
            AutoSizeMode = AutoSizeMode.GrowAndShrink
        };
        Controls.Add(mainLayout);

        // Workspace ID
        mainLayout.Controls.Add(new Label { Text = "ID del Workspace (GUID):", AutoSize = true });
        WorkspaceId = new TextBox { Width = 1000 };
        mainLayout.Controls.Add(WorkspaceId);

        // Resource ID
        mainLayout.Controls.Add(new Label { Text = "ID de Fabric Warehouse / Lakehouse (GUID):", AutoSize = true, Padding = new Padding(0, 20, 0, 0) });
        ResourceId = new TextBox { Width = 1000 };
        mainLayout.Controls.Add(ResourceId);

        // Buttons
        var buttonPanel = new FlowLayoutPanel
        {
            Padding = new Padding(0, 20, 0, 0),
            FlowDirection = FlowDirection.RightToLeft,
            Dock = DockStyle.Fill,
            AutoSize = true
        };

        okButton = new Button { Text = "OK", DialogResult = DialogResult.OK, AutoSize = true, Enabled = false };
        var cancelButton = new Button { Text = "Cancelar", DialogResult = DialogResult.Cancel, AutoSize = true };
        buttonPanel.Controls.Add(okButton);
        buttonPanel.Controls.Add(cancelButton);

        AcceptButton = okButton;
        CancelButton = cancelButton;
        mainLayout.Controls.Add(buttonPanel);

        WorkspaceId.TextChanged += Validate;
        ResourceId.TextChanged += Validate;
    }
    
    private void Validate(object sender, EventArgs e)
    {
        Guid g;
        okButton.Enabled = Guid.TryParse(WorkspaceId.Text, out g) && Guid.TryParse(ResourceId.Text, out g);
    }
}

Explicación

El script primero intenta localizar un EntityPartition que esté configurado en modo Direct Lake y que tenga un Expression Source (una referencia a una Shared Expression). Si no se encuentra ninguna partición de ese tipo, muestra un mensaje de advertencia y finaliza. Además, la Shared Expression a la que se hace referencia debe especificar el conector Sql.Database, lo que indica que el modelo está usando actualmente Direct Lake en SQL.

Cuando el script confirma que el modelo usa Direct Lake en SQL, solicita al usuario que introduzca el ID del Workspace y el ID de recurso del Warehouse o Lakehouse de Fabric. A continuación, el script reemplaza el conector Sql.Database de la Shared Expression por el conector AzureStorage.DataLake, utilizando los ID proporcionados.

Por último, si el modelo tiene una intercalación definida, la borra, ya que este cambio requiere una nueva intercalación. A continuación, el script informa al usuario de que el modelo se ha convertido correctamente a Direct Lake en OneLake.