OPCUA converter timestamp = int(time() * 1000)

Author: smatvienko-tb

thingsboard_gateway/connectors/opcua/opcua_uplink_converter.py

@@ -67,7 +67,7 @@ def convert(self, configs, values):
             telemetry_datapoints_count = 0
             attributes_datapoints_count = 0
 
-            basic_timestamp = int(time() * 1000)
+            timestamp = int(time() * 1000)
 
             for val, config in zip(values, configs):
                 if not val:
@@ -91,16 +91,6 @@ def convert(self, configs, values):
 
                 section = DATA_TYPES[config['section']]
 
-                if val.SourceTimestamp is not None:
-                    if abs(basic_timestamp - val.SourceTimestamp.timestamp()) > 3600:
-                        self._log.warning("Timestamps are not in sync for incoming value: %r. "
-                                          "Value timestamp: %s, current timestamp: %s",
-                                          val, val.SourceTimestamp.timestamp(), basic_timestamp)
-                    else:
-                        basic_timestamp = val.SourceTimestamp.timestamp() * 1000
-
-                timestamp = basic_timestamp
-
                 if val.SourceTimestamp and section == TELEMETRY_PARAMETER:
                     telemetry_datapoints_count += 1
                     if timestamp in telemetry_datapoints: