Habe es jetzt gelöst bekommen.
Mit folgendem Skript erhält man ein einziges Measurement was latitude und longitude mit exakt gleichen Zeitstempel enthält. Zusätzlich können latitude und longitude zeitversetzt eintrudeln - welcher Wert zuerst kommt ist dabei egal. In diesem Beispiel hier bis zu 10 Sekunden Versatz. Es wird also obwohl latitude und longitude in unterschiedlichen Datenpunkten liegen und bei Änderung beider Werte das Skript 2x triggert (bei Änderung von latitude und noch mal bei Änderung von longitude) immer nur einmal und nur die Kombination aus beiden neuen Werten in die influxDB geschrieben.
Funktioniert jetzt einwandfrei. Hiermit ist es möglich Koordinaten sauber in der influxDB abzulegen um beispielsweise mit Grafana Routen daraus zu basteln.
// v0.2
const axios = require('axios').default;
const influxDbInstance = 'influxdb.0';
const token = 'TOKEN';
const measurement = 'GPS-Test';
const loggingTemplate = {
'0_userdata.0.test-number2': 'lati',
'0_userdata.0.test-number3': 'longi',
};
const loggingObj = {};
async function start() {
const influxDbInstanceConfig = await getObjectAsync(`system.adapter.${influxDbInstance}`);
const protocol = influxDbInstanceConfig.native.protocol;
const host = influxDbInstanceConfig.native.host;
const port = influxDbInstanceConfig.native.port;
const org = influxDbInstanceConfig.native.organization;
const bucket = influxDbInstanceConfig.native.dbname;
console.log(`Starting "${measurement}" logging to ${protocol}://${host}:${port} into bucket "${bucket}" by org ${org}`);
// Init loggingObj with current values
for (let [objId, key] of Object.entries(loggingTemplate)) {
const state = await getStateAsync(objId);
if (state && !isNaN(state.val)) {
loggingObj[key] = state.val;
} else {
loggingObj[key] = 0;
}
}
// Variable für Timeout sodass bei Wiederholung der vorherige Timeout abgebrochen werden kann
let timeoutHandler;
// Trigger-Bedingung (bei Änderung eines der DP (loggingTemplate))
on({ id: Object.keys(loggingTemplate), change: 'ne' }, async (obj) => {
// Update value in loggingObj
const key = loggingTemplate[obj.id];
loggingObj[key] = obj.state.val;
// Lösche vorherigen Timeout, falls vorhanden
if (timeoutHandler) {
clearTimeout(timeoutHandler);
}
// Setze neuen Timeout
timeoutHandler = setTimeout(async () => {
// Save Data
const data = `${measurement} ${Object.keys(loggingObj)
.filter(key => !isNaN(loggingObj[key]))
.map((key) => `${key}=${loggingObj[key]}`)
.join(',')}`;
if (data) {
// console.log(`Saving "${data}" to InfluxDB @ ${protocol}://${host}:${port}/`);
axios.post(`${protocol}://${host}:${port}/api/v2/write?bucket=${bucket}&org=${org}`, data, {
headers: {
'Content-Type': 'text/plain',
'Authorization': `Token ${token}`
}
}).catch(err => {
console.error(err);
});
}
}, 10000); // 10.000 Millisekunden = 10 Sekunden
});
}
start();
Uns so hier sieht das ganze dann in Grafana mit dem Widget Geomap aus:
2023-12-19 14_21_41-Window.png
from(bucket: "iobroker")
|> range(start: v.timeRangeStart, stop: v.timeRangeStop)
|> filter(fn: (r) =>
r._measurement == "GPS-Test" and
r._field == "lati" or
r._field == "longi" )
|> pivot(rowKey:["_time"], columnKey: ["_field"], valueColumn: "_value")
|> drop(columns: ["_start", "_stop", "_measurement"])
