Skip to content

T
task_15_pollution_data
Commit 872b1396 authored by arun.uday's avatar arun.uday
Browse files
Options

check for mapper none value added

parent f839f2a7
Hide whitespace changes
Inline Side-by-side
Showing with 9 additions and 2 deletions
scripts/core/handlers/receiver_handlers/select_db_redis.py
View file @ 872b1396
......@@ -11,7 +11,9 @@ def operations_call_(json_poll_data):
1: redis_db_connection.conn_maintenance,
2: redis_db_connection.conn_error
}
# insert the data to the db
insert_data(mapper.get(json_poll_data['data_quality']), json_poll_data)
conn = mapper.get(json_poll_data['data_quality'])
if conn:
# insert the data to the db
insert_data(conn, json_poll_data)
except Exception as e:
logger.exception("Redis mapper Failed", e)
scripts/temp/log_task15.log
View file @ 872b1396
......@@ -4,3 +4,8 @@
2023-02-20 16:17:18 - INFO - Data entered
2023-02-20 16:22:23 - INFO - Data entered
2023-02-20 16:23:45 - INFO - Data entered
2023-02-20 16:30:23 - INFO - Data entered
2023-02-20 16:33:45 - INFO - Data entered
2023-02-20 16:37:28 - INFO - Data entered
2023-02-20 16:38:25 - INFO - Data entered
2023-02-20 16:38:25 - INFO - Data entered
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