Azure SQL Server与Fabric数据仓库SQL Server延迟差异问题排查

我正将应用的数据源从Azure SQL Server迁移至Fabric Datawarehouse，但发现二者的延迟差异极大。为此编写了测试程序，通过1000次往返调用简单T-SQL语句并记录耗时测试性能。测试环境如下：

• Azure SQL Server位于西欧，Fabric Datawarehouse SQL Server位于北欧
• 两台Azure VM客户端分别位于西欧、北欧

测试结果：

• 西欧客户端：Azure SQL Server耗时2秒，Fabric SQL Server耗时27秒
• 北欧客户端：Azure SQL Server耗时17秒，Fabric SQL Server耗时17秒

按预期客户端区域会影响延迟，但同区域的Fabric查询仍耗时17秒，而执行的SELECT 'Hello World'语句本身耗时极短，差异应源于延迟。请问Fabric端是否有可调整的设置？

测试程序代码：

Dim CurrConnection = New SqlConnection(SQL_CONNECTION_STRING)
With CurrConnection
    .Open()
    Dim SCommand As New SqlClient.SqlCommand
    With SCommand
        .Connection = CurrConnection
        Console.WriteLine("----------------------------CONNECTING TO SQL RUNNING 1000 HOOPS --------------------------------------------------------")
        Debug.Print(Now().ToString)
        Console.WriteLine(Now().ToString)

        For i = 1 To 1000
            .CommandText = "SELECT 'Hello World From SQL SERVER'"
            Dim p As Object = .ExecuteScalar()
            If i Mod 100 = 0 Then
                Console.WriteLine(i & " -  " & p.ToString)
            End If
        Next
    End With
    .Close()
End With
Console.WriteLine(Now().ToString)
Console.WriteLine("----------------------------FINSH CONNECTING TO SQL RUNNING 1000 CALL--------------------------------------------------------")

优化建议与设置调整方向 #

Fabric Datawarehouse主打大数据批量分析场景，单条小查询的往返延迟表现和OLTP定位的Azure SQL Server存在差异，可从以下维度调整优化：

1. 连接层优化 #

• 确认连接池启用：连接字符串默认开启连接池，可显式配置Pooling=true;Max Pool Size=100;，避免每次请求重建连接的额外开销。
• 配置Azure Private Link：若客户端VM与Fabric同属一个Azure租户，通过Private Link让流量走Azure内网，绕开公网传输，降低网络延迟。
• 使用专用SQL终结点：连接Fabric Datawarehouse时选择专用SQL终结点，而非通用终结点，专用终结点针对分析场景做了优化，延迟更低。

2. 查询执行优化 #

• 批量执行减少往返：你的测试是1000次单查询往返，这在Fabric场景下效率极低。可将多条查询合并为批量执行，比如用UNION ALL拼接或使用表值参数，大幅减少网络交互次数。
• 避免冷启动延迟：若使用Serverless层级的Fabric Datawarehouse，空闲后资源会释放，再次请求需重新调度。可切换到Provisioned（预留）层级，固定分配计算资源，消除冷启动带来的额外延迟。

3. 代码优化示例 #

将单循环查询改为批量执行的代码示例：

Dim CurrConnection = New SqlConnection(SQL_CONNECTION_STRING)
With CurrConnection
    .Open()
    Dim SCommand As New SqlClient.SqlCommand
    With SCommand
        .Connection = CurrConnection
        Console.WriteLine("----------------------------CONNECTING TO SQL RUNNING BATCH QUERIES --------------------------------------------------------")
        Console.WriteLine(Now().ToString)

        ' 构建1000条查询的批量语句
        Dim sb As New StringBuilder()
        For i = 1 To 1000
            sb.Append("SELECT 'Hello World From SQL SERVER';")
        Next
        .CommandText = sb.ToString()
        
        ' 执行批量查询并统计结果
        Dim reader As SqlDataReader = .ExecuteReader()
        Dim count As Integer = 0
        While reader.Read()
            count += 1
            If count Mod 100 = 0 Then
                Console.WriteLine(count & " -  " & reader(0).ToString)
            End If
        End While
        reader.Close()
    End With
    .Close()
End With
Console.WriteLine(Now().ToString)
Console.WriteLine("----------------------------FINISHED CONNECTING TO SQL RUNNING BATCH CALLS--------------------------------------------------------")

补充说明 #

Fabric Datawarehouse的设计核心是处理大规模数据的批量分析，而非高频小查询的OLTP场景。如果你的应用以OLTP业务为主，建议评估混合架构方案：Azure SQL Server负责OLTP业务，Fabric Datawarehouse承接数据分析需求，最大化发挥各自的优势。

内容的提问来源于stack exchange，提问作者perove