如何用SQL循环批量处理多复制发布的延迟告警逻辑？

核心思路 #

把分散的单个延迟变量统一存入表结构（表变量/临时表），通过游标循环遍历处理每个发布的延迟告警，同时实现全局状态判断（全部正常时发送单封邮件）。

具体实现步骤 #

1. 统一存储所有发布的延迟数据 #

先创建一个表变量，将各个发布的名称和对应的延迟分钟数存入其中，方便后续批量处理：

DECLARE @ReplicationDelays TABLE (
    PublicationName NVARCHAR(100), -- 发布名称，用于识别异常发布
    DelayMinutes INT -- 计算得到的延迟分钟数
)

-- 插入所有发布的延迟数据，替换成你的实际发布名称和变量
INSERT INTO @ReplicationDelays
VALUES
    ('订单数据发布', @DifferenceMinutes1),
    ('用户数据发布', @DifferenceMinutes2),
    ('商品数据发布', @DifferenceMinutes3),
    ('日志数据发布', @DifferenceMinutes4),
    ('报表数据发布', @DifferenceMinutes5),
    ('配置数据发布', @DifferenceMinutes6)

2. 判断全局状态并发送对应邮件 #

先检查所有发布的延迟是否都≤1分钟，如果是则发送单封“一切正常”邮件；否则遍历每个异常发布，根据延迟区间发送对应告警：

-- 检查是否所有发布都正常
IF NOT EXISTS (SELECT 1 FROM @ReplicationDelays WHERE DelayMinutes > 1)
BEGIN
    -- 发送全局正常邮件，替换成你的邮件配置
    EXEC msdb.dbo.sp_send_dbmail
        @profile_name = '你的数据库邮件配置文件',
        @recipients = 'alerts@yourcompany.com',
        @subject = 'SQL复制状态通知：全部正常',
        @body = '所有SQL复制发布的延迟均≤1分钟，系统运行正常。'
END
ELSE
BEGIN
    -- 声明游标遍历异常发布
    DECLARE @CurrentPub NVARCHAR(100), @CurrentDelay INT
    DECLARE pub_alarm_cursor CURSOR FOR
        SELECT PublicationName, DelayMinutes
        FROM @ReplicationDelays
        WHERE DelayMinutes > 1 -- 只处理延迟超标的发布

    OPEN pub_alarm_cursor
    FETCH NEXT FROM pub_alarm_cursor INTO @CurrentPub, @CurrentDelay

    -- 循环处理每个异常发布
    WHILE @@FETCH_STATUS = 0
    BEGIN
        BEGIN TRY
            -- 根据延迟区间发送对应告警邮件
            IF @CurrentDelay > 1 AND @CurrentDelay <= 5
            BEGIN
                -- 发送"延迟增长预警"邮件
                EXEC msdb.dbo.sp_send_dbmail
                    @profile_name = '你的数据库邮件配置文件',
                    @recipients = 'alerts@yourcompany.com',
                    @subject = '【预警】SQL复制发布延迟增长 - ' + @CurrentPub,
                    @body = '发布名称：' + @CurrentPub + CHAR(13) + CHAR(10)
                          + '当前延迟：' + CAST(@CurrentDelay AS NVARCHAR(10)) + ' 分钟' + CHAR(13) + CHAR(10)
                          + '告警说明：可能出现延迟增长，请关注。'
            END
            ELSE IF @CurrentDelay > 5 AND @CurrentDelay <= 15
            BEGIN
                -- 发送"延迟过高告警"邮件
                EXEC msdb.dbo.sp_send_dbmail
                    @profile_name = '你的数据库邮件配置文件',
                    @recipients = 'alerts@yourcompany.com',
                    @subject = '【严重告警】SQL复制发布延迟过高 - ' + @CurrentPub,
                    @body = '发布名称：' + @CurrentPub + CHAR(13) + CHAR(10)
                          + '当前延迟：' + CAST(@CurrentDelay AS NVARCHAR(10)) + ' 分钟' + CHAR(13) + CHAR(10)
                          + '告警说明：延迟已超过5分钟，请立即排查处理。'
            END
            -- 可选：添加延迟>15分钟的告警逻辑
            -- ELSE IF @CurrentDelay >15
            -- BEGIN
            --     -- 发送更高级别的告警
            -- END
        END TRY
        BEGIN CATCH
            -- 捕获错误，避免单个发布处理失败中断整个循环，可选记录错误日志
            INSERT INTO dbo.ReplicationAlarmErrors (
                ErrorMsg, PublicationName, CreateTime
            )
            VALUES (
                ERROR_MESSAGE(), @CurrentPub, GETDATE()
            )
        END CATCH

        -- 取下一个发布
        FETCH NEXT FROM pub_alarm_cursor INTO @CurrentPub, @CurrentDelay
    END

    -- 关闭并释放游标
    CLOSE pub_alarm_cursor
    DEALLOCATE pub_alarm_cursor
END

关键注意事项 #

• 边界条件确认：根据你的规则，≤1分钟不处理，所以异常判断用DelayMinutes >1；1-5分钟对应>1 AND <=5，5-15分钟对应>5 AND <=15，可根据实际需求调整。
• 扩展性：后续新增发布时，只需在INSERT INTO @ReplicationDelays语句中添加一行新的发布名称和对应的延迟变量即可，无需新增作业步骤。
• 容错性：使用TRY/CATCH块确保单个发布的告警处理失败时，不会中断整个循环，其他发布的告警仍能正常发送。
• 邮件配置：替换代码中的@profile_name、@recipients为你的实际数据库邮件配置和收件人信息。

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