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 lock for converter workers and for general message processing in order to avoid duplicating of message processing

Browse Source
This commit is contained in:
zbeacon
2021-10-27 18:50:57 +03:00
parent 01c1022542
commit 95112f9422
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
thingsboard_gateway/gateway/tb_gateway_service.py
View File

@@ -377,13 +377,13 @@ class TBGatewayService:
self._connect_with_connectors()
def send_to_storage(self, connector_name, data):
self.__converted_data_queue.put((connector_name, data), False)
self.__converted_data_queue.put((connector_name, data), True, 100)
def __send_to_storage(self):
while True:
try:
if not self.__converted_data_queue.empty():
connector_name, data = self.__converted_data_queue.get(False)
connector_name, data = self.__converted_data_queue.get(True, 100)
if not connector_name == self.name:
if not TBUtility.validate_converted_data(data):
log.error("Data from %s connector is invalid.", connector_name)