wn/mbusgateway
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

stats

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2020-08-29 18:00:39 +02:00
parent 4393f3747b
commit 13cced9c64
1 changed files with 23 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
snippets/snippet1.py
View File

@ -147,14 +147,14 @@ class MeterbusSerial(object):
expectedUserDataOctets = 0 expectedUserDataOctets = 0
state = MeterbusResponseStates.START1 state = MeterbusResponseStates.START1
while (state not in [MeterbusResponseStates.DONE, MeterbusResponseStates.ERROR, MeterbusResponseStates.TIMEOUT]): while (state not in [MeterbusResponseStates.DONE, MeterbusResponseStates.ERROR, MeterbusResponseStates.TIMEOUT]):
print("Waiting for input ... ") # print("Waiting for input ... ")
c = self.port.read(1) c = self.port.read(1)
if len(c) == 0: if len(c) == 0:
state = MeterbusResponseStates.TIMEOUT state = MeterbusResponseStates.TIMEOUT
continue continue
c = ord(c) c = ord(c)
print("State {}, Octet 0x{:02X}".format(state, c)) # print("State {}, Octet 0x{:02X}".format(state, c))
if state == MeterbusResponseStates.START1: if state == MeterbusResponseStates.START1:
if c == 0x68: if c == 0x68:
@ -221,7 +221,7 @@ class MeterbusSerial(object):
print('Invalid state') print('Invalid state')
state = MeterbusResponseStates.ERROR state = MeterbusResponseStates.ERROR
print(a2h(frameData)) # print(a2h(frameData))
res = {} res = {}
if state == MeterbusResponseStates.DONE: if state == MeterbusResponseStates.DONE:
@ -241,18 +241,34 @@ if __name__ == "__main__":
m = MeterbusSerial() m = MeterbusSerial()
m.open() m.open()
stats = {
84: {
'ok': 0,
'error': 0
},
87: {
'ok': 0,
'error': 0
},
80: {
'ok': 0
'error': 0
}
}
while True: while True:
for a in [ 84, 87, 80 ]: for a in stats.keys():
print("------------")
r = m.shortFrameRequest(0x5b, a) r = m.shortFrameRequest(0x5b, a)
if r['status'] == 'ERROR': if r['status'] == 'ERROR':
stats[a]['error'] += 1
print("Error, last state was {}, restarting loop".format(r['code'])) print("Error, last state was {}, restarting loop".format(r['code']))
m.close() m.close()
sleep(5) sleep(5)
m.open() m.open()
else:
stats[a]['ok'] += 1
sleep(1) sleep(1)
print("") print(stats)
print("-----------------------------------------------")
sleep(15) sleep(15)