mirror of
https://github.com/librenms/librenms-agent.git
synced 2024-05-09 09:54:52 +00:00
61064dc9fe
* Format with isort * Format with Black * Fix CRLF * Format with shellcheck * Fix some warning * Fix PHP style * Dont modifiy check_mk files * Fixes
131 lines
3.3 KiB
Python
Executable File
131 lines
3.3 KiB
Python
Executable File
#!/usr/bin/env python3
|
|
|
|
# Copyright (C) 2015 Mark Schouten <mark@tuxis.nl>
|
|
#
|
|
# This program is free software; you can redistribute it and/or
|
|
# modify it under the terms of the GNU General Public License
|
|
# as published by the Free Software Foundation; version 2 dated June,
|
|
# 1991.
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# See http://www.gnu.org/licenses/gpl.txt for the full license
|
|
|
|
import json
|
|
from subprocess import check_output
|
|
|
|
|
|
def cephversion():
|
|
cephv = (
|
|
check_output(["/usr/bin/ceph", "version"])
|
|
.decode("utf-8")
|
|
.replace("ceph version ", "")
|
|
)
|
|
major, minor = cephv.split(".")[0:2]
|
|
return [int(major), int(minor)]
|
|
|
|
|
|
def cephdf():
|
|
cephdf = (
|
|
check_output(["/usr/bin/ceph", "-f", "json", "df"])
|
|
.decode("utf-8")
|
|
.replace("-inf", "0")
|
|
)
|
|
|
|
s = json.loads(cephdf)
|
|
try:
|
|
ts = s["stats"]["total_bytes"]
|
|
except KeyError:
|
|
ts = s["stats"]["total_space"]
|
|
try:
|
|
tu = s["stats"]["total_used_bytes"]
|
|
except KeyError:
|
|
tu = s["stats"]["total_used"]
|
|
try:
|
|
ta = s["stats"]["total_avail_bytes"]
|
|
except KeyError:
|
|
ta = s["stats"]["total_avail"]
|
|
|
|
print("c:%i:%i:%i" % (ts, tu, ta))
|
|
|
|
for p in s["pools"]:
|
|
b = p["stats"]["bytes_used"]
|
|
a = p["stats"]["max_avail"]
|
|
o = p["stats"]["objects"]
|
|
print("%s:%i:%i:%i" % (p["name"], a, b, o))
|
|
|
|
|
|
def osdperf():
|
|
global major
|
|
osdperf = (
|
|
check_output(["/usr/bin/ceph", "-f", "json", "osd", "perf"])
|
|
.decode("utf-8")
|
|
.replace("-inf", "0")
|
|
)
|
|
|
|
if major > 13:
|
|
for o in json.loads(osdperf)["osdstats"]["osd_perf_infos"]:
|
|
print(
|
|
"osd.%s:%i:%i"
|
|
% (
|
|
o["id"],
|
|
o["perf_stats"]["apply_latency_ms"],
|
|
o["perf_stats"]["commit_latency_ms"],
|
|
)
|
|
)
|
|
else:
|
|
for o in json.loads(osdperf)["osd_perf_infos"]:
|
|
print(
|
|
"osd.%s:%i:%i"
|
|
% (
|
|
o["id"],
|
|
o["perf_stats"]["apply_latency_ms"],
|
|
o["perf_stats"]["commit_latency_ms"],
|
|
)
|
|
)
|
|
|
|
|
|
def poolstats():
|
|
global major
|
|
poolstats = (
|
|
check_output(["/usr/bin/ceph", "-f", "json", "osd", "pool", "stats"])
|
|
.decode("utf-8")
|
|
.replace("-inf", "0")
|
|
)
|
|
|
|
for p in json.loads(poolstats):
|
|
try:
|
|
r = p["client_io_rate"]["read_bytes_sec"]
|
|
except KeyError:
|
|
r = 0
|
|
try:
|
|
w = p["client_io_rate"]["write_bytes_sec"]
|
|
except KeyError:
|
|
w = 0
|
|
try:
|
|
if major > 11:
|
|
o = (
|
|
p["client_io_rate"]["read_op_per_sec"]
|
|
+ p["client_io_rate"]["write_op_per_sec"]
|
|
)
|
|
else:
|
|
o = p["client_io_rate"]["op_per_sec"]
|
|
except KeyError:
|
|
o = 0
|
|
|
|
print("%s:%i:%i:%i" % (p["pool_name"], o, w, r))
|
|
|
|
|
|
major, minor = cephversion()
|
|
|
|
print("<<<app-ceph>>>")
|
|
print("<poolstats>")
|
|
poolstats()
|
|
print("<osdperformance>")
|
|
osdperf()
|
|
print("<df>")
|
|
cephdf()
|