From ff91f0b772a1277ff65738a5eb84fe8a45debd72 Mon Sep 17 00:00:00 2001 From: qgarnier Date: Wed, 22 Dec 2021 13:12:00 +0100 Subject: [PATCH] break(mssql): mode backup-age - manage full/incremental/log backup type (#3333) --- database/mssql/mode/backupage.pm | 304 ++++++++++++++++++++----------- 1 file changed, 193 insertions(+), 111 deletions(-) diff --git a/database/mssql/mode/backupage.pm b/database/mssql/mode/backupage.pm index 7e6b030ed..6ec0bf0f2 100644 --- a/database/mssql/mode/backupage.pm +++ b/database/mssql/mode/backupage.pm @@ -20,126 +20,212 @@ package database::mssql::mode::backupage; -use base qw(centreon::plugins::mode); +use base qw(centreon::plugins::templates::counter); use strict; use warnings; -use Time::HiRes; -use Time::Local; +use centreon::plugins::misc; +use POSIX; + +my $unitdiv = { s => 1, w => 604800, d => 86400, h => 3600, m => 60 }; +my $unitdiv_long = { s => 'seconds', w => 'weeks', d => 'days', h => 'hours', m => 'minutes' }; + +sub custom_duration_perfdata { + my ($self, %options) = @_; + + $self->{output}->perfdata_add( + nlabel => $self->{nlabel}, + unit => 's', + instances => [$self->{result_values}->{name}, $self->{result_values}->{type}], + value => $self->{result_values}->{duration_seconds}, + warning => $self->{perfdata}->get_perfdata_for_output(label => 'warning-' . $self->{thlabel}), + critical => $self->{perfdata}->get_perfdata_for_output(label => 'critical-' . $self->{thlabel}), + min => 0 + ); +} + +sub custom_backup_perfdata { + my ($self, %options) = @_; + + $self->{output}->perfdata_add( + nlabel => $self->{nlabel} . '.' . $unitdiv_long->{ $self->{instance_mode}->{option_results}->{unit} }, + unit => $self->{instance_mode}->{option_results}->{unit}, + instances => [$self->{result_values}->{name}, $self->{result_values}->{type}], + value => floor($self->{result_values}->{exec_seconds} / $unitdiv->{ $self->{instance_mode}->{option_results}->{unit} }), + warning => $self->{perfdata}->get_perfdata_for_output(label => 'warning-' . $self->{thlabel}), + critical => $self->{perfdata}->get_perfdata_for_output(label => 'critical-' . $self->{thlabel}), + min => -1 + ); +} + +sub custom_backup_threshold { + my ($self, %options) = @_; + + return $self->{perfdata}->threshold_check( + value => floor($self->{result_values}->{exec_seconds} / $unitdiv->{ $self->{instance_mode}->{option_results}->{unit} }), + threshold => [ + { label => 'critical-' . $self->{thlabel}, exit_litteral => 'critical' }, + { label => 'warning-'. $self->{thlabel}, exit_litteral => 'warning' }, + { label => 'unknown-'. $self->{thlabel}, exit_litteral => 'unknown' } + ] + ); +} + +sub custom_backup_output { + my ($self, %options) = @_; + + my $msg; + if ($self->{result_values}->{exec_seconds} == -1) { + $msg = 'backup never executed'; + } else { + $msg = 'last backup execution: ' . $self->{result_values}->{exec_human}; + } + return $msg; +} + +sub prefix_database_output { + my ($self, %options) = @_; + + return "database '" . $options{instance} . "' "; +} + +sub database_long_output { + my ($self, %options) = @_; + + return "checking database '" . $options{instance} . "'"; +} + +sub prefix_full_output { return 'full '; } +sub prefix_incremental_output { return 'incremental '; } +sub prefix_log_output { return 'log '; } + +sub set_counters { + my ($self, %options) = @_; + + $self->{maps_counters_type} = [ + { + name => 'databases', type => 3, cb_prefix_output => 'prefix_database_output', cb_long_output => 'database_long_output', indent_long_output => ' ', message_multiple => 'All databases are ok', + group => [ + { name => 'full', type => 0, cb_prefix_output => 'prefix_full_output', skipped_code => { -10 => 1 } }, + { name => 'incremental', type => 0, cb_prefix_output => 'prefix_incremental_output', skipped_code => { -10 => 1 } }, + { name => 'log', type => 0, cb_prefix_output => 'prefix_log_output', skipped_code => { -10 => 1 } } + ] + } + ]; + + foreach ('full', 'incremental', 'log') { + $self->{maps_counters}->{$_} = [ + { label => $_ . '-last-execution', nlabel => 'backup.time.last.execution', set => { + key_values => [ { name => 'exec_seconds' }, { name => 'exec_human' }, { name => 'name' }, { name => 'type' } ], + closure_custom_output => $self->can('custom_backup_output'), + closure_custom_perfdata => $self->can('custom_backup_perfdata'), + closure_custom_threshold_check => $self->can('custom_backup_threshold') + } + }, + { label => $_ . '-last-duration', nlabel => 'backup.time.last.duration.seconds', set => { + key_values => [ { name => 'duration_seconds' }, { name => 'duration_human' }, { name => 'name' }, { name => 'type' } ], + output_template => 'duration time: %s', + output_use => 'duration_human', + closure_custom_perfdata => $self->can('custom_duration_perfdata') + } + } + ]; + } +} sub new { my ($class, %options) = @_; - my $self = $class->SUPER::new(package => __PACKAGE__, %options); + my $self = $class->SUPER::new(package => __PACKAGE__, %options, force_new_perfdata => 1); bless $self, $class; - - $options{options}->add_options(arguments => - { - "filter:s" => { name => 'filter', }, - "skip" => { name => 'skip', }, - "skip-no-backup" => { name => 'skip_no_backup', }, - "warning:s" => { name => 'warning', }, - "critical:s" => { name => 'critical', }, - }); + + $options{options}->add_options(arguments => { + 'filter-name:s' => { name => 'filter_name' }, + 'unit:s' => { name => 'unit', default => 'd' } + }); return $self; } sub check_options { my ($self, %options) = @_; - $self->SUPER::init(%options); + $self->SUPER::check_options(%options); - if (($self->{perfdata}->threshold_validate(label => 'warning', value => $self->{option_results}->{warning})) == 0) { - $self->{output}->add_option_msg(short_msg => "Wrong warning threshold '" . $self->{option_results}->{warning} . "'."); - $self->{output}->option_exit(); - } - if (($self->{perfdata}->threshold_validate(label => 'critical', value => $self->{option_results}->{critical})) == 0) { - $self->{output}->add_option_msg(short_msg => "Wrong critical threshold '" . $self->{option_results}->{critical} . "'."); - $self->{output}->option_exit(); + if ($self->{option_results}->{unit} eq '' || !defined($unitdiv->{$self->{option_results}->{unit}})) { + $self->{option_results}->{unit} = 'd'; } } -sub run { +sub manage_selection { my ($self, %options) = @_; - # $options{sql} = sqlmode object - $self->{sql} = $options{sql}; - $self->{output}->output_add(severity => 'OK', - short_msg => "All backups are ok."); - - $self->{sql}->connect(); - - my $count = 0; - my $query = 'SELECT - a.name, a.recovery_model, - DATEDIFF(SS, MAX(b.backup_finish_date), GETDATE()), - DATEDIFF(SS, MAX(b.backup_start_date), MAX(b.backup_finish_date)) - FROM master.dbo.sysdatabases a LEFT OUTER JOIN msdb.dbo.backupset b - ON b.database_name = a.name - GROUP BY a.name - ORDER BY a.name - '; - - if (($self->{sql}->is_version_minimum(version => '9.x'))) { - $query = "SELECT D.name AS [database_name], D.recovery_model, BS1.last_backup, BS1.last_duration - FROM sys.databases D - LEFT JOIN ( - SELECT BS.[database_name], - DATEDIFF(SS,MAX(BS.[backup_finish_date]),GETDATE()) AS last_backup, - DATEDIFF(SS,MAX(BS.[backup_start_date]),MAX(BS.[backup_finish_date])) AS last_duration - FROM msdb.dbo.backupset BS - WHERE BS.type = 'D' - GROUP BY BS.[database_name] - ) BS1 ON D.name = BS1.[database_name] - WHERE D.source_database_id IS NULL - ORDER BY D.[name]"; + my $query = q{ + SELECT + a.name, + a.recovery_model, + DATEDIFF(SS, MAX(b.backup_finish_date), GETDATE()), + DATEDIFF(SS, MAX(b.backup_start_date), MAX(b.backup_finish_date)), + b.type + FROM master.dbo.sysdatabases a LEFT OUTER JOIN msdb.dbo.backupset b ON b.database_name = a.name + WHERE b.type IN ('D', 'I', 'L') + GROUP BY a.name, b.type + ORDER BY a.name + }; + if ($options{sql}->is_version_minimum(version => '9.x')) { + $query = q{ + SELECT + D.name AS [database_name], + D.recovery_model, + BS1.last_backup, + BS1.last_duration, + BS1.type + FROM sys.databases D + LEFT JOIN ( + SELECT + BS.[database_name], + BS.[type], + DATEDIFF(SS, MAX(BS.[backup_finish_date]), GETDATE()) AS last_backup, + DATEDIFF(SS, MAX(BS.[backup_start_date]), MAX(BS.[backup_finish_date])) AS last_duration + FROM msdb.dbo.backupset BS + WHERE BS.type IN ('D', 'I', 'L') + GROUP BY BS.[database_name], BS.[type] + ) BS1 ON D.name = BS1.[database_name] + WHERE D.source_database_id IS NULL + ORDER BY D.[name] + }; } - $self->{sql}->query(query => $query); - my $result = $self->{sql}->fetchall_arrayref(); + $options{sql}->connect(); + $options{sql}->query(query => $query); + my $result = $options{sql}->fetchall_arrayref(); + + my $map_type = { D => 'full', I => 'incremental', L => 'log' }; + $self->{databases} = {}; foreach my $row (@$result) { - next if (defined($self->{option_results}->{filter}) && $$row[0] !~ /$self->{option_results}->{filter}/); - $count++; - #dbt_backup_start: 0x1686303d8 (dtdays=40599, dttime=7316475) Feb 27 2011 6:46:28:250AM - my $last_backup = $$row[2]; - my $backup_duration = $$row[3]; - if (!defined($last_backup)) { - if (!defined($self->{option_results}->{skip_no_backup})) { - $self->{output}->output_add(severity => 'CRITICAL', - short_msg => sprintf("No backup found for DB '%s'", $$row[0])); - } - } else { - $self->{output}->output_add(long_msg => sprintf("DB '%s' backup age : %ds [Duration : %ds]", $$row[0], $last_backup, $backup_duration)); - my $exit_code = $self->{perfdata}->threshold_check(value => $last_backup, threshold => [ { label => 'critical', exit_litteral => 'critical' }, { label => 'warning', exit_litteral => 'warning' } ]); - if (!$self->{output}->is_status(value => $exit_code, compare => 'ok', litteral => 1)) { - $self->{output}->output_add(severity => $exit_code, - short_msg => sprintf("DB '%s' backup age: %ds [Duration : %ds]", $$row[0], $last_backup, $backup_duration)); - - } - - $self->{output}->perfdata_add(label => sprintf("db_%s_backup_age",$$row[0]), - unit => 's', - value => $last_backup, - warning => $self->{perfdata}->get_perfdata_for_output(label => 'warning'), - critical => $self->{perfdata}->get_perfdata_for_output(label => 'critical'), - min => 0); - $self->{output}->perfdata_add(label => sprintf("db_%s_backup_duration",$$row[0]), - unit => 's', - value => $backup_duration, - min => 0); + next if (defined($self->{option_results}->{filter_name}) && $self->{option_results}->{filter_name} ne '' && + $row->[0] !~ /$self->{option_results}->{filter_name}/); + if (!defined($self->{databases}->{ $row->[0] })) { + $self->{databases}->{ $row->[0] } = { + full => { exec_seconds => -1, exec_human => '', type => 'full', name => $row->[0] }, + incremental => { exec_seconds => -1, exec_human => '', type => 'incremental', name => $row->[0] }, + log => { exec_seconds => -1, exec_human => '', type => 'log', name => $row->[0] } + }; + } + + next if (!defined($map_type->{ $row->[4] })); + + if (defined($row->[2])) { + $self->{databases}->{ $row->[0] }->{ $map_type->{ $row->[4] } }->{exec_seconds} = $row->[2]; + $self->{databases}->{ $row->[0] }->{ $map_type->{ $row->[4] } }->{exec_human} = centreon::plugins::misc::change_seconds( + value => $row->[2] + ); + } + if (defined($row->[3])) { + $self->{databases}->{ $row->[0] }->{ $map_type->{ $row->[4] } }->{duration_seconds} = $row->[3]; + $self->{databases}->{ $row->[0] }->{ $map_type->{ $row->[4] } }->{duration_human} = centreon::plugins::misc::change_seconds( + value => $row->[3] + ); } } - - if ($count == 0) { - $self->{output}->output_add(severity => 'OK', - short_msg => "No backup found"); - if (!defined($self->{option_results}->{skip})) { - $self->{output}->output_add(severity => 'UNKNOWN', - short_msg => "No backup found"); - } - } - - $self->{output}->display(); - $self->{output}->exit(); } 1; @@ -148,29 +234,25 @@ __END__ =head1 MODE -Check MSSQL backup age. +Check MSSQL backup. =over 8 -=item B<--filter> +=item B<--filter-name> -Filter database. +Filter databases by name. -=item B<--skip> +=item B<--unit> -Return ok if no backup found. +Select the unit for expires threshold. May be 's' for seconds, 'm' for minutes, +'h' for hours, 'd' for days, 'w' for weeks. Default is days. -=item B<--skip-no-backup> +=item B<--warning-*> B<--critical-*> -Skip databases without backup. - -=item B<--warning> - -Threshold warning in seconds. - -=item B<--critical> - -Threshold critical in seconds. +Thresholds. +Can be: 'incremental-last-execution', 'incremental-last-duration', +'full-last-execution', 'full-last-duration', +'log-last-execution', 'log-last-duration'. =back