Gecko [ waterstats.dev.bestseocompanymiami.com ]

Name	Size	Permission
__pycache__	[ DIR ]	drwxr-xr-x
__init__.py	0 B	-rw-r--r--
apache.py	20.07 KB	-rw-r--r--
apache_kafka.py	13.66 KB	-rw-r--r--
apache_zookeeper.py	6.34 KB	-rw-r--r--
bandwidth.py	22.59 KB	-rw-r--r--
cassandra.py	9.46 KB	-rw-r--r--
cert.py	2.89 KB	-rw-r--r--
couch.py	9.56 KB	-rw-r--r--
cpu_usage.py	32.09 KB	-rw-r--r--
dem_plugin.py	7.48 KB	-rw-r--r--
disk.py	16.8 KB	-rw-r--r--
docker.py	38.95 KB	-rw-r--r--
elasticsearch.py	2.9 KB	-rw-r--r--
entropy.py	930 B	-rw-r--r--
exim.py	1 KB	-rw-r--r--
file_presence.py	5.07 KB	-rw-r--r--
fortisase_connection.py	6.99 KB	-rw-r--r--
haproxy.py	13.46 KB	-rw-r--r--
io_stats.py	13.39 KB	-rw-r--r--
jboss.py	13.66 KB	-rw-r--r--
jmx.py	8.39 KB	-rw-r--r--
linux_logs.py	3.34 KB	-rw-r--r--
lm_sensors.py	2.54 KB	-rw-r--r--
logstash_forwarder.py	1.64 KB	-rw-r--r--
memcache.py	6.04 KB	-rw-r--r--
memory_usage.py	26.56 KB	-rw-r--r--
mongo.py	16.61 KB	-rw-r--r--
mysql.py	20.4 KB	-rw-r--r--
nagios.py	5.58 KB	-rw-r--r--
nginx.py	12.33 KB	-rw-r--r--
nodejs.py	6.44 KB	-rw-r--r--
ntp.py	1.98 KB	-rw-r--r--
opcache.py	2.3 KB	-rw-r--r--
oracle.py	15.6 KB	-rw-r--r--
package_upgrade.py	8.88 KB	-rw-r--r--
phpfpm.py	5.61 KB	-rw-r--r--
ping.py	2.6 KB	-rw-r--r--
postfix.py	1.99 KB	-rw-r--r--
postgresql.py	21.37 KB	-rw-r--r--
process.py	17.23 KB	-rw-r--r--
rabbitmq.py	19.85 KB	-rw-r--r--
redis.py	11.31 KB	-rw-r--r--
sendmail.py	2.42 KB	-rw-r--r--
sysctl.py	1.42 KB	-rw-r--r--
tcp.py	6.59 KB	-rw-r--r--
template.py	3.28 KB	-rw-r--r--
tomcat.py	7.09 KB	-rw-r--r--
tomcat_jmx.py	19.11 KB	-rw-r--r--
unbound_dns.py	4.62 KB	-rw-r--r--
uptime.py	3.61 KB	-rw-r--r--
users.py	1.09 KB	-rw-r--r--
uwsgi.py	4.73 KB	-rw-r--r--
varnish.py	4.91 KB	-rw-r--r--
weblogic.py	13.84 KB	-rw-r--r--
weblogic12c.py	19.2 KB	-rw-r--r--

Code Editor : tomcat.py

import re
import agent_util
from plugins.tomcat_jmx import TomcatJMXPlugin
import logging

try:
    from bs4 import BeautifulSoup
except:
    try:
        import BeautifulSoup
    except:
        BeautifulSoup = None
from agent_util import float

logger = logging.getLogger(__name__)

def execute_query(config, query):
    username = config["username"].strip()
    password = config["password"].strip()
    url = config["console_url"]
    queryType = "wget -qO-"
    query = query % (queryType, url, username, password)
    ret, output = agent_util.execute_command(query)
    return str(output)

def get_all_data(config):
    query = "%s %s/manager/status/all --user=%s --password=%s"
    output = str(execute_query(config, query))
    dom = BeautifulSoup(output)

def parse_item(item, prefix):
        res = ""
        for line in item.contents:
            if isinstance(line, basestring) and not line.strip().startswith(
                "Start time"
            ):
                res += "%s " % line
        results = {}
        for res in re.findall(r"((.*?):\s(.*?)\s((ms|MB|s)\s)?)", res):
            key = "%s/%s" % (prefix, res[1].strip())
            results[key] = {"value": float(res[2]), "unit": res[4]}
        return results

data = {}
    all_items = []
    for heading in reversed(dom.select("h1")):
        heading_text = heading.string.strip('"')
        if heading_text == "Application list":
            continue
        if heading_text == "JVM":
            data[heading_text] = {}
            p = heading.find_next("p")
            data[heading_text].update(parse_item(p, "Total"))
            table = heading.find_next("table")
            if not table:
                continue
            for item in table.find("tbody").find_all("tr"):
                try:
                    row = item.find_all("td")
                    row = [i.text for i in row]
                    mem_type = row[1].replace(" memory", "")
                    pool = row[0]
                    result = {}
                    result["%s/Initial" % mem_type] = {
                        "value": float(row[2].split(" ")[0]),
                        "unit": row[2].split(" ")[1],
                    }
                    result["%s/Total" % mem_type] = {
                        "value": float(row[3].split(" ")[0]),
                        "unit": row[3].split(" ")[1],
                    }
                    result["%s/Max" % mem_type] = {
                        "value": float(row[4].split(" ")[0]),
                        "unit": row[4].split(" ")[1],
                    }
                    result["%s/Used" % mem_type] = {
                        "value": float(row[5].split(" ")[0]),
                        "unit": row[5].split(" ")[1],
                    }
                    result["%s/Used Percentage" % mem_type] = {
                        "value": float(re.findall(r"\(([0-9]*)%\)", row[5])[0]),
                        "unit": "%",
                    }
                    data[pool] = result
                except Exception:
                    import sys

_, e, _ = sys.exc_info()
                    logging.getLogger("plugin 'tomcat'").error(str(e))
                    pass
            continue
        data[heading_text] = {}
        p = heading.find_next("p")
        data[heading_text].update(parse_item(p, "Total"))
        for item in heading.find_all_next("h2"):
            if item not in all_items:
                item["id"] = len(all_items)
                all_items.append(item)
                p = item.find_next("p")
                data[heading_text].update(
                    parse_item(p, item.string.split("[")[0].strip())
                )

reverse_data = {}
    for option, metrics in data.items():
        for metric, properties in metrics.items():
            metric = metric[0].upper() + metric[1:]
            if metric not in reverse_data:
                reverse_data[metric] = {"unit": properties["unit"], "options": {}}
            reverse_data[metric]["options"][option] = properties["value"]

return reverse_data

class TomcatPlugin(agent_util.Plugin):
    textkey = "tomcat"
    label = "Tomcat"

@classmethod
    def get_metadata(self, config):
        if (
            "username" in config and "console_url" in config and "password" in config
        ):  # Tomcat via wget Plugin
            status = agent_util.SUPPORTED
            msg = None

# check for tomcat configuration block
            if (
                "username" not in config
                or "console_url" not in config
                or "password" not in config
                or BeautifulSoup == None
            ):
                self.log.info("tomcat is not configured")
                status = agent_util.MISCONFIGURED
                msg = "tomcat is not configured properly"
                return {}

# check if tomcat is even installed or running
            ret, output = agent_util.execute_command(
                "wget -qO- %s" % config["console_url"]
            )
            if config.get("debug", False):
                self.log.debug("#####################################################")
                self.log.debug(
                    "Tomcat command 'wget -qO- %s' output:" % config["console_url"]
                )
                self.log.debug(str(output))
                self.log.debug("#####################################################")
            if ret != 0:
                self.log.info("tomcat is not running or installed")
                status = agent_util.UNSUPPORTED
                msg = "tomcat not found"
                return {}

data = {}
            for metric, properties in get_all_data(config).items():
                data[metric] = {
                    "label": metric,
                    "options": sorted(properties["options"].keys()),
                    "status": status,
                    "error_message": msg,
                    "unit": properties["unit"] or None,
                }
            return data
        elif "host" in config and "port" in config:  # Tomcat via JMX Plugin
            return TomcatJMXPlugin.get_metadata(config)

self.log.error(
            (
                "tomcat is not configured: you must have either a set"
                " of [username, console_url, password] or [host, port]"
                " configured in your tomcat application block."
            )
        )
        return {}

def check(self, textkey, data, config):
        if (
            "username" in config and "console_url" in config and "password" in config
        ):  # Tomcat via wget Plugin
            try:
                return get_all_data(config)[textkey]["options"][data]
            except:
                return 0
        elif "host" in config and "port" in config:  # Tomcat via JMX Plugin
            return TomcatJMXPlugin.check(textkey, data, config)

${this.title}

Code Editor : tomcat.py