# echo "# $topic [$rids] -> $file"
cat <<__SHELL__ >> /dev/shm/curl
-curl -G 'http://10.60.0.89:8086/query' --data-urlencode "db=telegraf" --data-urlencode "epoch=s" --data-urlencode "q=SELECT \"value\" FROM \"mqtt_stat\" WHERE time > now() - $INTERVAL AND \"topic\"='$topic' " | sed -e 's/^.*"values":\[\[//' -e 's/\],\[/\n/g' -e 's/,/ /g' -e 's/]].*$//' > /dev/shm/data.$file
+curl -G 'http://10.60.0.92:8086/query' --data-urlencode "db=telegraf" --data-urlencode "epoch=s" --data-urlencode "q=SELECT \"value\" FROM \"mqtt_stat\" WHERE time > now() - $INTERVAL AND \"topic\"='$topic' " | sed -e 's/^.*"values":\[\[//' -e 's/\],\[/\n/g' -e 's/,/ /g' -e 's/]].*$//' > /dev/shm/data.$file
__SHELL__
}
# echo "# $topic [$rids] -> $file"
cat <<__SHELL__ >> /dev/shm/curl
-curl -G 'http://10.60.0.89:8086/query' --data-urlencode "db=telegraf" --data-urlencode "epoch=s" --data-urlencode "q=SELECT \"temperature_C\",\"humidity\" FROM \"mqtt_rtl_433\" WHERE time > now() - $INTERVAL and model='Prologue-TH' AND ( $rids )" | sed -e 's/^.*"values":\[\[//' -e 's/\],\[/\n/g' -e 's/,/ /g' -e 's/]].*$//' > /dev/shm/data.$file
+curl -G 'http://10.60.0.92:8086/query' --data-urlencode "db=telegraf" --data-urlencode "epoch=s" --data-urlencode "q=SELECT \"temperature_C\",\"humidity\" FROM \"mqtt_rtl_433\" WHERE time > now() - $INTERVAL and model='Prologue-TH' AND ( $rids )" | sed -e 's/^.*"values":\[\[//' -e 's/\],\[/\n/g' -e 's/,/ /g' -e 's/]].*$//' > /dev/shm/data.$file
__SHELL__
}
file=$4
cat <<__SHELL__ >> /dev/shm/curl
-curl -G 'http://10.60.0.89:8086/query' --data-urlencode "db=telegraf" --data-urlencode "epoch=s" --data-urlencode "q=SELECT \"$t_col\",\"$h_col\" FROM \"mqtt_tele_sensor\" WHERE time > now() - $INTERVAL and topic='$topic'" | sed -e 's/^.*"values":\[\[//' -e 's/\],\[/\n/g' -e 's/,/ /g' -e 's/]].*$//' > /dev/shm/data.$file
+curl -G 'http://10.60.0.92:8086/query' --data-urlencode "db=telegraf" --data-urlencode "epoch=s" --data-urlencode "q=SELECT \"$t_col\",\"$h_col\" FROM \"mqtt_tele_sensor\" WHERE time > now() - $INTERVAL and topic='$topic'" | sed -e 's/^.*"values":\[\[//' -e 's/\],\[/\n/g' -e 's/,/ /g' -e 's/]].*$//' > /dev/shm/data.$file
__SHELL__
}
+curl -G 'http://10.60.0.92:8086/query' --data-urlencode "db=rtl_433" --data-urlencode "q=SELECT time,id,temperature_C,humidity FROM \"Prologue-TH\" WHERE time > now() - $INTERVAL" -H "Accept: application/csv" --data-urlencode "epoch=s" \
+ | tee /dev/shm/rtl_433.th \
+ | awk -F, '{print $3" "$5" "$6 > "/dev/shm/id."$4 }'
+
+rename_ids() {
+ to=$1
+ rm /dev/shm/data.$to
+ shift
+ while [ ! -z "$1" ] ; do
+ if [ -e /dev/shm/id.$1 ] ; then
+ cat /dev/shm/id.$1 > /dev/shm/data.$to
+ rm /dev/shm/id.$1
+ fi
+ shift
+ done
+}
+
+rename_ids 'vani-t-h' 238 126 # sunce
+rename_ids 'kutija-t-h' 162 237 # hlad
+rename_ids 'kupaona-t-h' 78 15
+rename_ids 'kuhinja-t-h' 154 85
+rename_ids 'soba-t-h' 235 234
+rename_ids 'hodnik-t-h' 99 145
+
+
influx_mqtt 'stat/boiler/DS18B20/temperature' 'DS18B20-t'
influx_mqtt 'stat/boiler/DHT22/temperature' 'DHT22-t'
influx_mqtt 'stat/boiler/DHT22/humidity' 'DHT22-h'
-influx_tele 'tele/ir/SENSOR' 'AM2301_Temperature' 'AM2301_Humidity' 'ir-dht22-t-h'
-influx_tele 'tele/dht11-ir-hdmi/SENSOR' 'DHT11_Temperature' 'DHT11_Humidity' 'stol-dht11-t-h'
+#influx_tele 'tele/ir/SENSOR' 'AM2301_Temperature' 'AM2301_Humidity' 'ir-dht22-t-h'
+#influx_tele 'tele/dht11-ir-hdmi/SENSOR' 'DHT11_Temperature' 'DHT11_Humidity' 'stol-dht11-t-h'
influx_mqtt 'stat/boiler/d' 'boiler-d'
-influx_rtl 'vani-t-h' 0 165 234
-influx_rtl 'kutija-t-h' 104 228 241 # hlad
-influx_rtl 'kupaona-t-h' 114 98
-influx_rtl 'kuhinja-t-h' 199 27
-influx_rtl 'soba-t-h' 59 252
+#influx_rtl 'vani-t-h' 0 165 234
+#influx_rtl 'kutija-t-h' 104 228 241 # hlad
+#influx_rtl 'kupaona-t-h' 114 98
+#influx_rtl 'kuhinja-t-h' 199 27
+#influx_rtl 'soba-t-h' 59 252
cat /dev/shm/curl | parallel
-echo "parallel over" >/dev/stderr
-
GRAY=`echo $QUERY_STRING | grep -i gray | wc -l`
tz_secs=`date +%:z | cut -d: -f1 | sed -e 's/^+//' -e 's/$/ * 3600/' | bc`