Loading transfer_service/transfer_service.py +16 −2 Original line number Diff line number Diff line #!/usr/bin/env python import logging from config import Config from cli_handler import CliHandler from job_scheduler import JobScheduler from log_listener import LogListener from redis_log_handler import RedisLogHandler from vospace_rest_handler import VOSpaceRestHandler Loading @@ -11,6 +14,18 @@ class TransferService(object): def __init__(self): config = Config("/etc/vos_ts/vos_ts.conf") params = config.loadSection("logging") self.logger = logging.getLogger(__name__) logLevel = "logging." + params["log_level"] logFormat = params["log_format"] logFormatter = logging.Formatter(logFormat) self.logger.setLevel(eval(logLevel)) redisLogHandler = RedisLogHandler() logStreamHandler = logging.StreamHandler() logStreamHandler.setFormatter(logFormatter) redisLogHandler.setFormatter(logFormatter) self.logger.addHandler(redisLogHandler) self.logger.addHandler(logStreamHandler) params = config.loadSection("job_cache") self.cliHandler = CliHandler(params["host"], params.getint("port"), params.getint("db_sched")) self.vosRestHandler = VOSpaceRestHandler(params["host"], params.getint("port"), params.getint("db_sched")) Loading Loading @@ -54,8 +69,7 @@ class TransferService(object): self.jobScheduler.start() self.vosRestHandler.start() self.cliHandler.start() print("\nVOSpace Transfer Service is RUNNING...\n") self.logger.info("========== VOSpace Transfer Service is RUNNING! ==========") ts = TransferService() ts.start() Loading
transfer_service/transfer_service.py +16 −2 Original line number Diff line number Diff line #!/usr/bin/env python import logging from config import Config from cli_handler import CliHandler from job_scheduler import JobScheduler from log_listener import LogListener from redis_log_handler import RedisLogHandler from vospace_rest_handler import VOSpaceRestHandler Loading @@ -11,6 +14,18 @@ class TransferService(object): def __init__(self): config = Config("/etc/vos_ts/vos_ts.conf") params = config.loadSection("logging") self.logger = logging.getLogger(__name__) logLevel = "logging." + params["log_level"] logFormat = params["log_format"] logFormatter = logging.Formatter(logFormat) self.logger.setLevel(eval(logLevel)) redisLogHandler = RedisLogHandler() logStreamHandler = logging.StreamHandler() logStreamHandler.setFormatter(logFormatter) redisLogHandler.setFormatter(logFormatter) self.logger.addHandler(redisLogHandler) self.logger.addHandler(logStreamHandler) params = config.loadSection("job_cache") self.cliHandler = CliHandler(params["host"], params.getint("port"), params.getint("db_sched")) self.vosRestHandler = VOSpaceRestHandler(params["host"], params.getint("port"), params.getint("db_sched")) Loading Loading @@ -54,8 +69,7 @@ class TransferService(object): self.jobScheduler.start() self.vosRestHandler.start() self.cliHandler.start() print("\nVOSpace Transfer Service is RUNNING...\n") self.logger.info("========== VOSpace Transfer Service is RUNNING! ==========") ts = TransferService() ts.start()