Skip to content
Snippets Groups Projects
Commit 0a1bf3d3 authored by Matthias Bodenbenner's avatar Matthias Bodenbenner
Browse files
parents 1e2027fb 1344d5b3
No related branches found
No related tags found
No related merge requests found
Pipeline #12429 failed
...@@ -111,3 +111,4 @@ venv.bak/ ...@@ -111,3 +111,4 @@ venv.bak/
*.1 *.1
*.2 *.2
*.3 *.3
.vscode/settings.json
...@@ -28,7 +28,8 @@ Copy To Container: ...@@ -28,7 +28,8 @@ Copy To Container:
- taskkill /FI "WINDOWTITLE eq $env:UUID" - taskkill /FI "WINDOWTITLE eq $env:UUID"
- Remove-Item -Recurse -Force -Path E:\apps\$env:UUID\* - Remove-Item -Recurse -Force -Path E:\apps\$env:UUID\*
- Copy-Item * -Destination E:\apps\$env:UUID\ -Recurse - Copy-Item * -Destination E:\apps\$env:UUID\ -Recurse
- Copy-Item $env:SECRETS\$env:UUID\config.json -Destination E:\apps\$env:UUID\ # - Copy-Item $env:SECRETS\$env:UUID\config.json -Destination E:\apps\$env:UUID\
- fsutil hardlink create E:\apps\$env:UUID\config.json $env:SECRETS\$env:UUID\config.json
Restart: Restart:
......
...@@ -140,7 +140,7 @@ class MQTT2InfluxDB: ...@@ -140,7 +140,7 @@ class MQTT2InfluxDB:
# reconnect then subscriptions will be renewed. # reconnect then subscriptions will be renewed.
for topic in self.topic_list_db: for topic in self.topic_list_db:
# print(topic) # print(topic)
client.subscribe(topic + "/#") client.subscribe(topic + "/#", 1)
def on_message(self, client, userdata, msg): def on_message(self, client, userdata, msg):
...@@ -174,7 +174,9 @@ class MQTT2InfluxDB: ...@@ -174,7 +174,9 @@ class MQTT2InfluxDB:
logger.debug("### CONTENT DICT ### \n" + str(payload_dict)) logger.debug("### CONTENT DICT ### \n" + str(payload_dict))
self.to_database(topic=msg.topic, payload=payload_dict) self.to_database(topic=msg.topic, payload=payload_dict)
except Exception as e: except Exception as e:
logger.error(e) logger.error(f'{e} - {msg.topic}: {msg.payload.decode("utf-8")}')
# logger.error(msg.topic)
# logger.error(msg.payload.decode("utf-8"))
logger.info(str(1000 * (time.perf_counter() - starttime)) + " ms") logger.info(str(1000 * (time.perf_counter() - starttime)) + " ms")
def to_database(self, topic, payload): def to_database(self, topic, payload):
...@@ -207,7 +209,7 @@ class MQTT2InfluxDB: ...@@ -207,7 +209,7 @@ class MQTT2InfluxDB:
[ [
self.topic_list_db[topic_list[0]], self.topic_list_db[topic_list[0]],
{ {
"measurement": measurement, "measurement": measurement.lower(),
"tags": tags, "tags": tags,
"fields": fields, "fields": fields,
"time": payload["timestamp"], "time": payload["timestamp"],
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment