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

add more logs

master
Dirk Heilig 2024-09-23 11:28:59 +02:00
parent f8a0b4fe17
commit 347f0b35d9
1 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
mqtt2prom/run
View File

@ -66,6 +66,7 @@ $mqtt->onMessage(function ($message) use (
&$isRunning,
$mqttTopic
) {
echo "got message\n";
if ($mqttTopic . "/restart" === $message->topic) {
$isRunning = false;
return;
@ -109,9 +110,24 @@ while (time() < $realStart) {
}
echo "\n Starting to export data\n";
$lastGC = time();
while ($isRunning) {
$loopEnd = microtime(true) + 1;
$mqtt->loop(1000);
if ($news || time() - $timer > 15) {
if ($lastGC + 60 < time()) {
gc_collect_cycles();
$lastGC = time();
echo "GC\n";
}
if ($loopEnd > microtime(true)) {
usleep(intval($loopEnd - microtime(true)) * 1000000);
}
if (($news && time() - $timer > 1) || time() - $timer > 15) {
echo "Outputting", $news ? "for changes" : "periodically", "\n";
output();
$news = false;
$timer = time();
@ -242,7 +258,6 @@ function output(): void
43200 => "12 Hours",
86400 => "Day",
];
echo "# gc_collect_cycles ".gc_collect_cycles()."\n";
foreach ($stats as $key => $values) {
$prom .= "# \n";
foreach ($timeframe as $time => $name) {