-
Notifications
You must be signed in to change notification settings - Fork 58
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Maarten Beeckmans
committed
Oct 8, 2021
1 parent
ae326cf
commit 6d8c190
Showing
12 changed files
with
1,725 additions
and
1 deletion.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,232 @@ | ||
| #!/usr/bin/env python3 | ||
| # -*- 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()) |
Oops, something went wrong.