Commit f4dfb826 by ajil.k

updated

parent b5aec168
......@@ -12,16 +12,12 @@ def generate_csv_data(tag_values, response_data):
if data["queries"][0]["sample_size"] > 0:
for i in range(0, len(data["queries"][0]["results"])):
c3 = data["queries"][0]["results"][i]["tags"]["c3"][0]
master_key = c3
if master_key not in temp_json:
temp_json[master_key] = data["queries"][0]["results"][i]["values"]
group_by_name = c3
if group_by_name not in temp_json:
temp_json[group_by_name] = data["queries"][0]["results"][i]["values"]
else:
temp_json[master_key].extend(data["queries"][0]["results"][i]["values"])
"""# Extract values from te query
values = data["queries"][0]["results"][0]["values"]
print(values)
converted_epochs = [convert_epoch(data[0]) for data in values]
value = [data[1] for data in values]"""
temp_json[group_by_name].extend(data["queries"][0]["results"][i]["values"])
da = pd.DataFrame(columns=['Timestamp'])
for key, value in temp_json.items():
dp = pd.DataFrame()
......@@ -30,10 +26,6 @@ def generate_csv_data(tag_values, response_data):
da = pd.concat([da, dp])
new_da = da.fillna("NA")
new_da.to_csv("temp/ilens.csv", index=False)
"""for i in range(len(tag_values)):
tag_name = tag_values[i]
dataframe = pd.DataFrame({'Timestamp': converted_epochs, tag_name: value})
print(dataframe)"""
except Exception as e:
from script.logging.logger import logger
logger.exception(e)
......
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