diff --git a/transfer_service/transfer_service.py b/transfer_service/transfer_service.py index db2c869b9f24b58cb9d6522c9d1b9d942da551f2..8884c6ffff728e22fb414f50ba65e7784743d5bb 100644 --- a/transfer_service/transfer_service.py +++ b/transfer_service/transfer_service.py @@ -1,9 +1,12 @@ #!/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 @@ -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")) @@ -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()