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

Tweaks based on PR comments

Browse Source
This commit is contained in:
Kevin Poole
2022-05-31 08:21:52 -04:00
parent 2bae7d7f63
commit 8103fb6f76
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
thingsboard_gateway/gateway/tb_gateway_service.py
View File

@@ -642,7 +642,7 @@ class TBGatewayService:
# First, loop through the attributes
for attribute in data['attributes']:
adopted_data['attributes'].update({attribute: data['attributes'][attribute]})
adopted_data['attributes'].update(attribute)
adopted_data_size = self.__get_data_size(adopted_data)
if adopted_data_size >= max_data_size:
# We have surpassed the max_data_size, so send what we have and clear attributes
@@ -650,7 +650,8 @@ class TBGatewayService:
adopted_data['attributes'] = {}
# Now, loop through telemetry. Possibly have some unsent attributes that have been adopted.
for ts_kv_list in data['telemetry']:
telemetry = data['telemetry'] if isinstance(data['telemetry'], list) else [data['telemetry']]
for ts_kv_list in telemetry:
ts = ts_kv_list['ts']
for kv in ts_kv_list['values']:
if len(adopted_data['telemetry']) == 0: