Commit 10333fe8 authored by suryakant's avatar suryakant

CSV-Kairos-ADX Data Push

parent 43a0965d
This diff is collapsed.
......@@ -7,7 +7,7 @@ from azure.iot.device import IoTHubDeviceClient
from kairos_to_IoT_Hub_data_push import KairosDataPush
# COMMON CONSTANTS
TIME_INTERVAL = 60
TIME_INTERVAL = 30
EQUIPMENT = "Equipment"
MACHINE = "Machine"
PARAMETER_NAME_KEY = "Parameter Name"
......@@ -70,9 +70,15 @@ class SDKIoTHubIntegration:
# Getting Data from Kairos and Creating CSV from the Tag Data
csv_excel_path, column_list = self.kairos_data_obj.getting_kairos_data(
excel_file_path=EXCEL_FILE_PATH)
tag_list, kairos_data_df = self.kairos_data_obj.reading_csv_excel_file(
csv_excel_path=csv_excel_path)
try:
tag_list, kairos_data_df = self.kairos_data_obj. \
reading_csv_excel_file(
csv_excel_path=csv_excel_path)
except:
print("Exception:- ")
tag_list, kairos_data_df = self.kairos_data_obj. \
reading_csv_excel_file(
csv_excel_path="Data/Kairos/kairos_iot_hub_data.csv")
# Iterating over each data in data_sheet
for each_row in range(len(data_sheet_df)):
......@@ -163,7 +169,7 @@ class SDKIoTHubIntegration:
}
else:
final_json[DATA_KEY][each_columns] = {
VAL_KEY: None,
VAL_KEY: 0,
DQ_KEY: 2,
TA_KEY: str(self.mapping_json[each_columns][
TA_KEY]).replace(" ", "").replace(
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment