SQL Server-Agent-Jobs und -Verfügbarkeitsgruppen

Ich suche nach bewährten Methoden für den Umgang mit geplanten SQL Server-Agent-Jobs in SQL Server 2012-Verfügbarkeitsgruppen. Vielleicht habe ich etwas verpasst, aber beim gegenwärtigen Stand habe ich das Gefühl, dass SQL Server Agent nicht wirklich in diese großartige SQL2012-Funktion integriert ist.

Wie kann ich einen geplanten SQL Agent-Job auf einen Knotenwechsel aufmerksam machen? Ich habe zum Beispiel einen Job auf dem primären Knoten, der stündlich Daten lädt. Wie kann ich nun den Job auf dem sekundären Server aktivieren, der jetzt zum primären Server wird, wenn der primäre Server ausfällt?

Wenn ich den Job immer auf der Sekundärseite einplane, schlägt dies fehl, da die Sekundärseite schreibgeschützt ist.

Verfügen Sie in Ihrem SQL Server-Agent-Auftrag über eine Bedingungslogik, um zu testen, ob die aktuelle Instanz die bestimmte Rolle erfüllt, nach der Sie in Ihrer Verfügbarkeitsgruppe suchen:

if (select
        ars.role_desc
    from sys.dm_hadr_availability_replica_states ars
    inner join sys.availability_groups ag
    on ars.group_id = ag.group_id
    where ag.name = 'YourAvailabilityGroupName'
    and ars.is_local = 1) = 'PRIMARY'
begin
    -- this server is the primary replica, do something here
end
else
begin
    -- this server is not the primary replica, (optional) do something here
end

Alles PRIMARY, was Sie tun müssen, ist, die aktuelle Rolle des lokalen Replikats abzurufen. Wenn diese in der Rolle enthalten ist, können Sie alles tun, was Ihr Job tun muss, wenn es sich um das primäre Replikat handelt. Der ELSEBlock ist optional, dient jedoch zur Behandlung möglicher Logik, wenn Ihre lokale Replik nicht primär ist.

Ändern Sie 'YourAvailabilityGroupName'in der obigen Abfrage natürlich den Namen Ihrer tatsächlichen Verfügbarkeitsgruppe.

Verwechseln Sie Verfügbarkeitsgruppen nicht mit Failoverclusterinstanzen. Ob die Instanz das primäre oder das sekundäre Replikat für eine bestimmte Verfügbarkeitsgruppe ist, wirkt sich nicht auf Objekte auf Serverebene aus, z. B. auf SQL Server-Agent-Jobs.

Anstatt dies auf Jobbasis zu tun (jeden Job auf den Status des Servers zu überprüfen, bevor Sie fortfahren), habe ich einen Job erstellt, der auf beiden Servern ausgeführt wird, um zu überprüfen, in welchem ​​Status sich der Server befindet.

• Wenn es sich um einen primären Job handelt, aktivieren Sie jeden Job, der einen Schritt für die Ausrichtung auf eine Datenbank in der AG enthält.
• Wenn der Server sekundär ist, deaktivieren Sie alle Jobs, die auf eine Datenbank in der AG abzielen.

Dieser Ansatz bietet eine Reihe von Dingen

• es funktioniert auf Servern, auf denen es keine Datenbanken in AG gibt (oder eine Mischung aus DBs in / out von AGs)
• Jeder kann einen neuen Job erstellen und muss sich keine Gedanken darüber machen, ob sich die Datenbank in einer AG befindet (obwohl er daran denken muss, den Job dem anderen Server hinzuzufügen).
• Ermöglicht es jedem Job, eine Fehler-E-Mail zu erhalten, die weiterhin nützlich ist (alle Ihre Jobs haben Fehler-E-Mails, oder?)
• Wenn Sie den Verlauf eines Jobs anzeigen, können Sie tatsächlich feststellen, ob der Job tatsächlich ausgeführt wurde und etwas getan hat (dies ist der primäre Job), anstatt eine lange Liste von Erfolgen anzuzeigen, bei denen tatsächlich nichts ausgeführt wurde (der sekundäre Job).

Das Skript überprüft die Datenbank im Feld darunter

Dieser Vorgang wird alle 15 Minuten auf jedem Server ausgeführt. (hat den zusätzlichen Bonus, einen Kommentar anzufügen, um die Leute darüber zu informieren, warum der Job deaktiviert wurde)

/*
    This proc goes through all SQL Server agent jobs and finds any that refer to a database taking part in the availability Group 
    It will then enable/disable the job dependant on whether the server is the primary replica or not   
        Primary Replica = enable job
    It will also add a comment to the job indicating the job was updated by this proc
*/
CREATE PROCEDURE dbo.sp_HADRAgentJobFailover (@AGname varchar(200) = 'AG01' )
AS 

DECLARE @SQL NVARCHAR(MAX)

;WITH DBinAG AS (  -- This finds all databases in the AG and determines whether Jobs targeting these DB's should be turned on (which is the same for all db's in the AG)
SELECT  distinct
        runJobs = CASE WHEN role_desc = 'Primary' THEN 1 ELSE 0 END   --If this is the primary, then yes we want to run the jobs
        ,dbname = db.name
        ,JobDescription = CASE WHEN hars.role_desc = 'Primary'  -- Add the reason for the changing the state to the Jobs description
                THEN '~~~ [Enabled] using automated process (DBA_tools.dbo.sp_HADRAgentJobFailover) looking for jobs running against Primary Replica AG ~~~ '
                ELSE '~~~ [Diabled] using Automated process (DBA_tools.dbo.sp_HADRAgentJobFailover) because the job cant run on READ-ONLY Replica AG~~~ ' END 
FROM sys.dm_hadr_availability_replica_states hars
INNER JOIN sys.availability_groups ag ON ag.group_id = hars.group_id
INNER JOIN sys.Databases db ON  db.replica_id = hars.replica_id
WHERE is_local = 1
AND ag.Name = @AGname
) 

SELECT @SQL = (
SELECT DISTINCT N'exec msdb..sp_update_job @job_name = ''' + j.name + ''', @enabled = ' + CAST(d.runJobs AS VARCHAR) 
                + ',@description = ''' 
                + CASE WHEN j.description = 'No description available.' THEN JobDescription -- if there is no description just add our JobDescription
                       WHEN PATINDEX('%~~~%~~~',j.description) = 0 THEN j.description + '    ' + JobDescription  -- If our JobDescription is NOT there, add it
                       WHEN PATINDEX('%~~~%~~~',j.description) > 0 THEN SUBSTRING(j.description,1,CHARINDEX('~~~',j.description)-1) + d.JobDescription  --Replace our part of the job description with what we are doing.
                       ELSE d.JobDescription  -- Should never reach here...
                    END 
                + ''';'
FROM msdb.dbo.sysjobs j
INNER JOIN msdb.dbo.sysjobsteps s
INNER JOIN DBinAG d ON d.DbName =s.database_name     
ON j.job_id = s.job_id
WHERE j.enabled != d.runJobs   -- Ensure we only actually update the job, if it needs to change
FOR XML PATH ('')
)
PRINT REPLACE(@SQL,';',CHAR(10))
EXEC sys.sp_executesql @SQL

Es ist nicht narrensicher, aber für Übernachtungen und stündliche Jobs erledigt es die Arbeit.

Es ist sogar noch besser, als dieses Verfahren nach einem Zeitplan ausführen zu lassen, als Reaktion auf Warnung 1480 (AG-Rollenwechsel-Warnung).

Ich kenne zwei Konzepte, um dies zu erreichen.

Voraussetzung: Basierend auf der Antwort von Thomas Stringer habe ich zwei Funktionen in der Master-Datenbank unserer beiden Server erstellt:

CREATE FUNCTION [dbo].[svf_AgReplicaState](@availability_group_name sysname)
RETURNS bit
AS
BEGIN

if EXISTS(
    SELECT        ag.name
    FROM            sys.dm_hadr_availability_replica_states AS ars INNER JOIN
                             sys.availability_groups AS ag ON ars.group_id = ag.group_id
    WHERE        (ars.is_local = 1) AND (ars.role_desc = 'PRIMARY') AND (ag.name = @availability_group_name))

    RETURN 1

RETURN 0

END
GO

CREATE FUNCTION [dbo].[svf_DbReplicaState](@database_name sysname)
RETURNS bit
AS
BEGIN

IF EXISTS(
    SELECT        adc.database_name
    FROM            sys.dm_hadr_availability_replica_states AS ars INNER JOIN
                             sys.availability_databases_cluster AS adc ON ars.group_id = adc.group_id
    WHERE        (ars.is_local = 1) AND (ars.role_desc = 'PRIMARY') AND (adc.database_name = @database_name))

    RETURN 1
RETURN 0

END

GO

1. Lassen Sie einen Job beenden, wenn er nicht auf dem primären Replikat ausgeführt wird

   In diesem Fall benötigt jeder Job auf beiden Servern einen der beiden folgenden Codeausschnitte als Schritt 1:

   Nach Gruppenname prüfen:

   IF master.dbo.svf_AgReplicaState('my_group_name')=0
     raiserror ('This is not the primary replica.',2,1)
   

   Nach Datenbanknamen prüfen:

   IF master.dbo.svf_AgReplicaState('my_db_name')=0
     raiserror ('This is not the primary replica.',2,1)
   

   Wenn Sie diese zweite Variante verwenden, sollten Sie jedoch auf die Systemdatenbanken achten - per Definition können sie keiner Verfügbarkeitsgruppe angehören, sodass sie für diese immer fehlschlagen.

   Beide Funktionen sind für Administratorbenutzer sofort einsatzbereit. Für Benutzer ohne Administratorrechte müssen Sie zusätzliche Berechtigungen hinzufügen, von denen eine hier vorgeschlagen wird :

   GRANT VIEW SERVER STATE TO [user];
   GRANT VIEW ANY DEFINITION TO [user];
   

   Wenn Sie die Fehleraktion in diesem ersten Schritt auf Jobberichtserfolg beenden setzen, wird das Jobprotokoll nicht mit hässlichen roten Kreuzzeichen gefüllt. Für den Hauptjob werden sie stattdessen in gelbe Warnzeichen umgewandelt.

   Nach unserer Erfahrung ist dies nicht ideal. Wir haben diesen Ansatz zunächst gewählt, jedoch schnell den Überblick über die Suche nach Jobs verloren, bei denen tatsächlich ein Problem aufgetreten ist, da alle sekundären Replikatjobs das Jobprotokoll mit Warnmeldungen überfüllten.

   Was wir dann wollten, ist:

2. Proxy-Jobs

   Wenn Sie dieses Konzept übernehmen, müssen Sie tatsächlich zwei Jobs pro Aufgabe erstellen, die Sie ausführen möchten. Der erste ist der "Proxy-Job", der prüft, ob er auf dem primären Replikat ausgeführt wird. Wenn dies der Fall ist, wird der "Arbeiterjob" gestartet. Wenn dies nicht der Fall ist, wird er ordnungsgemäß beendet, ohne das Protokoll mit Warn- oder Fehlermeldungen zu überladen.

   Ich persönlich mag die Idee, zwei Jobs pro Task auf jedem Server zu haben, nicht, aber ich denke, dass sie auf jeden Fall besser zu warten sind, und Sie müssen die Fehleraktion des Schritts nicht auf Erfolg beim Beenden der Jobberichterstellung setzen , was ein bisschen ist peinlich.

   Für die Jobs haben wir ein Namensschema übernommen. Der Proxy-Job wird gerade aufgerufen {put jobname here}. Der Arbeiterjob wird aufgerufen {put jobname here} worker. Dadurch ist es möglich, das Starten des Worker-Jobs vom Proxy aus zu automatisieren. Zu diesem Zweck habe ich den beiden Master-Datenbanken die folgende Prozedur hinzugefügt:

   CREATE procedure [dbo].[procStartWorkerJob](@jobId uniqueidentifier, @availabilityGroup sysname, @postfix sysname = ' worker') as
   declare @name sysname
   
   if dbo.svf_AgReplicaState(@availabilityGroup)=0
       print 'This is not the primary replica.'
   else begin
       SELECT @name = name FROM msdb.dbo.sysjobs where job_id = @jobId
   
       set @name = @name + @postfix
       if exists(select name from msdb.dbo.sysjobs where name = @name)
           exec msdb.dbo.sp_start_job @name
       else begin
           set @name = 'Job '''+@name+''' not found.'
           raiserror (@name ,2,1)
       end
   end
   GO
   

   Hierbei wird die svf_AgReplicaStateoben gezeigte Funktion verwendet. Sie können diese einfach ändern, um den Datenbanknamen zu überprüfen, indem Sie die andere Funktion aufrufen.

   Innerhalb des einzigen Schritts des Proxy-Jobs nennen Sie es folgendermaßen:

   exec procStartWorkerJob $(ESCAPE_NONE(JOBID)), '{my_group_name}'

   Hierbei werden die hier und hier gezeigten Tokens verwendet , um die aktuelle Job-ID abzurufen. Die Prozedur ruft dann den aktuellen Jobnamen von msdb ab, hängt  workerihn an und startet den Worker-Job mit sp_start_job.

   Obwohl dies immer noch nicht ideal ist, werden die Auftragsprotokolle übersichtlicher und wartbarer als bei der vorherigen Option. Sie können den Proxy-Job auch immer mit einem Sysadmin-Benutzer ausführen lassen, sodass das Hinzufügen zusätzlicher Berechtigungen nicht erforderlich ist.

Wenn es sich beim Datenladeprozess um eine einfache Abfrage oder einen einfachen Prozeduraufruf handelt, können Sie den Job auf beiden Knoten erstellen und anhand der Updateability-Eigenschaft der Datenbank bestimmen lassen, ob es sich um den primären Knoten handelt, bevor der Datenladeprozess ausgeführt wird:

IF (SELECT CONVERT(sysname,DatabasePropertyEx(DB_NAME(),'Updateability'))) != 'READ_ONLY'
BEGIN

-- Data Load code goes under here

END

Es ist immer besser, einen neuen Jobschritt zu erstellen, der prüft, ob es sich um ein primäres Replikat handelt. Wenn es sich um ein sekundäres Replikat handelt, ist alles in Ordnung, um mit der Jobausführung fortzufahren. Stoppen Sie dann den Job. Schlagen Sie den Auftrag nicht fehl, da sonst weiterhin unnötige Benachrichtigungen gesendet werden. Beenden Sie stattdessen den Job, damit er abgebrochen wird und keine Benachrichtigungen gesendet werden, wenn diese Jobs auf dem sekundären Replikat ausgeführt werden.

Das folgende Skript fügt einen ersten Schritt für einen bestimmten Job hinzu.

Hinweis zum Ausführen des Skripts:

• Ersetzen Sie 'XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX' durch Job_ID
• Ersetzen Sie 'JJJJJJJJJJJJJJJJJJJJJJJ' durch Job_Name

• Wenn mehrere Verfügbarkeitsgruppen vorhanden sind, legen Sie den AG-Namen in der Variablen @AGNameToCheck_IfMoreThanSingleAG fest, für die AG der Replikationsstatus überprüft werden soll.

• Beachten Sie auch, dass dieses Skript auch auf Servern ohne Verfügbarkeitsgruppen gut funktionieren sollte. Wird nur für SQL Server-Versionen 2012 und höher ausgeführt.

          USE [msdb]
          GO
          EXEC msdb.dbo.sp_add_jobstep @job_id=N'XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX', @step_name=N'CheckForSecondaryReplica', 
                  @step_id=1, 
                  @cmdexec_success_code=0, 
                  @on_success_action=3, 
                  @on_fail_action=2, 
                  @retry_attempts=0, 
                  @retry_interval=0, 
                  @os_run_priority=0, @subsystem=N'TSQL', 
                  @command=N'
          DECLARE @AGNameToCheck_IfMoreThanSingleAG VARCHAR(100)
          SET @AGNameToCheck_IfMoreThanSingleAG = ''AGName_IfMoreThanOneAG'' -- If there are Multiple AGs, then a single server can have Primary of one AG and Secondary of other. So Job creator has to define as to which AG needs to verified before the job is automatically run on Primary.
  
          DECLARE @NumberofAGs INT
          SELECT @NumberofAGs = COUNT(group_id) FROM sys.availability_groups ags
  
  
          IF(@NumberofAGs < 2)
              IF EXISTS(Select * FROM sys.dm_hadr_availability_replica_states hars WHERE role_desc = ''Secondary'' AND hars.is_local = 1)                 
                                  EXEC msdb.dbo.sp_stop_job N''YYYYYYYYYYYYYYYYYYYYYYYYYY'' ;
                                  --RAISERROR(''This is a Secondary Replica'',16,1)
  
          IF(@NumberofAGs >= 2)
              IF EXISTS(SELECT 1 FROM sys.availability_groups WHERE name = @AGNameToCheck_IfMoreThanSingleAG)
              BEGIN
                          IF EXISTS(Select * from  sys.availability_groups ag
                                          JOIN sys.dm_hadr_availability_replica_states hars
                                                      ON ag.group_id = hars.group_id
                                                      Where role_desc = ''Secondary''
                                                      AND hars.is_local = 1
                                                      AND ag.name = @AGNameToCheck_IfMoreThanSingleAG)
                          BEGIN
                                  EXEC msdb.dbo.sp_stop_job N''YYYYYYYYYYYYYYYYYYYYYYYYYY'' ;
                                  --RAISERROR(''This is a Secondary Replica'',16,1)
                          END
              END
              ELSE
                          BEGIN
                                  RAISERROR(''The Defined AG in the Variable is not a part of this Server. Please Check!!!!!!!!!!!'',16,1)
                          END', 
                  @database_name=N'master', 
                  @flags=0
          GO
  

Eine andere Möglichkeit besteht darin, in jeden Job, der zuerst ausgeführt werden soll, einen Schritt mit folgendem Code einzufügen:

IF (SELECT ars.role_desc
    FROM sys.dm_hadr_availability_replica_states ars
    INNER JOIN sys.availability_groups ag
    ON ars.group_id = ag.group_id
    AND ars.is_local = 1) <> 'PRIMARY'
BEGIN
   --We're on the secondary node, throw an error
   THROW 50001, 'Unable to execute job on secondary node',1
END

Setzen Sie diesen Schritt, um mit dem nächsten erfolgreichen Schritt fortzufahren und die Jobmeldung zu beenden, wenn ein Fehler aufgetreten ist.

Ich finde es übersichtlicher, einen zusätzlichen Schritt hinzuzufügen, anstatt einem vorhandenen Schritt zusätzliche Logik hinzuzufügen.

Eine andere, neuere Option ist die Verwendung von master.sys.fn_hadr_is_primary_replica ('DbName'). Ich fand das super hilfreich, wenn ich SQL Agent für die Datenbankwartung verwendete (zusammen mit einem Cursor, den ich seit Jahren verwende) und wenn ich eine ETL oder eine andere datenbankspezifische Aufgabe ausführte. Der Vorteil ist, dass die Datenbank herausgegriffen wird, anstatt die gesamte Verfügbarkeitsgruppe zu betrachten. Es ist auch sehr viel unwahrscheinlicher, dass ein Befehl für eine Datenbank ausgeführt wird, die sich auf der Primärdatenbank befand. Nehmen wir jedoch an, dass während der Jobausführung ein automatisches Failover stattgefunden hat und sich nun auf einer sekundären Replik befindet. Die oben genannten Methoden, die sich mit dem primären Replikat befassen, sehen sich nur einmal um und werden nicht aktualisiert. Beachten Sie, dass dies nur ein anderer Weg ist, um sehr ähnliche Ergebnisse zu erzielen und bei Bedarf eine genauere Steuerung zu ermöglichen. Der Grund, warum diese Methode bei der Beantwortung dieser Frage nicht erörtert wurde, ist, dass Microsoft diese Funktion erst nach der Veröffentlichung von SQL 2014 freigegeben hat. Im Folgenden finden Sie einige Beispiele für die Verwendung dieser Funktion:

   IF master.dbo.fn_hadr_database_is_primary_replica('Admin') = 1
    BEGIN 
        -- do whatever you were going to do in the Primary:
        PRINT 'Doing stuff in the Primary Replica';
    END
ELSE 
    BEGIN 
        -- we're not in the Primary - exit gracefully:
        PRINT 'This is not the primary replica - exiting with success';
    END

Wenn Sie dies für die Pflege der Benutzerdatenbank verwenden möchten, verwende ich Folgendes:

/*Below evaluates all user databases in the instance and gives stubs to do work; must change to get anything other than print statements*/
declare @dbname varchar(1000)
declare @sql nvarchar(4000)

declare AllUserDatabases cursor for
    select [name] from master.sys.databases
    where database_id > 4 --this excludes all sysdbs; if all but tempdb is desired, change to <> 2
    and [state] = 0

open AllUserDatabases
fetch AllUserDatabases into @dbname

while (@@FETCH_STATUS = 0)
    begin
    --PRINT @dbname
        set @sql = '
            IF master.sys.fn_hadr_is_primary_replica(''' + @dbname + ''') = 1
                BEGIN 
                    -- do whatever you are going to do in the Primary:
                    PRINT ''Doing stuff in the Primary Replica''
                END
            ELSE 
                BEGIN 
                    -- not in the Primary - exit gracefully:
                    PRINT ''This is not the primary replica - exiting with success''
                END             
        '
        exec sp_executesql @sql
        fetch AllUserDatabases into @dbname
    end
close AllUserDatabases
deallocate AllUserDatabases

Ich hoffe das ist ein hilfreicher Tipp!

Ich benutze das:

if (select primary_replica from sys.dm_hadr_availability_group_states) = @@SERVERNAME begin
... paste your t-sql here ...

end