VladislavOstapov/mb-tcp-logger
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Изменил логику опроса

Browse Source
This commit is contained in:
Vladislav 2023-10-31 10:38:10 +03:00
parent 0ac7db0b0d
commit 2033cc1137
1 changed files with 23 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
endpoint.py
View File

@ -178,10 +178,6 @@ class Endpoint(Thread):
else: else:
last_row = None last_row = None
while True:
# время следующего опроса
need_time = last_query + scan_rate
while True: while True:
try: try:
row = self.__mb_read_all_regs() row = self.__mb_read_all_regs()
@ -201,19 +197,20 @@ class Endpoint(Thread):
if not equal: if not equal:
self.__insert_db_row(row) self.__insert_db_row(row)
last_row = row last_row = row
last_query = need_time
break break
except Exception as ex: except Exception as ex:
journal.log(f"Exception: {ex}") journal.log(f"Exception: {ex}")
time.sleep(1) # небольшая задержка, чтоб не спамить запросами
need_time = datetime.now() + scan_rate
# вычислим время до следующего опроса и подождем # вычислим время до следующего опроса и подождем
# время следующего опроса
need_time = last_query + scan_rate
curr_time = datetime.now() curr_time = datetime.now()
if need_time > curr_time: if need_time > curr_time:
delta = need_time - curr_time delta = need_time - curr_time
time.sleep(delta.seconds + (delta.microseconds / 1000000)) time.sleep(delta.seconds + (delta.microseconds / 1000000))
last_query = need_time
else:
last_query = datetime.now()
def run(self): def run(self):
# запускаем клиента модбас # запускаем клиента модбас