X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fcmd%2Fmon_evaluator.py;h=ba9a4201ae6a519981c13d1d4bd1d980787584f8;hb=0085a4a8870a73a9186b0a2305ba00bae44a6ea0;hp=7d783d3c398e093d7e0b102550183721910748d5;hpb=51f4486b06781541ee15ea332261247ed3e930f6;p=osm%2FMON.git diff --git a/osm_mon/cmd/mon_evaluator.py b/osm_mon/cmd/mon_evaluator.py index 7d783d3..ba9a420 100644 --- a/osm_mon/cmd/mon_evaluator.py +++ b/osm_mon/cmd/mon_evaluator.py @@ -21,31 +21,33 @@ # For those usages not covered by the Apache License, Version 2.0 please # contact: bdiaz@whitestack.com or glavado@whitestack.com ## +import argparse import logging import sys -from osm_mon.core.settings import Config +from osm_mon.core.config import Config from osm_mon.evaluator.evaluator import Evaluator def main(): - cfg = Config.instance() + parser = argparse.ArgumentParser(prog='osm-mon-evaluator') + parser.add_argument('--config-file', nargs='?', help='MON configuration file') + args = parser.parse_args() + cfg = Config(args.config_file) root = logging.getLogger() - root.setLevel(logging.getLevelName(cfg.OSMMON_LOG_LEVEL)) + root.setLevel(logging.getLevelName(cfg.get('global', 'loglevel'))) ch = logging.StreamHandler(sys.stdout) - ch.setLevel(logging.getLevelName(cfg.OSMMON_LOG_LEVEL)) + ch.setLevel(logging.getLevelName(cfg.get('global', 'loglevel'))) formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s', '%m/%d/%Y %I:%M:%S %p') ch.setFormatter(formatter) root.addHandler(ch) - kafka_logger = logging.getLogger('kafka') - kafka_logger.setLevel(logging.getLevelName(cfg.OSMMON_KAFKA_LOG_LEVEL)) - log = logging.getLogger(__name__) log.info("Starting MON Evaluator...") - log.info("Config: %s", vars(cfg)) - evaluator = Evaluator() + log.debug("Config: %s", cfg.conf) + log.info("Initializing database...") + evaluator = Evaluator(cfg) evaluator.evaluate_forever()