使用本插件，必须先安装并设置好 NRPE 。

一、插件（mogilefs_check.py）

#!/usr/bin/env python
# coding=utf-8

###############################################
#	nagios plugin
#
#	本插件用于检测MogileFS的工作状态(LITE)
#
#	@author Tianzhen(uimeet.com)
#	@version 0.12.521
###############################################

import os
import sys
import getopt
import re

# status re
STATUS_RE = re.compile(r'([\d\.\:\w\-]+) ... (OK|REQUEST FAILURE)')
def usage():
	print """
Usage: mogile_check.py [-h|--help] [-t|--trackers trackers] \
				[-m|--mogadm 'mogadm' path]

	"""
	sys.exit(3)

def check(inputs, output, prefix):
	"""
	通用的检查方法
	"""
	# 崩溃掉的部分
	ctris= []
	# 匹配的总数
	matches = 0
	while inputs:
		input = inputs.pop(0)
		if input == '\n':
			break

		match = re.search(STATUS_RE, input.strip())
		# 匹配失败
		if not match:
			break

		# 返回给 nagios 的消息
		# 只返回错误消息
		if match.group(2) == 'REQUEST FAILURE':
			ctris.append('[%s]' % match.group(1))

		matches += 1

	if ctris:
		# tracker
		output['msg'].append( '-(%s)- %s: REQUEST FAILURE!!!' % ( prefix, ','.join(ctris) ) )
		if matches == 1 or (matches > 1 and len(ctris) == matches):
			# tracker 全部坏掉了
			# 杯具地崩溃了
			output['status'] = max(output['status'], 2)
		else:
			# 不是全部坏掉，还有希望
			# 给个警告
			output['status'] = max(output['status'], 1)

	return output

def check_host(inputs, output):
	"""
	处理host的检查信息
	"""
	return check(inputs, output, 'HOST')

def check_tracker(inputs, output):
	"""
	处理tracker的检查信息
	"""
	return check(inputs, output, 'TRACKER')

try:
	options, args = getopt.getopt(sys.argv[1:],
			'ht:m:',
			['help','trackers=','mogadm=']
			)
except getopt.GetoptError:
	# 给出的参数无效
	usage()
	sys.exit(3)

# 表示 mogile 的tracker地址
argTrackers = None
# 表示 mogadm 路径
argMogadm = 'mogadm'

# 每个参数各归各位
for name, value in options:
	if name in ('-h', '--help'):
		usage()
	if name in ('-t', '--trackers'):
		argTrackers = value
	if name in ('-m', '--mogadm'):
		argMogadm = value

if not argTrackers:
	# trackers参数无效
	print 'Please most be specified "trackers".'
	sys.exit(3)

out = os.popen('%(mogadm)s --trackers=%(trackers)s check' % {
			'mogadm': argMogadm,
			'trackers': argTrackers,
		}).readlines()

ret = {'msg':[], 'status':0}
while out:
	o = out.pop(0)
	if o:
		# 去掉末尾的 ...\n 符号
		o = o[:-4]
	if o == 'Checking trackers':
		# trackers 状态检查
		check_tracker(out, ret)
	elif o == 'Checking hosts':
		# hosts 状态检查
		check_host(out, ret)
	elif o == 'Checking devices':
		# devices 状态检查
		# 本插件暂不包括 devices 的状态检查
		# 检查到这里时，直接退出
		break
	else:
		# 走到这里来了，那我也不知道该怎么处理
		# 直接跳过吧
		continue

	# 上面出现崩溃的话，没必要继续往下面检查了
	# 速度处理吧
	if ret['status'] == 2:
		break

out = None

if ret:
	# 返回值有效
	if ret['msg']:
		print ' - '.join(ret['msg'])
	else:
		print 'Everything is OK.'

	sys.exit(ret['status'])
else:
	# 返回值无效
	# 给出警告信息，这可能是因为配置的原因引起
	print '未能正确配置插件，状态信息获取失败'
	sys.exit(1)

二、监控服务器的相关设置

Continue reading “Nagios 插件（一）：监控 MogileFS 插件” »