REDROOM

Navigation

Breadcrumbs

/ / lib / fm-agent / plugins

Create

Create File | Create Folder | Upload Files | Run Command

Edit File Size: 2.90 KB

//lib/fm-agent/plugins/elasticsearch.py

Text Base64

import agent_util

class ElasticSearchPlugin(agent_util.Plugin):
    textkey = "elasticsearch"
    label = "Elastic Search"

@classmethod
    def get_metadata(self, config):
        status = agent_util.SUPPORTED
        msg = None

if not config:
            self.log.info(
                "The [elasticsearch] config block not found in the config file"
            )
            return {}

if not "hostname" in config or not "port" in config:
            self.log.info(
                "The [elasticsearch] config block does not contain variables for hostname and/or port"
            )
            return {}

if not agent_util.which("curl", exc=False):
            self.log.info("curl not found!")
            status = agent_util.UNSUPPORTED
            msg = "Curl is not installed - please install"
            return {}

options = []

data = {
            "number_of_nodes": {
                "label": "Total number of nodes in cluster",
                "options": None,
                "status": status,
                "error_message": msg,
            },
            "number_of_data_nodes": {
                "label": "Number of data nodes in cluster",
                "options": None,
                "status": status,
                "error_message": msg,
            },
            "active_primary_shards": {
                "label": "Number of active primary shards",
                "options": None,
                "status": status,
                "error_message": msg,
            },
            "active_shards": {
                "label": "Total number of shards",
                "options": None,
                "status": status,
                "error_message": msg,
            },
            "relocating_shards": {
                "label": "Number of shards getting relocated",
                "options": None,
                "status": status,
                "error_message": msg,
            },
            "initializing_shards": {
                "label": "Number of initializing shards",
                "options": None,
                "status": status,
                "error_message": msg,
            },
            "unassigned_shards": {
                "label": "Number of unassigned shards",
                "options": None,
                "status": status,
                "error_message": msg,
            },
        }
        return data

def check(self, textkey, data, config):
        user_string = ""
        if config.get("username") and config.get("password"):
            user_string = "--user %s:%s" % (
                config.get("username"),
                config.get("password"),
            )

cmd = "curl %s %s:%s/_cluster/health" % (
            user_string,
            config["hostname"],
            config["port"],
        )
        ret, output = agent_util.execute_command(cmd)
        reply = agent_util.json_loads(output)
        return int(reply[textkey])

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Directory Contents

Dirs: 1 Ã— Files: 55

Sort:

Enable drag-to-move

Name	Size	Perms	Modified	Actions
__pycache__ DIR	-	drwxr-xr-x	2025-06-19 05:08:01	Edit Download recursive recursive
apache.py	20.07 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
apache_kafka.py	13.66 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
apache_zookeeper.py	6.34 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
bandwidth.py	22.59 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
cassandra.py	9.46 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
cert.py	2.89 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
couch.py	9.56 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
cpu_usage.py	32.09 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
dem_plugin.py	7.33 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
disk.py	16.80 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
docker.py	38.95 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
elasticsearch.py	2.90 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
entropy.py	930 B	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
exim.py	1.00 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
file_presence.py	5.07 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
fortisase_connection.py	4.68 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
haproxy.py	13.46 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
io_stats.py	13.21 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
jboss.py	13.58 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
jmx.py	8.39 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
linux_logs.py	3.34 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
lm_sensors.py	2.54 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
logstash_forwarder.py	1.64 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
memcache.py	6.04 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
memory_usage.py	26.56 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
mongo.py	16.61 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
mysql.py	20.40 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
nagios.py	5.58 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
nginx.py	12.33 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
nodejs.py	6.44 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
ntp.py	1.98 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
opcache.py	2.30 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
oracle.py	15.51 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
package_upgrade.py	8.88 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
phpfpm.py	5.61 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
ping.py	2.60 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
postfix.py	1.99 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
postgresql.py	21.37 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
process.py	17.23 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
rabbitmq.py	19.85 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
redis.py	11.31 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
sendmail.py	2.42 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
sysctl.py	1.42 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
tcp.py	6.59 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
template.py	3.28 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
tomcat.py	7.09 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
tomcat_jmx.py	19.11 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
unbound_dns.py	4.62 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
uptime.py	3.61 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
users.py	1.09 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
uwsgi.py	4.73 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
varnish.py	4.91 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
weblogic.py	13.84 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
weblogic12c.py	19.20 KB	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive
__init__.py	0 B	lrw-r--r--	2025-06-18 20:44:50	Edit Download recursive recursive