diff --git a/myems-cleaning/clean_energy_value.py b/myems-cleaning/clean_energy_value.py index 9a964491..4104d56f 100644 --- a/myems-cleaning/clean_energy_value.py +++ b/myems-cleaning/clean_energy_value.py @@ -186,7 +186,7 @@ def process(logger): cursor_system = None try: cnx_system = mysql.connector.connect(**config.myems_system_db) - cursor_system = cnx_system.cursor(dictionary=True) + cursor_system = cnx_system.cursor() query = (" SELECT id, high_limit, low_limit " " FROM tbl_points " @@ -197,8 +197,8 @@ def process(logger): point_dict = dict() if rows_points is not None and len(rows_points) > 0: for row in rows_points: - point_dict[row['id']] = {"high_limit": row['high_limit'], - "low_limit": row['low_limit']} + point_dict[row[0]] = {"high_limit": row[1], + "low_limit": row[2]} except Exception as e: logger.error("Error in step 2.1 of clean_energy_value.process " + str(e)) time.sleep(60) diff --git a/myems-normalization/virtualpoint.py b/myems-normalization/virtualpoint.py index 49a7297e..2c17fd68 100644 --- a/myems-normalization/virtualpoint.py +++ b/myems-normalization/virtualpoint.py @@ -22,7 +22,7 @@ def calculate(logger): cursor_system_db = None try: cnx_system_db = mysql.connector.connect(**config.myems_system_db) - cursor_system_db = cnx_system_db.cursor(dictionary=True) + cursor_system_db = cnx_system_db.cursor() except Exception as e: logger.error("Error in step 0 of virtual point calculate " + str(e)) if cursor_system_db: @@ -48,12 +48,12 @@ def calculate(logger): continue for row in rows_virtual_points: - meta_result = {"id": row['id'], - "name": row['name'], - "data_source_id": row['data_source_id'], - "high_limit": row['high_limit'], - "low_limit": row['low_limit'], - "address": row['address']} + meta_result = {"id": row[0], + "name": row[1], + "data_source_id": row[2], + "high_limit": row[3], + "low_limit": row[4], + "address": row[5]} virtual_point_list.append(meta_result) except Exception as e: