Skip to content

Commit 34e9a40

Browse files
committed
Added ability to use useReceivedTs
1 parent 6095fc7 commit 34e9a40

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

thingsboard_gateway/connectors/mqtt/json_mqtt_uplink_converter.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -78,10 +78,9 @@ def _convert_single_item(self, topic, data):
7878

7979
try:
8080
for datatype in datatypes:
81+
timestamp = None
8182
if self.__config.get(USE_RECEIVED_TS_PARAMETER, False) is True:
8283
timestamp = converted_data.metadata["receivedTs"]
83-
else:
84-
timestamp = data.get("ts", data.get("timestamp")) if datatype == 'timeseries' else None
8584

8685
for datatype_config in self.__config.get(datatype, []):
8786
if isinstance(datatype_config, str) and datatype_config == "*":
@@ -116,7 +115,8 @@ def _convert_single_item(self, topic, data):
116115
if datatype == "attributes":
117116
converted_data.add_to_attributes(converted_key, converted_value)
118117
else:
119-
timestamp = TBUtility.resolve_different_ts_formats(data=data, config=datatype_config, logger=self._log, default_ts=False)
118+
if timestamp is None:
119+
timestamp = TBUtility.resolve_different_ts_formats(data=data, config=datatype_config, logger=self._log, default_ts=False)
120120
telemetry_entry = TelemetryEntry({converted_key: converted_value}, timestamp)
121121
converted_data.add_to_telemetry(telemetry_entry)
122122
except Exception as e:

0 commit comments

Comments
 (0)