c3re
/
mqtt2prom
7
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

persist data

master
Dirk Heilig 2024-09-23 15:08:48 +02:00
parent fc0ac95e98
commit 2a07084f9e
1 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
mqtt2prom/run
View File

@ -24,7 +24,15 @@ $ignoreRetained = getEnvWithDefaultInt("IGNORE_RETAINED", 1) ? 1 : 0;
$mqtt = new Mosquitto\Client($mqttClientId); $mqtt = new Mosquitto\Client($mqttClientId);
$data = []; $data = null;
if (is_file("/www/metrics/raw")) {
$data = json_decode(strval(file_get_contents("/www/metrics/raw")), true);
}
if (!is_array($data)) {
$data = [];
}
$mqtt->setCredentials($mqttUser, $mqttPass); $mqtt->setCredentials($mqttUser, $mqttPass);
$usedConfig = [ $usedConfig = [
@ -140,7 +148,7 @@ while ($isRunning) {
$mqtt->loop(100); $mqtt->loop(100);
} }
if ($lastGC + 60*15 < time()) { if ($lastGC + 60 * 15 < time()) {
logit("doing Garbage collection..."); logit("doing Garbage collection...");
$c = gc_collect_cycles(); $c = gc_collect_cycles();
logit("Garbage collection done, $c cycles collected"); logit("Garbage collection done, $c cycles collected");
@ -355,6 +363,14 @@ function output(): void
JSON_PRETTY_PRINT + JSON_UNESCAPED_SLASHES + JSON_UNESCAPED_UNICODE JSON_PRETTY_PRINT + JSON_UNESCAPED_SLASHES + JSON_UNESCAPED_UNICODE
) )
); );
file_put_contents(
"/www/metrics/raw",
json_encode(
$data,
JSON_PRETTY_PRINT + JSON_UNESCAPED_SLASHES + JSON_UNESCAPED_UNICODE
)
);
rename("/www/metrics/new.json", "/www/metrics/metrics.json"); rename("/www/metrics/new.json", "/www/metrics/metrics.json");
rename("/www/metrics/new.prom", "/www/metrics/index.prom"); rename("/www/metrics/new.prom", "/www/metrics/index.prom");
// return $prom; // return $prom;