das/DasSimpleExporter
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: das:5fdca2c30d85c8deab8c7142b485ff291abe0141
Branches Tags
das:main
das:dev
das:v.2.1
das:v.2.0
..
compare: das:902d60bbea1abd9f826a0e3e2628a9245b844859
Branches Tags
das:main
das:dev
das:v.2.1
das:v.2.0

No commits in common. "5fdca2c30d85c8deab8c7142b485ff291abe0141" and "902d60bbea1abd9f826a0e3e2628a9245b844859" have entirely different histories.
5fdca2c30d ... 902d60bbea

4 changed files with 22 additions and 24 deletions
Show Stats Expand all files Collapse all files

2
app_config.py
View File

@ -1,6 +1,6 @@
import os
APP_VERSION="2.2"
APP_VERSION="2.1"
SCRIPT_PATH = os.path.dirname(__file__)
CONFIGS_DIR = SCRIPT_PATH + "/configs"
CONFIG_FILE_NAME = CONFIGS_DIR + "/config.json"

12
main.py
View File

@ -44,12 +44,12 @@ def parse_config(cfg):
def init_metric_entities(data):
return {
M.DiskMetric(data),
M.HealthMetric(data),
M.IcmpMetric(data),
M.InterfaceMetric(data),
M.RestValueMetric(data),
M.ShellValueMetric(data),
M.DiskMetric(data, app_config.INSTANCE_PREFIX),
M.HealthMetric(data, app_config.INSTANCE_PREFIX),
M.IcmpMetric(data, app_config.INSTANCE_PREFIX),
M.InterfaceMetric(data, app_config.INSTANCE_PREFIX),
M.RestValueMetric(data, app_config.INSTANCE_PREFIX),
M.ShellValueMetric(data, app_config.INSTANCE_PREFIX),
M.UptimeMetric(app_config.UPTIME_UPDATE_SECONDS),
M.SystemMetric(app_config.SYSTEM_UPDATE_SECONDS)
}

2
metrics/DataStructures.py
View File

@ -249,7 +249,7 @@ class UptimeData(AbstractData):
def __init__(self, interval, prefix=''):
super().__init__('uptime', interval, prefix)
self.uptime = 0
self.c_uptime = get_counter_metric('das_exporter_uptime',
self.c_uptime = get_counter_metric('das_exporter',
'Exporter Uptime for [server] in seconds',
['server'])
self.c_uptime.labels(server=self.instance_prefix)

30
metrics/MetricClasses.py
View File

@ -18,10 +18,8 @@ from metrics.DataStructures import DiskData, HealthData, IcmpData, ENUM_UP_DN_ST
class AbstractMetric:
metric_key = ""
config = {}
prefix = ""
def __init__(self, key, config):
self.metric_key = key
self.prefix = app_config.INSTANCE_PREFIX
if key and key in config:
self.config = config[key]
self.data_array = []
@ -136,12 +134,12 @@ def get_next_update_time(d):
class DiskMetric(AbstractMetric):
def __init__(self, config):
def __init__(self, config, prefix=''):
super().__init__('disk', config)
for d in self.config:
mount_point, interval, name = d['path'], d['interval'], d['name']
total, used, free = shutil.disk_usage(mount_point)
self.data_array.append(DiskData(mount_point, total, used, free, interval, name, self.prefix))
self.data_array.append(DiskData(mount_point, total, used, free, interval, name, prefix))
def proceed_metric(self):
for d in self.data_array:
@ -156,7 +154,7 @@ class DiskMetric(AbstractMetric):
class HealthMetric(AbstractMetric):
def __init__(self, config):
def __init__(self, config, prefix=''):
super().__init__('health', config)
for d in self.config:
name, url, interval, timeout, method = d['name'], d['url'], d['interval'], d['timeout'], d['method']
@ -171,7 +169,7 @@ class HealthMetric(AbstractMetric):
else:
headers = ''
result = is_health_check(url, timeout, method, user, pwd, headers)
self.data_array.append(HealthData(name, url, interval, timeout, result, method, user, pwd, headers, self.prefix))
self.data_array.append(HealthData(name, url, interval, timeout, result, method, user, pwd, headers, prefix))
def proceed_metric(self):
for d in self.data_array:
@ -185,12 +183,12 @@ class HealthMetric(AbstractMetric):
class IcmpMetric(AbstractMetric):
def __init__(self, config):
def __init__(self, config, prefix=''):
super().__init__('ping', config)
for d in self.config:
name, ip, count, interval = d['name'], d['ip'], d['count'], d['interval']
result = is_ping(ip, count)
self.data_array.append(IcmpData(name, ip, count, interval, result, self.prefix))
self.data_array.append(IcmpData(name, ip, count, interval, result, prefix))
def proceed_metric(self):
for d in self.data_array:
@ -204,12 +202,12 @@ class IcmpMetric(AbstractMetric):
class InterfaceMetric(AbstractMetric):
def __init__(self, config):
def __init__(self, config, prefix=''):
super().__init__('iface', config)
for d in self.config:
name, iface, interval = d['name'], d['iface'], d['interval']
result = get_net_iface_stat(iface)
self.data_array.append(InterfaceData(name, iface, interval, result.bytes_sent, result.bytes_recv, self.prefix))
self.data_array.append(InterfaceData(name, iface, interval, result.bytes_sent, result.bytes_recv, prefix))
def proceed_metric(self):
for d in self.data_array:
@ -223,7 +221,7 @@ class InterfaceMetric(AbstractMetric):
class RestValueMetric(AbstractMetric):
def __init__(self, config):
def __init__(self, config, prefix=''):
super().__init__('rest_value', config)
for d in self.config:
name, url, interval, timeout, method = d['name'], d['url'], d['interval'], d['timeout'], d['method']
@ -240,7 +238,7 @@ class RestValueMetric(AbstractMetric):
result_type, result_path = d['result_type'], d['result_path']
result = get_rest_value(url=url, timeout=timeout, method=method, user=user, pwd=pwd, headers=headers,
result_type=result_type, path=result_path)
self.data_array.append(RestValueData(name, url, interval, timeout, result, method, user, pwd, headers, self.prefix, result_type, result_path))
self.data_array.append(RestValueData(name, url, interval, timeout, result, method, user, pwd, headers, prefix, result_type, result_path))
def proceed_metric(self):
for d in self.data_array:
@ -255,12 +253,12 @@ class RestValueMetric(AbstractMetric):
class ShellValueMetric(AbstractMetric):
def __init__(self, config):
def __init__(self, config, prefix=''):
super().__init__('shell_value', config)
for d in self.config:
name, command, interval, args = d['name'], d['command'], d['interval'], d['args']
result = get_shell_value(command, args)
self.data_array.append(ShellValueData(name, interval, command, result, args, self.prefix))
self.data_array.append(ShellValueData(name, interval, command, result, args, prefix))
def proceed_metric(self):
for d in self.data_array:
@ -276,7 +274,7 @@ class ShellValueMetric(AbstractMetric):
class UptimeMetric(AbstractMetric):
def __init__(self, interval):
super().__init__(None, {})
self.data_array.append(UptimeData(interval, self.prefix))
self.data_array.append(UptimeData(interval))
def proceed_metric(self):
for d in self.data_array:
@ -291,7 +289,7 @@ class UptimeMetric(AbstractMetric):
class SystemMetric(AbstractMetric):
def __init__(self, interval):
super().__init__(None, {})
self.data_array.append(SystemData(interval, self.prefix))
self.data_array.append(SystemData(interval, app_config.INSTANCE_PREFIX))
def proceed_metric(self):
for d in self.data_array: