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

add more logs

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

31
mqtt2prom/run
View File

@ -5,7 +5,7 @@ use Mosquitto\Message;
define("STARTED", time()); define("STARTED", time());
$mqttHost = getenv("MQTT_HOST"); $mqttHost = getenv("MQTT_HOST");
if (!$mqttHost) { if (!$mqttHost) {
echo "Please set MQTT_HOST environment variable\n"; logit( "Please set MQTT_HOST environment variable");
exit(1); exit(1);
} }
@ -45,9 +45,9 @@ foreach ($usedConfig as $key => $value) {
echo str_pad($key, $padLength) . ": $value\n"; echo str_pad($key, $padLength) . ": $value\n";
} }
echo "Connecting to $mqttHost:$mqttPort"; logit("Connecting to $mqttHost:$mqttPort");
$mqtt->connect($mqttHost, $mqttPort); $mqtt->connect($mqttHost, $mqttPort);
echo "Connected\n"; logit( "Connected");
$data = []; $data = [];
$stats = [ $stats = [
@ -66,7 +66,7 @@ $mqtt->onMessage(function ($message) use (
&$isRunning, &$isRunning,
$mqttTopic $mqttTopic
) { ) {
echo "got message\n"; logit("got message");
if ($mqttTopic . "/restart" === $message->topic) { if ($mqttTopic . "/restart" === $message->topic) {
$isRunning = false; $isRunning = false;
return; return;
@ -88,27 +88,27 @@ $mqtt->onMessage(function ($message) use (
$news = true; $news = true;
}); });
echo "Subscribing to $mqttTopic with QoS $qos "; logit( "Subscribing to $mqttTopic with QoS $qos ");
$mqtt->subscribe($mqttTopic, $qos); $mqtt->subscribe($mqttTopic, $qos);
$mqtt->subscribe($mqttTopic . "/restart", $qos); $mqtt->subscribe($mqttTopic . "/restart", $qos);
echo "Subscribed\n"; logit( "Subscribed");
$timer = 0; $timer = 0;
echo "Started listening for incoming messages\n will wait 60 seconds before starting to export data\n"; logit("Started listening for incoming messages\n will wait 60 seconds before starting to export data");
$realStart = time() + 15; $realStart = time() + 15;
echo "waiting till " . logit( "waiting till " .
date("Y-m-d H:i:s", $realStart) . date("Y-m-d H:i:s", $realStart) .
" that's in " . " that's in " .
($realStart - time()) . ($realStart - time()) .
" seconds\n"; " seconds");
while (time() < $realStart) { while (time() < $realStart) {
$wait = time() + 5; $wait = time() + 5;
$mqtt->loop(5000); $mqtt->loop(5000);
sleep($wait - time()); sleep($wait - time());
echo "Still waiting...\n"; logit( "Still waiting...");
} }
echo "\n Starting to export data\n"; logit("Starting to export data");
$lastGC = time(); $lastGC = time();
@ -119,7 +119,7 @@ while ($isRunning) {
if ($lastGC + 60 < time()) { if ($lastGC + 60 < time()) {
gc_collect_cycles(); gc_collect_cycles();
$lastGC = time(); $lastGC = time();
echo "GC\n"; logit("doint GC");
} }
if ($loopEnd > microtime(true)) { if ($loopEnd > microtime(true)) {
@ -127,7 +127,7 @@ while ($isRunning) {
} }
if (($news && time() - $timer > 1) || time() - $timer > 15) { if (($news && time() - $timer > 1) || time() - $timer > 15) {
echo "Outputting", $news ? "for changes" : "periodically", "\n"; logit("Outputting ", $news ? "for changes" : "periodically");
output(); output();
$news = false; $news = false;
$timer = time(); $timer = time();
@ -387,3 +387,8 @@ function endit(): void
error("Exiting"); error("Exiting");
} }
function logit():void{
echo date("[Y-m-d H:i:s]")." ".implode(" ",func_get_args())."\n";
}