启用Azure SQL Server Ledger致Azure函数执行挂起的解决问询

启用Ledger的Azure SQL会额外维护不可篡改的账本日志，单条循环操作的开销会被大幅放大，导致事务超时、执行挂起。针对你的场景，可通过以下代码优化解决问题：

1. 用批量操作替代单条循环写入 #

单条循环插入/更新会产生大量小事务，每个事务都要写入账本日志，累积开销导致超时。改用批量操作减少数据库往返次数，降低日志生成频率。

示例：批量插入ByTactic表 #

替换原有的foreach单条插入：

using (IDbConnection conn = new SqlConnection(connectionString))
{
    conn.Open();
    using (var transaction = conn.BeginTransaction())
    {
        // 全表删除时添加TABLOCK提示，减少锁竞争
        await conn.ExecuteAsync(@"DELETE FROM ByTactic WITH (TABLOCK)", null, transaction, commandTimeout: 600);
        
        // 批量插入SQL
        string batchInsertSql = @"
            INSERT INTO ByTactic (MSID, UMSID, Publisher, Created, Modified)
            VALUES (@MSID, @UMSID, @Publisher, GETDATE(), GETDATE());
        ";
        
        // 一次性传入整个列表，Dapper会自动处理批量参数
        await conn.ExecuteAsync(batchInsertSql, bggbytactics, transaction, commandTimeout: 600);
        
        transaction.Commit();
    }
}

2. 合并事务减少提交次数 #

将原本独立的单条操作合并到一个事务中，避免每个单条操作都触发一次账本日志写入。针对Upsert场景，可使用表值参数（TVP）实现批量处理：

步骤1：创建SQL表值类型 #

先在Azure SQL中创建对应的数据类型：

CREATE TYPE CallTransferLogTVP AS TABLE (
    SharePointSourceID INT,
    SRBrokerName NVARCHAR(100),
    Log NVARCHAR(MAX)
);

步骤2：修改C#代码实现批量Upsert #

private async Task UpsertCallTransferHistoryLogToSqlServer(List<CallTransferLogData> callTransferLogData)
{
    using (IDbConnection conn = new SqlConnection(connectionString))
    {
        conn.Open();
        using (var transaction = conn.BeginTransaction())
        {
            await conn.ExecuteAsync(@"DELETE FROM CallTransfer WITH (TABLOCK)", null, transaction, commandTimeout: 600);
            
            // 构建表值参数
            var tvp = new DataTable();
            tvp.Columns.Add("SharePointSourceID", typeof(int));
            tvp.Columns.Add("SRBrokerName", typeof(string));
            tvp.Columns.Add("Log", typeof(string));
            
            foreach (var item in callTransferLogData)
            {
                tvp.Rows.Add(item.SharePointSourceID, item.SRBrokerName, item.Log);
            }
            
            // 批量MERGE SQL
            string batchMergeSql = @"
                MERGE INTO CallTransfer AS target
                USING @TVP AS source
                ON target.SharePointSourceID = source.SharePointSourceID
                WHEN MATCHED THEN 
                    UPDATE SET 
                        SRBrokerName = source.SRBrokerName,
                        Log = source.Log,
                        Modified = GETDATE()
                WHEN NOT MATCHED THEN 
                    INSERT (SRBrokerName, Log, SharePointSourceID, Created, Modified)
                    VALUES (source.SRBrokerName, source.Log, source.SharePointSourceID, GETDATE(), GETDATE());
            ";
            
            await conn.ExecuteAsync(batchMergeSql, new { TVP = tvp.AsTableValuedParameter("CallTransferLogTVP") }, transaction, commandTimeout: 600);
            
            transaction.Commit();
        }
    }
    await SQLInteraction(new Log { Status = "End SQL Interaction for Call Transfer History Log" }, false);
}

3. 调整超时与连接参数 #

Ledger操作的耗时比普通SQL更长，需针对性调整参数：

• 将commandTimeout从300秒（5分钟）调整为600秒（10分钟）或更高
• 连接字符串添加Connect Timeout=30确保连接建立不超时，Max Pool Size=100（按需调整）

4. 优化全表删除操作 #

Ledger表不支持TRUNCATE TABLE，全表删除时添加WITH (TABLOCK)提示，让SQL Server采用更高效的锁策略，减少锁等待时间。

核心原理 #

Ledger表每次写入都会在对应的系统账本表中生成一条不可篡改的记录，单条循环操作会产生数千个小事务，每个事务都要写入账本日志，导致IO开销急剧上升。批量操作和事务合并能大幅减少事务数量，降低账本日志的总写入量，从而避免超时挂起。

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