Refactor metric retrieval and display

Improved handling of submetrics for better data organization and presentation. Updated metric values based on retrieved data, ensuring accurate representation in the metrics template file.
This commit is contained in:
Jeroen De Meerleer 2024-06-03 23:47:40 +02:00
parent 41f2ddea37
commit 069e550a3f
Signed by: JeroenED
GPG Key ID: 28CCCB8F62BFADD6
2 changed files with 50 additions and 42 deletions

View File

@ -4,53 +4,59 @@ require 'config.php';
if(php_sapi_name() == 'cli' || $_SERVER["REQUEST_URI"] == '/metrics') { if(php_sapi_name() == 'cli' || $_SERVER["REQUEST_URI"] == '/metrics') {
header('Content-Type: text/plain; version=0.0.4'); header('Content-Type: text/plain; version=0.0.4');
foreach ($config as $key => &$c) { foreach ($config as $key => &$metric) {
if(isset($c['command'])) { if (!isset($metric['submetrics'])) {
$output=null; $metric['submetrics'] = [$metric];
$retval=null; }
exec($c['command'], $output, $retval); foreach ($metric['submetrics'] as $key => &$submetric) {
$output = implode("\n", $output);
} elseif(isset($c['http'])) {
$client = new GuzzleHttp\Client();
$options = []; if (isset($submetric['command'])) {
$output = NULL; $output = null;
if (isset($c['http']['proxy'])) { $retval = null;
$options['proxy'] = $c['http']['proxy']; exec($submetric['command'], $output, $retval);
} $output = implode("\n", $output);
if (isset($c['http']['data']) && $c['http']['data'] == 'responsetime') { } elseif (isset($submetric['http'])) {
$options['on_stats'] = function (GuzzleHttp\TransferStats $stats) use (&$output) { $client = new GuzzleHttp\Client();
$output = $stats->getTransferTime();
};
}
$hasresponse = NULL; $options = [];
try{ $output = NULL;
$res = $client->request('GET', $c['http']['url'], $options); if (isset($submetric['http']['proxy'])) {
$hasresponse = true; $options['proxy'] = $submetric['http']['proxy'];
} catch(GuzzleHttp\Exception\GuzzleException $e) { }
if(method_exists($e, 'getResponse')) { if (isset($submetric['http']['data']) && $submetric['http']['data'] == 'responsetime') {
$res = $e->getResponse(); $options['on_stats'] = function (GuzzleHttp\TransferStats $stats) use (&$output) {
$output = $stats->getTransferTime();
};
}
$hasresponse = NULL;
try {
$res = $client->request('GET', $submetric['http']['url'], $options);
$hasresponse = true; $hasresponse = true;
} else { } catch (GuzzleHttp\Exception\GuzzleException $e) {
$hasresponse = false; if (method_exists($e, 'getResponse')) {
$res = $e->getResponse();
$hasresponse = true;
} else {
$hasresponse = false;
}
}
if (isset($submetric['http']['data']) && $submetric['http']['data'] == 'responsebody') {
$output = $res->getBody()->getContents();
} elseif (isset($submetric['http']['data']) && $submetric['http']['data'] == 'hasresponse') {
$output = (int)$hasresponse;
} }
} }
if (isset($c['http']['data']) && $c['http']['data'] == 'responsebody') { if (isset($submetric['jsonelem'])) {
$output = $res->getBody()->getContents(); $submetric['value'] = getArrayValue($submetric['jsonelem'], json_decode($output, true));
} elseif (isset($c['http']['data']) && $c['http']['data'] == 'hasresponse') { } else {
$output = (int)$hasresponse; $submetric['value'] = $output;
} }
}
if(isset($c['jsonelem'])) { if (is_bool($submetric['value'])) $submetric['value'] = $submetric['value'] ? 1 : 0;
$c['value'] = getArrayValue($c['jsonelem'], json_decode($output, true));
} else {
$c['value'] = $output;
} }
if(is_bool($c['value'])) $c['value'] = $c['value'] ? 1 : 0;
} }
$loader = new \Twig\Loader\FilesystemLoader('templates'); $loader = new \Twig\Loader\FilesystemLoader('templates');

View File

@ -1,8 +1,10 @@
{% for key, elem in config %} {% for key, metric in config %}
{% if elem.help is defined and elem.help is not empty %} {% if metric.help is defined and metric.help is not empty %}
# HELP {{ key }} {{ elem.help }} # HELP {{ key }} {{ metric.help }}
{% endif %} {% endif %}
# TYPE {{ key }} gauge # TYPE {{ key }} gauge
{{ key }} {{ elem.value }} {% for subkey, submetric in metric.submetrics %}
{{ key }}{% if submetric.labels is defined and submetric.labels is not empty %}{{ '{' }}{% for label, value in submetric.labels %}{{ label }}="{{ value }}"{% if not loop.last %},{% endif %}{% endfor %}{{ '}' }}{% endif %} {{ submetric.value }}
{% endfor %}
{% endfor %} {% endfor %}