#!/usr/bin/env python
# -*- coding: utf-8 -*-
#
# Copyright (c) 2013 SWITCH http://www.switch.ch
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
from __future__ import print_function
import argparse
import os
import subprocess
import sys
__version__ = '1.7.1'
# default ceph values
CEPH_COMMAND = '/usr/bin/ceph'
# nagios exit code
STATUS_OK = 0
STATUS_WARNING = 1
STATUS_ERROR = 2
STATUS_UNKNOWN = 3
def main():
# parse args
parser = argparse.ArgumentParser(description="'ceph df' nagios plugin.")
parser.add_argument('-e','--exe', help='ceph executable [%s]' % CEPH_COMMAND)
parser.add_argument('-c','--conf', help='alternative ceph conf file')
parser.add_argument('-m','--monaddress', help='ceph monitor address[:port]')
parser.add_argument('-i','--id', help='ceph client id')
parser.add_argument('-n','--name', help='ceph client name')
parser.add_argument('-k','--keyring', help='ceph client keyring file')
parser.add_argument('-p','--pool', help='ceph pool name')
parser.add_argument('-d','--detail', help="show pool details on warn and critical", action='store_true')
parser.add_argument('-W','--warn', help="warn above this percent RAW USED", type=float)
parser.add_argument('-C','--critical', help="critical alert above this percent RAW USED", type=float)
parser.add_argument('-V','--version', help='show version and exit', action='store_true')
args = parser.parse_args()
# validate args
ceph_exec = args.exe if args.exe else CEPH_COMMAND
if not os.path.exists(ceph_exec):
print("ERROR: ceph executable '%s' doesn't exist" % ceph_exec)
return STATUS_UNKNOWN
if args.version:
print('version %s' % __version__)
return STATUS_OK
if args.conf and not os.path.exists(args.conf):
print("ERROR: ceph conf file '%s' doesn't exist" % args.conf)
return STATUS_UNKNOWN
if args.keyring and not os.path.exists(args.keyring):
print("ERROR: keyring file '%s' doesn't exist" % args.keyring)
return STATUS_UNKNOWN
if not args.warn or not args.critical or args.warn > args.critical:
print("ERROR: warn and critical level must be set and critical must be greater than warn")
return STATUS_UNKNOWN
# build command
ceph_df = [ceph_exec]
if args.monaddress:
ceph_df.append('-m')
ceph_df.append(args.monaddress)
if args.conf:
ceph_df.append('-c')
ceph_df.append(args.conf)
if args.id:
ceph_df.append('--id')
ceph_df.append(args.id)
if args.name:
ceph_df.append('--name')
ceph_df.append(args.name)
if args.keyring:
ceph_df.append('--keyring')
ceph_df.append(args.keyring)
ceph_df.append('df')
#print ceph_df
# exec command
p = subprocess.Popen(ceph_df,stdout=subprocess.PIPE,stderr=subprocess.PIPE)
output, err = p.communicate()
# parse output
# print "DEBUG: output:", output
# print "DEBUG: err:", err
if output:
output = output.decode('utf-8')
# parse output
# if detail switch was not set only show global values and compare to warning and critical
# otherwise show space for pools too
result=output.splitlines()
# values for GLOBAL are in 3rd line of output
globalline = result[2]
globalvals = globalline.split()
# Luminous vs Minic output (27.3TiB vs 27.3 TiB)
if len(globalvals) == 7:
gv = []
gv.append("{}{}".format(globalvals[0], globalvals[1]))
gv.append("{}{}".format(globalvals[2], globalvals[3]))
gv.append("{}{}".format(globalvals[4], globalvals[5]))
gv.append(globalvals[6])
globalvals = gv
#print "XXX: globalvals: {} {}".format(len(globalvals), globalvals)
# Nautilus output
if len(globalvals) == 10:
gv = []
gv.append("{}{}".format(globalvals[1], globalvals[2]))
gv.append("{}{}".format(globalvals[3], globalvals[4]))
gv.append("{}{}".format(globalvals[5], globalvals[6]))
gv.append(globalvals[9])
globalvals = gv
#print "XXX: globalvals: {} {}".format(len(globalvals), globalvals)
# prepare pool values
# pool output starts in line 4 with the bare word POOLS: followed by the output
poollines = result[3:]
if args.pool:
for line in poollines:
if args.pool in line:
poolvals = line.split()
# Luminous vs Minic output (27.3TiB vs 27.3 TiB)
if len(poolvals) == 8:
pv = []
pv.append(poolvals[0]) # NAME
pv.append(poolvals[1]) # ID
pv.append("{}{}".format(poolvals[2], poolvals[3])) # USED 27.3 TiB
pv.append(poolvals[4]) # %USED
pv.append("{}{}".format(poolvals[5], poolvals[6])) # MAX AVAIL 27.3 TiB
# pv.append(poolvals[7]) # OBJECTS
poolvals = pv
#print "XXX: poolvals: {} {}".format(len(poolvals), poolvals)
# Nautilus output
if len(poolvals) == 10:
pv = []
pv.append(poolvals[0]) # NAME
pv.append(poolvals[1]) # ID
pv.append("{}{}".format(poolvals[2], poolvals[3])) # USED 27.3 TiB
pv.append(poolvals[7]) # %USED
pv.append("{}{}".format(poolvals[8], poolvals[9])) # MAX AVAIL 27.3 TiB
# pv.append(poolvals[7]) # OBJECTS, not used
poolvals = pv
#print "XXX: poolvals: {} {}".format(len(poolvals), poolvals)
# Octopus >= v15.2.8 (pgs added to ceph-df)
if len(poolvals) == 11:
pv = []
pv.append(poolvals[0]) # NAME
pv.append(poolvals[1]) # ID
#pv.append(poolvals[2]) # PGS, not used
pv.append("{}{}".format(poolvals[3], poolvals[4])) # USED 27.3 TiB
pv.append(poolvals[8]) # %USED
pv.append("{}{}".format(poolvals[9], poolvals[10])) # MAX AVAIL 27.3 TiB
# pv.append(poolvals[7]) # OBJECTS, not used
poolvals = pv
#print "XXX: poolvals: {} {}".format(len(poolvals), poolvals)
pool_used = poolvals[2]
pool_usage_percent = float(poolvals[3])
pool_available_space = poolvals[4]
# pool_objects = float(poolvals[5]) # not used
if pool_usage_percent > args.critical:
print('CRITICAL: %s%% usage in Pool \'%s\' is above %s%% (%s used) | Usage=%s%%;%s;%s;;' % (pool_usage_percent, args.pool, args.critical, pool_used, pool_usage_percent, args.warn, args.critical))
return STATUS_ERROR
if pool_usage_percent > args.warn:
print('WARNING: %s%% usage in Pool \'%s\' is above %s%% (%s used) | Usage=%s%%;%s;%s;;' % (pool_usage_percent, args.pool, args.warn, pool_used, pool_usage_percent, args.warn, args.critical))
return STATUS_WARNING
else:
print('%s%% usage in Pool \'%s\' | Usage=%s%%;%s;%s;;' % (pool_usage_percent, args.pool, pool_usage_percent, args.warn, args.critical))
return STATUS_OK
else:
# print 'DEBUG:', globalvals
# finally 4th element contains percentual value
# print 'DEBUG USAGE:', globalvals[3]
global_usage_percent = float(globalvals[3])
global_available_space = globalvals[1]
global_total_space = globalvals[0]
# print 'DEBUG WARNLEVEL:', args.warn
# print 'DEBUG CRITICALLEVEL:', args.critical
if global_usage_percent > args.critical:
if args.detail:
poollines.insert(0, '\n')
poolout = '\n '.join(poollines)
else:
poolout = ''
print('CRITICAL: global RAW usage of %s%% is above %s%% (%s of %s free)%s | Usage=%s%%;%s;%s;;' % (global_usage_percent, args.critical, global_available_space, global_total_space, poolout, global_usage_percent, args.warn, args.critical))
return STATUS_ERROR
elif global_usage_percent > args.warn:
if args.detail:
poollines.insert(0, '\n')
poolout = '\n '.join(poollines)
else:
poolout = ''
print('WARNING: global RAW usage of %s%% is above %s%% (%s of %s free)%s | Usage=%s%%;%s;%s;;' % (global_usage_percent, args.warn, global_available_space, global_total_space, poolout, global_usage_percent, args.warn, args.critical))
return STATUS_WARNING
else:
print('RAW usage %s%% | Usage=%s%%;%s;%s;;' % (global_usage_percent, global_usage_percent, args.warn, args.critical))
return STATUS_OK
#for
elif err:
# read only first line of error
one_line = err.split('\n')[0]
if '-1 ' in one_line:
idx = one_line.rfind('-1 ')
print('ERROR: %s: %s' % (ceph_exec, one_line[idx+len('-1 '):]))
else:
print(one_line)
return STATUS_UNKNOWN
if __name__ == "__main__":
sys.exit(main())
