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

Added parameter minEventsProcess

Browse Source
This commit is contained in:
samson0v
2022-11-21 13:16:52 +02:00
parent c3fe8308b6
commit c5a3ea2e73
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
thingsboard_gateway/gateway/tb_gateway_service.py
View File

@@ -251,7 +251,7 @@ class TBGatewayService:
self.__min_pack_send_delay_ms = 10
self.__min_pack_send_delay_ms = self.__min_pack_send_delay_ms / 1000.0
self.__min_events_process = self.__config['thingsboard'].get('minEventsProcess', 50)
self.__min_pack_size_to_send = self.__config['thingsboard'].get('minPackSizeToSend', 50)
self._send_thread = Thread(target=self.__read_data_from_storage, daemon=True,
name="Send data to Thingsboard Thread")
@@ -859,7 +859,7 @@ class TBGatewayService:
break
events = [self._published_events.get(False, 10) for _ in
range(min(self.__min_events_process, self._published_events.qsize()))]
range(min(self.__min_pack_size_to_send, self._published_events.qsize()))]
for event in events:
try:
if self.tb_client.is_connected() and (