diff --git a/notatki.txt b/notatki.txt index 71a2c786a55e4b0de0563f86453a67bf17719689..8e9ea3380f96464d24e423126fd8c290023a0a0e 100644 --- a/notatki.txt +++ b/notatki.txt @@ -115,3 +115,12 @@ iptables -t nat -A PREROUTING -p tcp -d 192.168.49.32 --dport 4000 -j DNAT --to- +influxd backup -portable -db "sustronics" /imports/backup/influx_20241126_pilot3_3 + + + +Czysczenie DB z blednych pomaiarow: +docker exec -it influxdb /bin/bash +influx -precision 'rfc3339' +use sustronicsPilot3_3 +DELETE FROM "sustronics" WHERE "beacon_t" != 'c00000000104' AND "beacon_t" != 'c00000000103' diff --git a/rewriteDataInIfluxdb.py b/rewriteDataInIfluxdb.py new file mode 100755 index 0000000000000000000000000000000000000000..ef1a122fb7ffa0be74d6accc88a774f71ca36549 --- /dev/null +++ b/rewriteDataInIfluxdb.py @@ -0,0 +1,23 @@ +#!/usr/bin/env python3 +from influxdb import InfluxDBClient + +client_rd = InfluxDBClient('192.168.34.10', port="8086", database='influx') +client_wr = InfluxDBClient('192.168.33.100', port="8087", database='sustronicsPilot3_3') +db_data = client_rd.query("select * from \"sustronics\" where beacon_t='c00000000104' and espar_t='c10000000e17' LIMIT 100000") + +#time beacon_t channel char espar_t pH rssi temp timestamp tx_power +#Sent to MQTT: sustronics,espar_t=c10000000e17,beacon_t=c00000000104 rssi=59,char=15,channel=37,tx_power=8,temp=1,pH=3804,timestamp=47 + + +#print(db_data) +data_to_write = [ + { + 'measurement': 'sustronics', + 'tags': {'espar_t': d['espar_t'],'beacon_t': d['beacon_t']}, + 'time': d['time'], + 'fields': {'rssi':d['rssi'], 'timestamp':d['timestamp'], 'temp':d['temp'], 'pH':d['pH'] } + } + for d in db_data.get_points() + ] +client_wr.write_points(data_to_write) +#data_to_write \ No newline at end of file