Munin contributed plugins

# Munin plugin to monitor requests number, cache statuses, http status codes and average request

# times of specified nginx upstreams.

# env.graphs - which graphs to produce (optional, list of graphs separated by spaces, default -

#              cache http time request)

# env.upstream - list of upstreams to monitor (mandatory, including port numbers separated by

#                space, e.g.: 10.0.0.1:80 10.0.0.2:8080)

# env.statuses - list of http status codes to monitor (optional, default - all statuses,

#                e.g.: 200 403 404 410 500 502)

# env.percentiles - which percentiles to draw on time graphs (optional, list of percentiles

#                   separated by spaces, default - 80)

# Copy file to directory /usr/share/munin/pligins/ and create symbolic link(s) for each log file

# you wish to monitor.

# log_format upstream "ua=[$upstream_addr] ut=[$upstream_response_time] us=[$upstream_status] \

#     cs=[$upstream_cache_status]"

# Attention! Since the default user (nobody) does not have read permission for nginx log files we

# need to run it as root.

#  #%# family=contrib

httpStatusString = (

    "100:Continue;101:Switching protocols;102:Processing;200:OK;201:Created;202:Accepted;"

    "203:Non-Authoritative Information;204:No content;205:Reset content;206:Partial content;"

    "207:Multi-status;226:IM used;300:Multiple choices;301:Moved permanently;"

    "302:Moved temporarily;303:See other;304:Not modified;305:Use proxy;307:Temporary redirect;"

    "400:Bad request;401:Unauthorized;402:Payment required;403:Forbidden;404:Not found;"

    "405:Method not allowed;406:Not acceptable;407:Proxy Authentication Required;"

    "408:Request timeout;409:Conflict;410:Gone;411:Length required;412:Precondition failed;"

    "413:Request entity too large;414:Request URI too large;415:Usupported media type;"

    "416:Request range not satisfiable;417:Expectation failed;422:Unprocessable entity;"

    "423:Locked;424:Failed dependency;425:Unordered collection;426:Upgrade required;"

    "449:Retry with;456:Unrecoverable error;500:Internal server error;501:Not implemented;"

    "502:Bad gateway;503:Service unavailable;504:Gateway timeout;505:HTTP version not supported;"

    "506:Variant also negotiates;507:Insufficient storage;508:Loop detected;"

    "509:Bandwidth limit exceeded;510:Not extended")

            "title": title,

            "requests": 0

cacheStatusList = {"MISS": 0, "BYPASS": 0, "EXPIRED": 0, "UPDATING": 0, "STALE": 0, "HIT": 0}

            "requests": 0,

            "time": 0,

            "times": [],

            "cache": copy.deepcopy(cacheStatusList),

            "http": copy.deepcopy(httpStatusList)

            print("multigraph nginx_upstream_multi_%s.%s_requests"

                  % (sanitize(siteName), sanitize(upstream)))

            print("multigraph nginx_upstream_multi_%s.%s_times"

                  % (sanitize(siteName), sanitize(upstream)))

                print("us%s_times_percentile_%s.label %s-percentile"

                      % (sanitize(upstream), percentile, percentile))

            print("multigraph nginx_upstream_multi_%s.%s_statuses"

                  % (sanitize(siteName), sanitize(upstream)))

                print("http%s_%s_status.label %s - %s"

                      % (status, sanitize(upstream), status, httpStatusList[status]["title"]))

            print("multigraph nginx_upstream_multi_%s.%s_cache"

                  % (sanitize(siteName), sanitize(upstream)))

    if lastByteHandle is not None:

            time = match.group(2)

            status = match.group(3)

            cache = match.group(4)

            address = re.sub(r"\s+", " ", address)

            time = time.replace(",", " ")

            time = time.replace(" : ", " ")

            time = re.sub(r"\s+", " ", time)

            status = status.replace(",", " ")

            status = status.replace(" : ", " ")

            status = re.sub(r"\s+", " ", status)

            cache = cache.replace(",", " ")

            cache = cache.replace(" : ", " ")

            cache = re.sub(r"\s+", " ", cache)

            times = time.split()

            statuses = status.split()

            caches = cache.split()

                        uTime = float(times[index])

                        uTime = 0

                        uStatus = statuses[index]

                        uCache = caches[index]

                        upstreams[uAddress]["requests"] += 1

                        upstreams[uAddress]["time"] += uTime

                        upstreams[uAddress]["cache"][uCache] += 1

            print("multigraph nginx_upstream_multi_%s.%s_requests"

                  % (sanitize(siteName), sanitize(upstream)))

            print("multigraph nginx_upstream_multi_%s.%s_times"

                  % (sanitize(siteName), sanitize(upstream)))

                    if len(upstreams[upstream]["times"]) % 2 > 0:

                        percentileValue = (upstreams[upstream]["times"][low]

                                           + upstreams[upstream]["times"][high]) / 2

                print("us%s_times_percentile_%s.value %s"

                      % (sanitize(upstream), percentile, percentileValue))

            print("multigraph nginx_upstream_multi_%s.%s_statuses"

                  % (sanitize(siteName), sanitize(upstream)))

            print("multigraph nginx_upstream_multi_%s.%s_cache"

                  % (sanitize(siteName), sanitize(upstream)))