nmelone/HP_InHand_IG502
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

updates flowmeterskid and hrtankbattery

Browse Source
This commit is contained in:
Nico Melone
2022-10-26 07:54:07 -05:00
parent 0c0030ef28
commit cd55d7c0d3
4 changed files with 1688 additions and 336 deletions
Download Patch File Download Diff File Expand all files Collapse all files

BIN
Pub_Sub/.DS_Store vendored
View File

Binary file not shown.

21
Pub_Sub/flowmeterskid/thingsboard/v1/flowmeterskid_tb_v1.cfg
View File

File diff suppressed because one or more lines are too long

7
Pub_Sub/flowmeterskid/thingsboard/v1/sub/receiveCommand.py
View File

@@ -69,9 +69,6 @@ def receiveCommand(topic, payload):
message = [{"name": "flowmeter", "measures":[{"name":"reset_totalizers", "value": 1}]}] message = [{"name": "flowmeter", "measures":[{"name":"reset_totalizers", "value": 1}]}]
try: try:
resp = write(message) resp = write(message)
except Exception as e:
logger.error("Failed to write message")
logger.error(e)
payload = { payload = {
"ts": (round(dt.timestamp(dt.now())/600)*600)*1000, "ts": (round(dt.timestamp(dt.now())/600)*600)*1000,
"values": { "values": {
@@ -86,6 +83,10 @@ def receiveCommand(topic, payload):
} }
} }
publish("v1/devices/me/telemetry",json.dumps(payload)) publish("v1/devices/me/telemetry",json.dumps(payload))
except Exception as e:
logger.error("Failed to write message")
logger.error(e)
ack(topic.split("/")[-1], r) ack(topic.split("/")[-1], r)
def ack(msgid, r): def ack(msgid, r):

1340
Pub_Sub/hrtankbattery/thingsboard/hrtankbattery_tb_v1.cfg
View File

File diff suppressed because it is too large Load Diff