CSV-Kairos-ADX Data Push

data_push_with_tag.py

@@ -7,7 +7,7 @@ from azure.iot.device import IoTHubDeviceClient
 from kairos_to_IoT_Hub_data_push import KairosDataPush
 
 # COMMON CONSTANTS
-TIME_INTERVAL = 10
+TIME_INTERVAL = 60
 EQUIPMENT = "Equipment"
 MACHINE = "Machine"
 PARAMETER_NAME_KEY = "Parameter Name"
@@ -146,7 +146,9 @@ class SDKIoTHubIntegration:
                             final_json[DATA_KEY][each_columns] = {
                                 VAL_KEY: float(data_point),
                                 DQ_KEY: 1,
-                                TA_KEY: self.mapping_json[each_columns][TA_KEY],
+                                TA_KEY: str(
+                                    self.mapping_json[each_columns][TA_KEY]).replace(
+                                    " ", ""),
                                 TH_KEY: self.mapping_json[each_columns][TH_KEY]
                             }
                         except:
@@ -154,14 +156,16 @@ class SDKIoTHubIntegration:
                                 final_json[DATA_KEY][each_columns] = {
                                     VAL_KEY: data_point,
                                     DQ_KEY: 1,
-                                    TA_KEY: self.mapping_json[each_columns][TA_KEY],
+                                    TA_KEY: str(self.mapping_json[each_columns][
+                                                    TA_KEY]).replace(" ", ""),
                                     TH_KEY: self.mapping_json[each_columns][TH_KEY]
                                 }
                             else:
                                 final_json[DATA_KEY][each_columns] = {
                                     VAL_KEY: None,
                                     DQ_KEY: 2,
-                                    TA_KEY: self.mapping_json[each_columns][TA_KEY],
+                                    TA_KEY: str(self.mapping_json[each_columns][
+                                                    TA_KEY]).replace(" ", ""),
                                     TH_KEY: self.mapping_json[each_columns][TH_KEY]
                                 }