将 SQL 上的 Direct Lake 转换到 OneLake
脚本用途
此脚本会将使用 Direct Lake on SQL (DL/SQL) 的模型转换为 Direct Lake on OneLake (DL/OL)。 如 Direct Lake 指南文章 所述，这只需更新模型中 Direct Lake 分区使用的共享表达式上的 M 查询，使其使用 AzureStorage.DataLake 连接器，而不是 Sql.Database 连接器。
先决条件
你需要 Workspace ID，以及 Fabric Warehouse 或 Lakehouse 的 Resource ID。 这两个值都是 GUID，在 Fabric 门户中导航到 Warehouse 或 Lakehouse 时，它们会出现在 URL 中：
在上面的截图中，Lakehouse 的 Workspace ID 用蓝色标出，而 Resource ID 用绿色标出。
脚本
将 Direct Lake on SQL 转换为 OneLake
// ==================================================================
// Convert Direct Lake on SQL to OneLake
// -------------------------------------
//
// This script detects if the current model uses Direct Lake on SQL
// and suggests to upgrade the model to Direct Lake on OneLake.
//
// You will need the Workspace ID and the ID of your Fabric Warehouse
// or Lakehouse (both are GUIDs).
// ==================================================================
// Find the Shared Expression that is being used by EntityPartitions on the model:
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("Your model does not seem to contain any tables in Direct Lake mode.");
return;
}
if (!expressionSource.Expression.Contains("Sql.Database"))
{
Warning("This model is not configured for Direct Lake over 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("Model successfully converted to Direct Lake on OneLake. You may need to deploy it as a new semantic model, since the model collation was modified.");
}
else
Info("Model successfully converted to Direct Lake on OneLake.");
// UI code below this line:
public class UrlNameDialog : Form
{
public TextBox WorkspaceId { get; private set; }
public TextBox ResourceId { get; private set; }
private Button okButton;
public UrlNameDialog()
{
Text = "Convert Direct Lake on SQL to 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 = "Workspace ID (GUID):", AutoSize = true });
WorkspaceId = new TextBox { Width = 1000 };
mainLayout.Controls.Add(WorkspaceId);
// Resource ID
mainLayout.Controls.Add(new Label { Text = "Fabric Warehouse / Lakehouse ID (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 = "Cancel", 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);
}
}
说明
该脚本首先会尝试定位一个配置为 Direct Lake 模式且具有 Expression Source（指向 Shared Expression 的引用）的 EntityPartition 分区。 如果找不到此类分区，脚本会显示一条警告信息并退出。 此外，被引用的共享表达式必须指定 Sql.Database 连接器，这表明该模型当前正在使用 Direct Lake on SQL。
脚本确认模型使用 Direct Lake on SQL 后，会提示用户输入 Fabric Warehouse 或 Lakehouse 的 Workspace ID 和 Resource ID。 随后，脚本会在共享表达式中将 Sql.Database 连接器替换为 AzureStorage.DataLake 连接器，并使用所提供的 ID。
最后，如果模型已设置排序规则，脚本会将其清除，因为此更改需要新的排序规则。 随后，脚本会通知用户，该模型已成功转换为 OneLake 上的 Direct Lake。