Automatische gegevensverzameling over voltooide taken in MS SQL Server

Inleiding

Het is belangrijk voor een databasebeheerder om te weten welke taken en hoe deze zijn uitgevoerd. Om dit proces te vereenvoudigen, is het beter om het te automatiseren in plaats van het handmatig uit te voeren.

In dit artikel zal ik aan de hand van een bepaald voorbeeld analyseren hoe automatisch gegevens kunnen worden verzameld over voltooide taken van de SQL Server Agent.

Oplossing

Algoritme:

1. Maak een instantie om taken te selecteren:

   USE [DATABASE_NAME]
   GO
   
   SET ANSI_NULLS ON
   GO
   
   SET QUOTED_IDENTIFIER ON
   GO
   
   CREATE view [srv].[vJobRunShortInfo] as
   SELECT sj.[job_id] as Job_GUID
         ,j.name as Job_Name
         ,case sj.[last_run_outcome]
           when 0 then 'Error'
           when 1 then 'Successful'
           when 3 then 'Canceled'
           else case when sj.[last_run_date] is not null and len(sj.[last_run_date])=8 then 'Inconsistent state'
                   else NULL
                   end
          end as LastFinishRunState
         ,sj.[last_run_outcome] as LastRunOutcome
         ,case when sj.[last_run_date] is not null and len(sj.[last_run_date])=8 then
           DATETIMEFROMPARTS(
           substring(cast(sj.[last_run_date] as nvarchar(255)),1,4),
           substring(cast(sj.[last_run_date] as nvarchar(255)),5,2),
           substring(cast(sj.[last_run_date] as nvarchar(255)),7,2),
           case when len(cast(sj.[last_run_time] as nvarchar(255)))>=5 
           then substring(cast(sj.[last_run_time] as nvarchar(255)),1,len(cast(sj.[last_run_time] as nvarchar(255)))-4)
             else 0
             end,
           case when len(right(cast(sj.[last_run_time] as nvarchar(255)),4))>=4 
           then substring(right(cast(sj.[last_run_time] as nvarchar(255)),4),1,2)
           when len(right(cast(sj.[last_run_time] as nvarchar(255)),4))=3  
           then substring(right(cast(sj.[last_run_time] as nvarchar(255)),4),1,1)
              else 0
              end,
           right(cast(sj.[last_run_duration] as nvarchar(255)),2),
                               0
                           )
          else NULL
          end as LastDateTime
          ,case when len(cast(sj.[last_run_duration] as nvarchar(255)))>5 
          then substring(cast(sj.[last_run_duration] as nvarchar(255)),1,len(cast(sj.[last_run_duration] as nvarchar(255)))-4)
               when len(cast(sj.[last_run_duration] as nvarchar(255)))=5 
          then '0'+substring(cast(sj.[last_run_duration] as nvarchar(255)),1,len(cast(sj.[last_run_duration] as nvarchar(255)))-4)
               else '00'
          end
          +':'
          +case when len(cast(sj.[last_run_duration] as nvarchar(255)))>=4 then substring(right(cast(sj.[last_run_duration] as nvarchar(255)),4),1,2)
                when len(cast(sj.[last_run_duration] as nvarchar(255)))=3  then '0'+substring(right(cast(sj.[last_run_duration] as nvarchar(255)),4),1,1)
                else '00'
          end
          +':'
          +case when len(cast(sj.[last_run_duration] as nvarchar(255)))>=2
           then substring(right(cast(sj.[last_run_duration] as nvarchar(255)),2),1,2)
                when len(cast(sj.[last_run_duration] as nvarchar(255)))=2  
           then '0'+substring(right(cast(sj.[last_run_duration] as nvarchar(255)),2),1,1)
                else '00'
          end as [LastRunDurationString]
         ,sj.last_run_duration as LastRunDurationInt
         ,sj.[last_outcome_message] as LastOutcomeMessage
         ,j.enabled as [Enabled]
     FROM [msdb].[dbo].[sysjobservers] as sj
     inner join msdb.dbo.sysjobs_view as j on j.job_id=sj.job_id;
   
   GO

   Gebruik hiervoor de sysjobservers en sysjobs_view instances.

2. Maak een tabel om geselecteerde gegevens op te slaan:

   USE [DATABASE_NAME]
   GO
   
   SET ANSI_NULLS ON
   GO
   
   SET QUOTED_IDENTIFIER ON
   GO
   
   CREATE TABLE [srv].[ShortInfoRunJobs](
       [Job_GUID] [uniqueidentifier] NOT NULL,
       [Job_Name] [nvarchar](255) NOT NULL,
       [LastFinishRunState] [nvarchar](255) NULL,
       [LastDateTime] [datetime] NOT NULL,
       [LastRunDurationString] [nvarchar](255) NULL,
       [LastRunDurationInt] [int] NULL,
       [LastOutcomeMessage] [nvarchar](255) NULL,
       [LastRunOutcome] [tinyint] NOT NULL,
       [Server] [nvarchar](255) NOT NULL,
       [InsertUTCDate] [datetime] NOT NULL,
       [ID] [int] IDENTITY(1,1) NOT NULL,
    CONSTRAINT [PK_ShortInfoRunJobs] PRIMARY KEY CLUSTERED 
   (
       [ID] ASC
   )WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
   ) ON [PRIMARY]
   
   GO
   
   ALTER TABLE [srv].[ShortInfoRunJobs] ADD  CONSTRAINT [DF_ShortInfoRunJobs_InsertUTCDate]  DEFAULT (getutcdate()) FOR [InsertUTCDate]
   GO

3. Maak een taak in de SQL Server Agent en krijg informatie over die taken die ofwel voor een lange tijd (meer dan 30 seconden) zijn uitgevoerd of die niet konden worden voltooid. U moet deze informatie voor de afgelopen twee dagen verzamelen:

   USE [DATABASE_NAME];
   GO
   
   truncate table [srv].[ShortInfoRunJobs];
   
   INSERT INTO [srv].[ShortInfoRunJobs]
              ([Job_GUID]
              ,[Job_Name]
              ,[LastFinishRunState]
              ,[LastDateTime]
              ,[LastRunDurationString]
              ,[LastRunDurationInt]
              ,[LastOutcomeMessage]
              ,[LastRunOutcome]
              ,[Server])
       SELECT [Job_GUID]
             ,[Job_Name]
             ,[LastFinishRunState]
             ,[LastDateTime]
             ,[LastRunDurationString]
             ,[LastRunDurationInt]
             ,[LastOutcomeMessage]
             ,LastRunOutcome
             ,@@SERVERNAME
         FROM [srv].[vJobRunShortInfo]
         where [Enabled]=1
         and ([LastRunOutcome]=0
         or [LastRunDurationInt]>=30)
         and LastDateTime>=DateAdd(day,-2,getdate());
   GO

   Hier kun je een filter instellen om alle onnodige taken te verwijderen. Bijvoorbeeld die taken die verwijzen naar replicatie omdat het veel meer tijd kost om te voltooien.

Genereer een HTML-rapport om het naar het e-mailadres van de beheerders te sturen:

USE [DATABASE_NAME]
GO

SET ANSI_NULLS ON
GO

SET QUOTED_IDENTIFIER ON
GO

CREATE PROCEDURE [srv].[GetHTMLTableShortInfoRunJobs]
    @body nvarchar(max) OUTPUT
AS
BEGIN
    /*
        generates an HTML-code for the tables of completed tasks
    */
    SET NOCOUNT ON;
    SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;

    declare @tbl table (
                        Job_GUID                uniqueidentifier
                        ,Job_Name               nvarchar(255)
                        ,LastFinishRunState     nvarchar(255)
                        ,LastDateTime           datetime
                        ,LastRunDurationString  nvarchar(255)
                        ,LastOutcomeMessage     nvarchar(max)
                        ,[Server]               nvarchar(255)
                        ,ID                     int identity(1,1)
                       );

    declare
    @Job_GUID               uniqueidentifier
    ,@Job_Name              nvarchar(255)
    ,@LastFinishRunState    nvarchar(255)
    ,@LastDateTime          datetime
    ,@LastRunDurationString nvarchar(255)
    ,@LastOutcomeMessage    nvarchar(max)
    ,@Server                nvarchar(255)
    ,@ID                    int;

    insert into @tbl(
                        Job_GUID
                        ,Job_Name
                        ,LastFinishRunState
                        ,LastDateTime
                        ,LastRunDurationString
                        ,LastOutcomeMessage
                        ,[Server]
                    )
            select      Job_GUID
                        ,Job_Name
                        ,LastFinishRunState
                        ,LastDateTime
                        ,LastRunDurationString
                        ,LastOutcomeMessage
                        ,[Server]
            from    srv.ShortInfoRunJobs
            --order by LastRunDurationInt desc;

    if(exists(select top(1) 1 from @tbl))
    begin
        set @body='When analyzing these tasks execution, I have found out the tasks that either have failed with an error,
        or, it has taken more than 30 seconds for their execution :<br><br>'+'<TABLE BORDER=5>';

        set @[email protected]+'<TR>';

        set @[email protected]+'<TD>';
        set @[email protected]+'№ p/p';
        set @[email protected]+'</TD>';

        set @[email protected]+'<TD>';
        set @[email protected]+'GUID';
        set @[email protected]+'</TD>';

        set @[email protected]+'<TD>';
        set @[email protected]+'TASK';
        set @[email protected]+'</TD>';

        set @[email protected]+'<TD>';
        set @[email protected]+'STATUS';
        set @[email protected]+'</TD>';

        set @[email protected]+'<TD>';
        set @[email protected]+'DATE AND TIME';
        set @[email protected]+'</TD>';

        set @[email protected]+'<TD>';
        set @[email protected]+'DURATION';
        set @[email protected]+'</TD>';

        set @[email protected]+'<TD>';
        set @[email protected]+'MESSAGE';
        set @[email protected]+'</TD>';

        set @[email protected]+'<TD>';
        set @[email protected]+'SERVER';
        set @[email protected]+'</TD>';

        set @[email protected]+'</TR>';

        while((select top 1 1 from @tbl)>0)
        begin
            set @[email protected]+'<TR>';

            select top 1
            @ID                     =   [ID]
            ,@Job_GUID              =   Job_GUID
            ,@Job_Name              =   Job_Name                
            ,@LastFinishRunState    =   LastFinishRunState      
            ,@LastDateTime          =   LastDateTime            
            ,@LastRunDurationString =   LastRunDurationString   
            ,@LastOutcomeMessage    =   LastOutcomeMessage      
            ,@Server                =   [Server]                
            from @tbl
            order by LastRunDurationInt desc;

            set @[email protected]+'<TD>';
            set @[email protected]+cast(@ID as nvarchar(max));
            set @[email protected]+'</TD>';

            set @[email protected]+'<TD>';
            set @[email protected]+cast(@Job_GUID as nvarchar(255));
            set @[email protected]+'</TD>';

            set @[email protected]+'<TD>';
            set @[email protected]+coalesce(@Job_Name,'');
            set @[email protected]+'</TD>';

            set @[email protected]+'<TD>';
            set @[email protected]+coalesce(@LastFinishRunState,'');
            set @[email protected]+'</TD>';

            set @[email protected]+'<TD>';
            set @[email protected]+rep.GetDateFormat(@LastDateTime, default)+' '+rep.GetTimeFormat(@LastDateTime, default);--cast(@InsertDate as nvarchar(max));
            set @[email protected]+'</TD>';

            set @[email protected]+'<TD>';
            set @[email protected]+coalesce(@LastRunDurationString,'');
            set @[email protected]+'</TD>';

            set @[email protected]+'<TD>';
            set @[email protected]+coalesce(@LastOutcomeMessage, '');
            set @[email protected]+'</TD>';

            set @[email protected]+'<TD>';
            set @[email protected]+coalesce(@Server, '');
            set @[email protected]+'</TD>';

            delete from @tbl
            where [email protected];

            set @[email protected]+'</TR>';
        end

        set @[email protected]+'</TABLE>';
    end
    else
    begin
        set @body='The tasks, that have failed with an error or that have been executed for more than 30 seconds, have not been found';
    end

    set @[email protected]+'<br><br>For the detailed information, please refer to the table DATABASE_NAME.srv.ShortInfoRunJobs';
END

GO

Deze opgeslagen procedure genereert een HTML-rapport over voltooide taken die gedurende 30 seconden zijn uitgevoerd of die niet konden worden voltooid.

Resultaat

In dit artikel heb ik op een bepaald voorbeeld de implementatie van een dagelijkse automatische gegevensverzameling over voltooide taken in de SQL Server Agent onderzocht. Deze informatie helpt bij het bepalen van taken die lange tijd zijn uitgevoerd of met een fout zijn voltooid. Het stelt een beheerder in staat maatregelen te nemen om dergelijke fouten in de toekomst te voorkomen. Het is bijvoorbeeld mogelijk om de taak sneller te laten verlopen of de maximale tijd voor de opgegeven taak in te stellen.

Deze oplossing helpt ook bij het bewaken van problemen met betrekking tot back-ups. Toch zullen we het later bespreken, omdat het niet voldoende is om eenmaal per dag belangrijke taken te melden. Het is noodzakelijk om er onmiddellijk en regelmatig over te e-mailen totdat de fout is verholpen.

Als u gegevens van meerdere servers moet selecteren, is het mogelijk om resultaten te combineren en `via één e-mail' te verzenden.

Referenties:

» sysjobs
» sysjobservers

Verder lezen:

Automatische gegevensverzameling van wijzigingen in het databaseschema in MS SQL Server

Automatische gegevensverzameling:databasebestanden en logische schijven in MS SQL Server

Database-e-mailmeldingen configureren in MS SQL Server