Puede utilizar esta secuencia de comandos de Python para supervisar su clúster de Elasticsearch. Este script verifica su IP: puerto para el estado de Elasticsearch. Esta y más secuencias de comandos de Python para supervisar Elasticsearch se pueden encontrar en here.
#!/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
class ESClusterHealthCheck(NagiosCheck):
def __init__(self):
NagiosCheck.__init__(self)
self.add_option('H', 'host', 'host', 'The cluster to check')
self.add_option('P', 'port', 'port', 'The ES port - defaults to 9200')
def check(self, opts, args):
host = opts.host
port = int(opts.port or '9200')
try:
response = urllib2.urlopen(r'http://%s:%d/_cluster/health'
% (host, port))
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:
es_cluster_health = json.loads(response_body)
except ValueError:
raise Status('unknown', ("API returned nonsense",))
cluster_status = es_cluster_health['status'].lower()
if cluster_status == 'red':
raise Status("CRITICAL", "Cluster status is currently reporting as "
"Red")
elif cluster_status == 'yellow':
raise Status("WARNING", "Cluster status is currently reporting as "
"Yellow")
else:
raise Status("OK",
"Cluster status is currently reporting as Green")
if __name__ == "__main__":
ESClusterHealthCheck().run()
¡Gracias por resolver esto! Además de trabajar en todos los sistemas para evitar problemas de seguridad, es ideal para monitorear clústeres en máquinas con diferentes estructuras de directorios. El complemento check_http está en 3 directorios diferentes en nuestros diversos servidores. Este método me permite ejecutar la verificación, pero deja que la máquina local administre la ruta del complemento. ¡Gracias de nuevo! –