Automatisk datainsamling om slutförda uppgifter i MS SQL Server

Introduktion

Det är viktigt för en databasadministratör att veta vilka uppgifter och hur de har slutförts. För att förenkla denna process är det bättre att automatisera den istället för att utföra den manuellt.

I den här artikeln kommer jag att analysera på ett särskilt exempel hur man automatiskt samlar in data om slutförda uppgifter för SQL Server Agent.

Lösning

Algoritm:

1. Skapa en instans för att välja uppgifter:

   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

   För att göra detta, använd sysjobservers och sysjobs_view-instanserna.

2. Skapa en tabell för att lagra vald data:

   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. Skapa en uppgift i SQL Server-agenten och få information om de uppgifter som antingen har körts under en längre tid (mer än 30 sekunder) eller som inte har slutförts. Du måste samla in denna information för de senaste två dagarna:

   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

   Här kan du ställa in ett filter för att ta bort alla onödiga uppgifter. Till exempel de uppgifter som hänvisar till replikering eftersom det tar mycket längre tid att slutföra.

Skapa en HTML-rapport för att skicka den till administratörens e-post:

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

Denna lagrade procedur genererar en HTML-rapport om slutförda uppgifter som har utförts i 30 sekunder eller som inte kunde slutföras.

Resultat

I den här artikeln har jag undersökt ett särskilt exempel implementeringen av en daglig automatisk datainsamling om slutförda uppgifter i SQL Server Agent. Denna information hjälper till att avgöra uppgifter som har utförts under lång tid eller slutförts med ett fel. Det tillåter en administratör att vidta åtgärder för att undvika sådana misstag i framtiden. Det är till exempel möjligt att få uppgiften att köras snabbare eller ställa in maximal tid för den angivna uppgiften.

Denna lösning hjälper också till att övervaka problem relaterade till säkerhetskopior. Ändå kommer vi att diskutera det senare, eftersom det inte räcker med att meddela om viktiga uppgifter en gång om dagen. Det är nödvändigt att maila om dem omedelbart och regelbundet tills felet är åtgärdat.

Om du behöver välja data från flera servrar är det möjligt att kombinera resultat och skicka dem 'via ett e-postmeddelande.

Referenser:

» sysjobs
» sysjobservrar

Mer läsning:

Automatisk datainsamling av databasschemaändringar i MS SQL Server

Automatisk datainsamling:Databasfiler och logiska enheter i MS SQL Server

Konfigurera e-postmeddelanden i databasen i MS SQL Server