l33tkrew
commented
2 years ago I encounter the same output when I push data through REST connector. I think it appears when gateway tries to send to main server. Interestingly, The 2.9 version works well. I want to use master branch because docker image and 2.9 version gives error when I want to use REST connector.
As MQTT protocol, even if it gives an error in tb-gateway server, I can see the first data transfer in MQTT Explorer. But, when I run the same command again, I cannot see the data in my MQTT explorer.
======== Running on http://0.0.0.0:5000 ========
(Press CTRL+C to quit)
""2022-01-02 17:44:06" - |INFO| - [tb_gateway_service.py] - tb_gateway_service - __init__ - 154 - Gateway started."
""2022-01-02 17:44:28" - |INFO| - [rest_connector.py] - rest_connector - __call__ - 319 - CONVERTER CONFIG: {'type': 'json', 'deviceNameExpression': 'Device ${name}', 'deviceTypeExpression': 'default', 'attributes': [{'type': 'string', 'key': 'model', 'value': '${sensorModel}'}], 'timeseries': [{'type': 'double', 'key': '${sensorModel}', 'value': '${temp}'}, {'type': 'double', 'key': 'humidity', 'value': '${hum}'}, {'type': 'string', 'key': 'combine', 'value': '${hum}:${temp}'}]}"
""2022-01-02 17:44:28" - |INFO| - [rest_connector.py] - rest_connector - __call__ - 324 - CONVERTED_DATA: {'deviceName': 'Device SN-101', 'deviceType': 'default', 'attributes': [{'model': 'Thermometer'}], 'telemetry': [{'Thermometer': '123'}, {'humidity': '123'}, {'combine': '123:123'}]}"
Exception in thread Thread-4:
Traceback (most recent call last):
File "/usr/lib/python3.8/threading.py", line 932, in _bootstrap_inner
self.run()
File "/usr/lib/python3.8/threading.py", line 870, in run
self._target(*self._args, **self._kwargs)
File "/usr/local/lib/python3.8/dist-packages/paho_mqtt-1.6.1-py3.8.egg/paho/mqtt/client.py", line 3591, in _thread_main
self.loop_forever(retry_first_connection=True)
File "/usr/local/lib/python3.8/dist-packages/paho_mqtt-1.6.1-py3.8.egg/paho/mqtt/client.py", line 1756, in loop_forever
rc = self._loop(timeout)
File "/usr/local/lib/python3.8/dist-packages/paho_mqtt-1.6.1-py3.8.egg/paho/mqtt/client.py", line 1164, in _loop
rc = self.loop_read()
File "/usr/local/lib/python3.8/dist-packages/paho_mqtt-1.6.1-py3.8.egg/paho/mqtt/client.py", line 1556, in loop_read
rc = self._packet_read()
File "/usr/local/lib/python3.8/dist-packages/paho_mqtt-1.6.1-py3.8.egg/paho/mqtt/client.py", line 2439, in _packet_read
rc = self._packet_handle()
File "/usr/local/lib/python3.8/dist-packages/paho_mqtt-1.6.1-py3.8.egg/paho/mqtt/client.py", line 3033, in _packet_handle
return self._handle_publish()
File "/usr/local/lib/python3.8/dist-packages/paho_mqtt-1.6.1-py3.8.egg/paho/mqtt/client.py", line 3330, in _handle_publish
self._handle_on_message(message)
File "/usr/local/lib/python3.8/dist-packages/paho_mqtt-1.6.1-py3.8.egg/paho/mqtt/client.py", line 3570, in _handle_on_message
on_message(self, self._userdata, message)
File "/usr/local/lib/python3.8/dist-packages/thingsboard_gateway-2.9-py3.8.egg/thingsboard_gateway/tb_client/tb_gateway_mqtt.py", line 79, in _on_message
self._on_decoded_message(content, message)
File "/usr/local/lib/python3.8/dist-packages/thingsboard_gateway-2.9-py3.8.egg/thingsboard_gateway/tb_client/tb_gateway_mqtt.py", line 97, in _on_decoded_message
target = content["device"] + "|*"
KeyError: 'device'
""2022-01-02 17:44:44" - |INFO| - [rest_connector.py] - rest_connector - __call__ - 319 - CONVERTER CONFIG: {'type': 'json', 'deviceNameExpression': 'Device ${name}', 'deviceTypeExpression': 'default', 'attributes': [{'type': 'string', 'key': 'model', 'value': '${sensorModel}'}], 'timeseries': [{'type': 'double', 'key': '${sensorModel}', 'value': '${temp}'}, {'type': 'double', 'key': 'humidity', 'value': '${hum}'}, {'type': 'string', 'key': 'combine', 'value': '${hum}:${temp}'}]}"
""2022-01-02 17:44:44" - |INFO| - [rest_connector.py] - rest_connector - __call__ - 324 - CONVERTED_DATA: {'deviceName': 'Device SN-102', 'deviceType': 'default', 'attributes': [{'model': 'Thermometer'}], 'telemetry': [{'Thermometer': '123'}, {'humidity': '123'}, {'combine': '123:123'}]}"
imbeacon
Describe the issue When I push data from the client, I could see the result in MQTT explorer. But I cannot push the data more than once. I do not encounter this problem in deb package (2.9). I cannot spam data when I install tb-gateway latest image or tb-gateway latest master branch. Again the error below only occurs when I send the first data.
The command I run in client: Again I run the same command multiple times in 2.9 (deb package) version. It works well. But I want it to work in the newest version of tb-gateway as well.
Configuration (Attach your configuration file) I only changed security section
Connector name (If you need help with some connector/converter): MQTT Connector
Error traceback (If it was raised):
Versions (please complete the following information):