nagios-plugins/check_dataprotector/trunk/check_dp_backups

#!/usr/bin/python
# -*- coding: utf-8 -*-
#
# Copyright 2010, Pall Sigurdsson <palli@opensource.is>
#
# This script is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This script is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program.  If not, see <http://www.gnu.org/licenses/>.

# About this script
# 
# This script collects statistics about all Dataprotector sessions for today
# Does not do any checking, only used for trending purposes


import subprocess
import datetime
import sys
now = datetime.datetime.now()


# return code 3 = No sessions matching the search criteria were found. 
omnistat_returncode_no_sessions_found=3
class GenericObject:
  def __init__(self):
    self.dict = {}

def runCommand(command):
  proc = subprocess.Popen(command, shell=True, stdout=subprocess.PIPE,stderr=subprocess.PIPE,)
  stdout, stderr = proc.communicate('through stdin to stdout')
  if proc.returncode > 0 and proc.returncode != omnistat_returncode_no_sessions_found: 
    print "Error running '%s' command:\n %s" % (command, stderr)
    print proc.returncode
    print stderr, stdout
    sys.exit(1)
  else:
    return stdout

def getSessions():
  sessions = []
  date = "%s/%s/%s" % ( now.year, now.month, now.day )
  output = runCommand( '/opt/omni/bin/omnistat -previous -since %s' % date )
  for line in output.split('\n')[1:]:
    tmp = line.split()
    if len(tmp) < 4: continue
    sessionID = tmp[0]
    sessions.append( sessionID )
    #print sessionID
  return sessions

def parseSessions(session_list):
  parsedSessions = []
  for sessionID in session_list:
    output = runCommand('/opt/omni/bin/omnidb -rpt %s -detail' % sessionID )
    session = GenericObject()
    parsedSessions.append ( session )
    for line in output.split('\n'):
      tmp = line.split(':')
      if len(tmp) != 2: continue
      key,value = tmp
      key = key.strip()
      value = value.strip()
      session.dict[key] = value
  return parsedSessions

sessions = getSessions()
parsedSessions = parseSessions( sessions )


total_errors = 0
total_warnings = 0
total_size = 0
total_sessions = 0
for session in parsedSessions:
	errors = int( session.dict['Number of errors'] )
	warnings = int( session.dict['Number of warnings'] )
	try:
		size = 1024 * int( session.dict['Session size'].split()[0] )
	except:
		size = 0
	total_errors = total_errors + errors
	total_warnings = total_warnings + warnings
	total_size = total_size + size
	total_sessions += 1

print "Everything is ok | 'errors'=%d 'warnings'=%d 'size'=%dB 'num_sessions'=%dc" % (total_errors,total_warnings,total_size,total_sessions)