mirror/thingsboard-gateway
1
0
Fork 0
mirror of https://github.com/thingsboard/thingsboard-gateway synced 2025-10-26 22:31:42 +08:00
Code Issues Releases Wiki Activity

Some improvements for performance

Browse Source
This commit is contained in:
zbeacon
2019-12-10 13:17:47 +02:00
parent 400e1813e1
commit 4fc1ec11a3
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
thingsboard_gateway/gateway/tb_gateway_service.py
View File

@@ -16,7 +16,7 @@ import logging.config
import logging.handlers import logging.handlers
import time import time
import yaml import yaml
from json import load, loads, dumps from simplejson import load, loads, dumps
from os import listdir, path from os import listdir, path
from threading import Thread from threading import Thread
from thingsboard_gateway.gateway.tb_client import TBClient from thingsboard_gateway.gateway.tb_client import TBClient
@@ -85,7 +85,7 @@ class TBGatewayService:
self.__rpc_requests_in_progress[rpc_in_progress][2](rpc_in_progress) self.__rpc_requests_in_progress[rpc_in_progress][2](rpc_in_progress)
self.cancel_rpc_request(rpc_in_progress) self.cancel_rpc_request(rpc_in_progress)
if int(time.time()*1000) - gateway_statistic_send >= 60000: if time.time()*1000 - gateway_statistic_send > 60000.0:
summary_messages = {"SummaryReceived": 0, "SummarySent": 0} summary_messages = {"SummaryReceived": 0, "SummarySent": 0}
telemetry = {} telemetry = {}
for connector in self.available_connectors: for connector in self.available_connectors:
@@ -96,7 +96,7 @@ class TBGatewayService:
summary_messages['SummaryReceived'] += telemetry[(connector+' MessagesReceived').replace(' ', '')] summary_messages['SummaryReceived'] += telemetry[(connector+' MessagesReceived').replace(' ', '')]
summary_messages['SummarySent'] += telemetry[(connector+' MessagesSent').replace(' ', '')] summary_messages['SummarySent'] += telemetry[(connector+' MessagesSent').replace(' ', '')]
self.tb_client.client.send_telemetry(summary_messages) self.tb_client.client.send_telemetry(summary_messages)
gateway_statistic_send = int(time.time()*1000) gateway_statistic_send = time.time()*1000
except Exception as e: except Exception as e:
log.exception(e) log.exception(e)
for device in self.__connected_devices: for device in self.__connected_devices:
@@ -178,7 +178,7 @@ class TBGatewayService:
if events: if events:
for event in events: for event in events:
current_event = loads(event) current_event = loads(event)
time.sleep(.001) # time.sleep(.001)
if current_event.get("telemetry"): if current_event.get("telemetry"):
telemetry = {} telemetry = {}
if type(current_event["telemetry"]) == list: if type(current_event["telemetry"]) == list: