Commit f0fd658e authored by Akshay G's avatar Akshay G

Read config from ENV instead of from config

parent 0e60af8c
......@@ -83,7 +83,7 @@ def get_data(query):
data = response.json()[KariosConstants.QUERIES_KEY][0][KariosConstants.RESULTS_KEY][0] \
[KariosConstants.VALUES_KEY]
df = DataFrame.from_dict(data)
logger.debug("Dataframe --> {}".format(df.head()))
logger.info("Dataframe --> {}".format(df.head()))
if len(df) > 0:
df.columns = [KariosConstants.TIMESTAMP_COLUMN_NAME, list(config[KariosConstants.TAG_HIERARCHY_KEY].keys())
......
#!/usr/bin/env python
import os
import sys
import json
import yaml
import json
# os.environ['config'] = '{"kairosdb_url": "http://192.168.0.207:8080",' \
# '"metric_name": "ilens.live_data.raw",' \
......@@ -30,8 +30,15 @@ if not os.path.exists(os.path.join(os.getcwd(), 'logs')):
LOG_LEVEL = os.environ.get("LOG_LEVEL" ,_config.get('SERVICE_CONFIG', {}).get("LOG_LEVEL", "INFO")).upper()
LOG_HANDLER_NAME = _config.get('SERVICE_CONFIG', {}).get("LOG_HANDLER_NAME", "ReadFromKairos")
config = json.loads(os.environ.get('config'))
# config = json.loads(os.environ.get('config'))
config = {
"shared_volume": os.environ.get("shared_volume"),
"end_absolute": os.environ.get("end_absolute"),
"start_absolute": os.environ.get("start_absolute"),
"tag_hierarchy": json.loads(os.environ.get("tag_hierarchy")),
"metric_name": os.environ.get("metric_name"),
"kairosdb_url": os.environ.get("kairosdb_url")
}
if not os.path.exists(config['shared_volume']):
sys.stderr.write("Shared path does not exist!")
sys.stderr.write("Creating path --> {}".format(config['shared_volume']))
......
from __future__ import absolute_import
from __future__ import division
from __future__ import print_function
import os
import logging
from logging.handlers import RotatingFileHandler
......
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