forked from jasonmcintosh/rabbitmq-nagios-plugins
-
Notifications
You must be signed in to change notification settings - Fork 0
/
base_rabbit_check.py
98 lines (78 loc) · 3.15 KB
/
base_rabbit_check.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
import abc
import urllib2
import json
from pynagios import Plugin, make_option, Response, CRITICAL, UNKNOWN
class BaseRabbitCheck(Plugin):
"""
performs a nagios compliant check
attempts to catch all errors. expected usage is with a critical threshold of 0
"""
username = make_option("--username", dest="username", help="RabbitMQ API username", type="string", default="guest")
password = make_option("--password", dest="password", help="RabbitMQ API password", type="string", default="guest")
port = make_option("--port", dest="port", help="RabbitMQ API port", type="string", default="15672")
use_ssl = make_option("--ssl", action="store_true", dest="use_ssl", default=False, help="Use SSL")
def doApiGet(self):
"""
performs and returns content from an api get
"""
password_mgr = urllib2.HTTPPasswordMgrWithDefaultRealm()
password_mgr.add_password(None, self.url, self.options.username, self.options.password)
handler = urllib2.HTTPBasicAuthHandler(password_mgr)
opener = urllib2.build_opener(handler)
response = None
try:
request = opener.open(self.url)
response = request.read()
request.close()
except Exception, e:
response = False
self.rabbit_error = 2
self.rabbit_note = "problem with api get:" + str(e)
return response
def parseJson(self, response):
"""
parse test and return api json
"""
try:
data = json.loads(response)
except Exception, e:
data = None
self.rabbit_error = 4
self.rabbit_note = "problem with json parse:", e
return data
@abc.abstractmethod
def makeUrl(self):
return
@abc.abstractmethod
def testOptions(self):
return
@abc.abstractmethod
def setPerformanceData(self, data, result):
return
@abc.abstractmethod
def parseResult(self, data):
return Response(UNKNOWN, "No result set!")
def check(self):
"""
returns a response and perf data for this check
"""
try:
self.rabbit_error = 0
self.rabbit_note = "action performed successfully"
if not self.testOptions():
return Response(UNKNOWN, "Incorrect check config" + self.rabbit_note)
if not self.options.hostname or not self.options.port or not self.options.username or not self.options.password or not self.testOptions():
return Response(UNKNOWN, "Incorrect missing options")
if not self.makeUrl():
return Response(UNKNOWN, "Error with URL")
response = self.doApiGet()
if self.rabbit_error > 0:
return Response(CRITICAL, self.rabbit_note)
data = self.parseJson(response)
if self.rabbit_error > 0:
return Response(CRITICAL, self.rabbit_note)
result = self.parseResult(data)
self.setPerformanceData(data, result)
return result
except Exception as e:
return Response(UNKNOWN, "Error occurred:" + str(e))