Initial creation of the check_es_nodes script. This also has a requirements and also a setup.py

Author: stack72

.gitignore

@@ -0,0 +1,4 @@
+build/
+dist/
+venv/
+nagios_elasticsearch.egg-info/

check_es_nodes.py

@@ -0,0 +1,55 @@
+#!/usr/bin/python
+from nagioscheck import NagiosCheck, UsageError
+from nagioscheck import PerformanceMetric, Status
+import urllib2
+import optparse
+
+try:
+    import json
+except ImportError:
+    import simplejson as json
+
+parser = optparse.OptionParser()
+parser.add_option('-E','--expected_nodes_in_cluster', dest='nodes_in_cluster')
+parser.add_option('-H','--host', dest='host')
+parser.add_option('-P','--port', dest='port')
+(opts, args) = parser.parse_args()
+
+mandatories = ['nodes_in_cluster', 'host']
+for m in mandatories:
+  if not opts.__dict__[m]:
+    print "mandatory parameter is missing\n"
+    exit(-1)
+
+def get_json(uri):
+    try:
+        response = urllib2.urlopen(uri)
+    except urllib2.HTTPError, e:
+        raise Status('unknown', ("API failure", None, "API failure:\n\n%s" % str(e)))
+    except urllib2.URLError, e:
+        raise Status('critical', (e.reason))
+
+    response_body = response.read()
+
+    try:
+        json_rep = json.loads(response_body)
+    except ValueError:
+        raise Status('unknown', ("API returned nonsense",))
+
+    return json_rep
+
+def main():
+  host = opts.host
+  port = int(opts.port or '9200')
+  nodes_in_cluster = int(opts.nodes_in_cluster)
+
+  es_cluster_health = get_json(r'http://%s:%d/_cluster/health' %(host, port))
+
+  active_cluster_nodes = es_cluster_health['number_of_nodes']
+
+  if active_cluster_nodes != nodes_in_cluster:
+    raise Status('CRITICAL', "The number of nodes in the cluster is not '%s'" %es_cluster_health['number_of_nodes'])
+  else:
+    raise Status('OK', "The number of nodes in the clust is good")
+
+if __name__ == "__main__":main()

requirements.txt

@@ -0,0 +1,3 @@
+nagioscheck==0.1.6
+setuptools>=3.4.0
+pip>=1.4

setup.py

@@ -0,0 +1,15 @@
+from setuptools import setup, find_packages
+from pip.req import parse_requirements
+
+setup(
+    name="nagios-elasticsearch",
+    description="A selection of Nagios plugins to monitor ElasticSearch",
+    version="0.1.0",
+    packages=find_packages(),
+    url="https://github.com/anchor/nagios-plugin-elasticsearch",
+    scripts=["check_es_nodes.py"],
+    license="MIT",
+    install_requires=[str(req.req) for req in
+                          parse_requirements("requirements.txt")],
+    include_package_data=True
+)