【进阶实战】服务器宕机：硬件故障停服的复盘与修复封装

local function reconcileAfterFailover(fromTs, toTs)
    local primary = queryMaster("SELECT id,amount FROM trades WHERE ts BETWEEN " ..
        fromTs .. " AND " .. toTs)
    local backup = queryBackup("SELECT id,amount FROM trades WHERE ts BETWEEN " ..
        fromTs .. " AND " .. toTs)
    local missing = {}
    for _, p in ipairs(primary) do
        local found = false
        for _, b in ipairs(backup) do
            if b.id == p.id then
                found = true
                break
            end
        end
        if not found then
            missing[#missing + 1] = p
        end
    end
    for _, m in ipairs(missing) do
        insertBackup(m.id, m.amount)
    end
    return #missing
end

registerMetric("disk_health", function()
    return diskSmartStatus()
end, 1, "lt")