Commit 93f77978 authored by Marco Mariani's avatar Marco Mariani

cli: simpler logging, always use self.app.log

parent a99e2e16
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
import logging
from slapos.cli.command import must_be_root from slapos.cli.command import must_be_root
from slapos.cli.config import ConfigCommand from slapos.cli.config import ConfigCommand
from slapos.bang import do_bang from slapos.bang import do_bang
...@@ -12,8 +10,6 @@ class BangCommand(ConfigCommand): ...@@ -12,8 +10,6 @@ class BangCommand(ConfigCommand):
request update on all partitions request update on all partitions
""" """
log = logging.getLogger('bang')
def get_parser(self, prog_name): def get_parser(self, prog_name):
ap = super(BangCommand, self).get_parser(prog_name) ap = super(BangCommand, self).get_parser(prog_name)
ap.add_argument('-m', '--message', ap.add_argument('-m', '--message',
......
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
import logging
from slapos.cli.config import ConfigCommand from slapos.cli.config import ConfigCommand
from slapos.cache import do_lookup from slapos.cache import do_lookup
...@@ -17,8 +15,6 @@ class CacheLookupCommand(ConfigCommand): ...@@ -17,8 +15,6 @@ class CacheLookupCommand(ConfigCommand):
with the OS you are currently running. with the OS you are currently running.
""" """
log = logging.getLogger('cache-lookup')
def get_parser(self, prog_name): def get_parser(self, prog_name):
ap = super(CacheLookupCommand, self).get_parser(prog_name) ap = super(CacheLookupCommand, self).get_parser(prog_name)
ap.add_argument('software_url', ap.add_argument('software_url',
......
...@@ -13,8 +13,6 @@ class ConfigError(Exception): ...@@ -13,8 +13,6 @@ class ConfigError(Exception):
class ConfigCommand(Command): class ConfigCommand(Command):
"Base class for commands that require a configuration file" "Base class for commands that require a configuration file"
log = None
default_config_var = 'SLAPOS_CONFIGURATION' default_config_var = 'SLAPOS_CONFIGURATION'
# use this if default_config_var does not exist # use this if default_config_var does not exist
...@@ -45,7 +43,7 @@ class ConfigCommand(Command): ...@@ -45,7 +43,7 @@ class ConfigCommand(Command):
cfg_path = self.config_path(args) cfg_path = self.config_path(args)
self.log.debug('Loading config: %s', cfg_path) self.app.log.debug('Loading config: %s', cfg_path)
if not os.path.exists(cfg_path): if not os.path.exists(cfg_path):
raise ConfigError('Configuration file does not exist: %s' % cfg_path) raise ConfigError('Configuration file does not exist: %s' % cfg_path)
......
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
import logging
import re import re
import os import os
import sys import sys
...@@ -16,8 +15,6 @@ class ConfigureClientCommand(ClientConfigCommand): ...@@ -16,8 +15,6 @@ class ConfigureClientCommand(ClientConfigCommand):
register a node in the SlapOS cloud register a node in the SlapOS cloud
""" """
log = logging.getLogger('configure-client')
def get_parser(self, prog_name): def get_parser(self, prog_name):
ap = super(ConfigureClientCommand, self).get_parser(prog_name) ap = super(ConfigureClientCommand, self).get_parser(prog_name)
...@@ -38,7 +35,7 @@ class ConfigureClientCommand(ClientConfigCommand): ...@@ -38,7 +35,7 @@ class ConfigureClientCommand(ClientConfigCommand):
return ap return ap
def take_action(self, args): def take_action(self, args):
do_configure_client(logger=self.log, do_configure_client(logger=self.app.log,
master_url_web=args.master_url_web, master_url_web=args.master_url_web,
token=args.token, token=args.token,
config_path=self.config_path(args), config_path=self.config_path(args),
......
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
import logging
from slapos.cli.config import ClientConfigCommand from slapos.cli.config import ClientConfigCommand
from slapos.client import init, do_console, ClientConfig from slapos.client import init, do_console, ClientConfig
...@@ -22,8 +20,6 @@ class ConsoleCommand(ClientConfigCommand): ...@@ -22,8 +20,6 @@ class ConsoleCommand(ClientConfigCommand):
>>> request(kvm, "myuniquekvm").getConnectionParameter("url") >>> request(kvm, "myuniquekvm").getConnectionParameter("url")
""" """
log = logging.getLogger('console')
def get_parser(self, prog_name): def get_parser(self, prog_name):
ap = super(ConsoleCommand, self).get_parser(prog_name) ap = super(ConsoleCommand, self).get_parser(prog_name)
......
...@@ -57,7 +57,7 @@ class SlapOSApp(cliff.app.App): ...@@ -57,7 +57,7 @@ class SlapOSApp(cliff.app.App):
log = logging.getLogger('slapos') log = logging.getLogger('slapos')
CONSOLE_MESSAGE_FORMAT = '%(message)s' CONSOLE_MESSAGE_FORMAT = '%(message)s'
LOG_FILE_MESSAGE_FORMAT = '[%(asctime)s] %(levelname)-8s %(name)s %(message)s' LOG_FILE_MESSAGE_FORMAT = '[%(asctime)s] %(levelname)-8s %(message)s'
def __init__(self): def __init__(self):
super(SlapOSApp, self).__init__( super(SlapOSApp, self).__init__(
......
...@@ -13,8 +13,6 @@ class FormatCommand(ConfigCommand): ...@@ -13,8 +13,6 @@ class FormatCommand(ConfigCommand):
create users, partitions and network configuration create users, partitions and network configuration
""" """
log = logging.getLogger('format')
def get_parser(self, prog_name): def get_parser(self, prog_name):
ap = super(FormatCommand, self).get_parser(prog_name) ap = super(FormatCommand, self).get_parser(prog_name)
...@@ -64,7 +62,7 @@ class FormatCommand(ConfigCommand): ...@@ -64,7 +62,7 @@ class FormatCommand(ConfigCommand):
def take_action(self, args): def take_action(self, args):
configp = self.fetch_config(args) configp = self.fetch_config(args)
conf = FormatConfig(logger=self.log) conf = FormatConfig(logger=self.app.log)
conf.mergeConfig(args, configp) conf.mergeConfig(args, configp)
...@@ -74,7 +72,7 @@ class FormatCommand(ConfigCommand): ...@@ -74,7 +72,7 @@ class FormatCommand(ConfigCommand):
file_handler = logging.FileHandler(conf.log_file) file_handler = logging.FileHandler(conf.log_file)
formatter = logging.Formatter(self.app.LOG_FILE_MESSAGE_FORMAT) formatter = logging.Formatter(self.app.LOG_FILE_MESSAGE_FORMAT)
file_handler.setFormatter(formatter) file_handler.setFormatter(formatter)
self.log.addHandler(file_handler) self.app.log.addHandler(file_handler)
try: try:
conf.setConfig() conf.setConfig()
......
...@@ -2,7 +2,6 @@ ...@@ -2,7 +2,6 @@
import collections import collections
import hashlib import hashlib
import logging
import lxml.etree import lxml.etree
import prettytable import prettytable
...@@ -18,8 +17,6 @@ class ProxyShowCommand(ConfigCommand): ...@@ -18,8 +17,6 @@ class ProxyShowCommand(ConfigCommand):
display proxy instances and parameters display proxy instances and parameters
""" """
log = logging.getLogger('proxy')
def get_parser(self, prog_name): def get_parser(self, prog_name):
ap = super(ProxyShowCommand, self).get_parser(prog_name) ap = super(ProxyShowCommand, self).get_parser(prog_name)
...@@ -54,7 +51,7 @@ class ProxyShowCommand(ConfigCommand): ...@@ -54,7 +51,7 @@ class ProxyShowCommand(ConfigCommand):
def take_action(self, args): def take_action(self, args):
configp = self.fetch_config(args) configp = self.fetch_config(args)
conf = ProxyConfig(logger=self.log) conf = ProxyConfig(logger=self.app.log)
conf.mergeConfig(args, configp) conf.mergeConfig(args, configp)
conf.setConfig() conf.setConfig()
do_show(conf=conf) do_show(conf=conf)
......
...@@ -12,8 +12,6 @@ class ProxyStartCommand(ConfigCommand): ...@@ -12,8 +12,6 @@ class ProxyStartCommand(ConfigCommand):
minimalist, stand-alone SlapOS Master minimalist, stand-alone SlapOS Master
""" """
log = logging.getLogger('proxy')
def get_parser(self, prog_name): def get_parser(self, prog_name):
ap = super(ProxyStartCommand, self).get_parser(prog_name) ap = super(ProxyStartCommand, self).get_parser(prog_name)
...@@ -26,7 +24,7 @@ class ProxyStartCommand(ConfigCommand): ...@@ -26,7 +24,7 @@ class ProxyStartCommand(ConfigCommand):
def take_action(self, args): def take_action(self, args):
configp = self.fetch_config(args) configp = self.fetch_config(args)
conf = ProxyConfig(logger=self.log) conf = ProxyConfig(logger=self.app.log)
conf.mergeConfig(args, configp) conf.mergeConfig(args, configp)
...@@ -36,7 +34,7 @@ class ProxyStartCommand(ConfigCommand): ...@@ -36,7 +34,7 @@ class ProxyStartCommand(ConfigCommand):
file_handler = logging.FileHandler(conf.log_file) file_handler = logging.FileHandler(conf.log_file)
formatter = logging.Formatter(self.app.LOG_FILE_MESSAGE_FORMAT) formatter = logging.Formatter(self.app.LOG_FILE_MESSAGE_FORMAT)
file_handler.setFormatter(formatter) file_handler.setFormatter(formatter)
self.log.addHandler(file_handler) self.app.log.addHandler(file_handler)
conf.setConfig() conf.setConfig()
......
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
import logging
import sys import sys
from slapos.cli.command import Command, must_be_root from slapos.cli.command import Command, must_be_root
...@@ -12,8 +11,6 @@ class RegisterCommand(Command): ...@@ -12,8 +11,6 @@ class RegisterCommand(Command):
register a node in the SlapOS cloud register a node in the SlapOS cloud
""" """
log = logging.getLogger('register')
def get_parser(self, prog_name): def get_parser(self, prog_name):
ap = super(RegisterCommand, self).get_parser(prog_name) ap = super(RegisterCommand, self).get_parser(prog_name)
...@@ -85,7 +82,7 @@ class RegisterCommand(Command): ...@@ -85,7 +82,7 @@ class RegisterCommand(Command):
@must_be_root @must_be_root
def take_action(self, args): def take_action(self, args):
try: try:
conf = RegisterConfig(logger=self.log) conf = RegisterConfig(logger=self.app.log)
conf.setConfig(args) conf.setConfig(args)
return_code = do_register(conf) return_code = do_register(conf)
except SystemExit as err: except SystemExit as err:
......
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
import logging
from slapos.cli.config import ClientConfigCommand from slapos.cli.config import ClientConfigCommand
from slapos.client import init, ClientConfig from slapos.client import init, ClientConfig
...@@ -11,8 +9,6 @@ class RemoveCommand(ClientConfigCommand): ...@@ -11,8 +9,6 @@ class RemoveCommand(ClientConfigCommand):
remove a Software from a node remove a Software from a node
""" """
log = logging.getLogger('remove')
def get_parser(self, prog_name): def get_parser(self, prog_name):
ap = super(RemoveCommand, self).get_parser(prog_name) ap = super(RemoveCommand, self).get_parser(prog_name)
......
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
import logging
import pprint import pprint
from slapos.cli.config import ClientConfigCommand from slapos.cli.config import ClientConfigCommand
...@@ -25,8 +24,6 @@ def parse_option_dict(options): ...@@ -25,8 +24,6 @@ def parse_option_dict(options):
class RequestCommand(ClientConfigCommand): class RequestCommand(ClientConfigCommand):
"""request an instance and get status and parameters of instance""" """request an instance and get status and parameters of instance"""
log = logging.getLogger('request')
def get_parser(self, prog_name): def get_parser(self, prog_name):
ap = super(RequestCommand, self).get_parser(prog_name) ap = super(RequestCommand, self).get_parser(prog_name)
......
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
import logging
from slapos.cli.command import must_be_root from slapos.cli.command import must_be_root
from slapos.cli.config import ConfigCommand from slapos.cli.config import ConfigCommand
...@@ -12,8 +10,6 @@ from slapos.grid.slapgrid import (merged_options, check_missing_parameters, chec ...@@ -12,8 +10,6 @@ from slapos.grid.slapgrid import (merged_options, check_missing_parameters, chec
class SlapgridCommand(ConfigCommand): class SlapgridCommand(ConfigCommand):
log = None
method_name = NotImplemented method_name = NotImplemented
default_pidfile = NotImplemented default_pidfile = NotImplemented
...@@ -73,14 +69,14 @@ class SlapgridCommand(ConfigCommand): ...@@ -73,14 +69,14 @@ class SlapgridCommand(ConfigCommand):
check_missing_parameters(options) check_missing_parameters(options)
check_missing_files(options) check_missing_files(options)
random_delay(options, logger=self.log) random_delay(options, logger=self.app.log)
slapgrid_object = create_slapgrid_object(options, logger=self.log) slapgrid_object = create_slapgrid_object(options, logger=self.app.log)
pidfile = options.get('pidfile') or self.default_pidfile pidfile = options.get('pidfile') or self.default_pidfile
if pidfile: if pidfile:
setRunning(logger=self.log, pidfile=pidfile) setRunning(logger=self.app.log, pidfile=pidfile)
try: try:
return getattr(slapgrid_object, self.method_name)() return getattr(slapgrid_object, self.method_name)()
finally: finally:
...@@ -91,8 +87,6 @@ class SlapgridCommand(ConfigCommand): ...@@ -91,8 +87,6 @@ class SlapgridCommand(ConfigCommand):
class SoftwareCommand(SlapgridCommand): class SoftwareCommand(SlapgridCommand):
"""run software installation/deletion""" """run software installation/deletion"""
log = logging.getLogger('software')
method_name = 'processSoftwareReleaseList' method_name = 'processSoftwareReleaseList'
default_pidfile = '/opt/slapos/slapgrid-sr.pid' default_pidfile = '/opt/slapos/slapgrid-sr.pid'
...@@ -112,8 +106,6 @@ class SoftwareCommand(SlapgridCommand): ...@@ -112,8 +106,6 @@ class SoftwareCommand(SlapgridCommand):
class InstanceCommand(SlapgridCommand): class InstanceCommand(SlapgridCommand):
"""run instance deployment""" """run instance deployment"""
log = logging.getLogger('instance')
method_name = 'processComputerPartitionList' method_name = 'processComputerPartitionList'
default_pidfile = '/opt/slapos/slapgrid-cp.pid' default_pidfile = '/opt/slapos/slapgrid-cp.pid'
...@@ -133,7 +125,5 @@ class InstanceCommand(SlapgridCommand): ...@@ -133,7 +125,5 @@ class InstanceCommand(SlapgridCommand):
class ReportCommand(SlapgridCommand): class ReportCommand(SlapgridCommand):
"""run instance reports and garbage collection""" """run instance reports and garbage collection"""
log = logging.getLogger('report')
method_name = 'agregateAndSendUsage' method_name = 'agregateAndSendUsage'
default_pidfile = '/opt/slapos/slapgrid-ur.pid' default_pidfile = '/opt/slapos/slapgrid-ur.pid'
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
import argparse import argparse
import logging
import os import os
from slapos.cli.command import must_be_root from slapos.cli.command import must_be_root
...@@ -14,8 +13,6 @@ import supervisor.supervisorctl ...@@ -14,8 +13,6 @@ import supervisor.supervisorctl
class SupervisorctlCommand(ConfigCommand): class SupervisorctlCommand(ConfigCommand):
"""open supervisor console, for process management""" """open supervisor console, for process management"""
log = logging.getLogger('supervisorctl')
def get_parser(self, prog_name): def get_parser(self, prog_name):
ap = super(SupervisorctlCommand, self).get_parser(prog_name) ap = super(SupervisorctlCommand, self).get_parser(prog_name)
ap.add_argument('supervisor_args', ap.add_argument('supervisor_args',
...@@ -30,7 +27,7 @@ class SupervisorctlCommand(ConfigCommand): ...@@ -30,7 +27,7 @@ class SupervisorctlCommand(ConfigCommand):
configuration_file = os.path.join(instance_root, 'etc', 'supervisord.conf') configuration_file = os.path.join(instance_root, 'etc', 'supervisord.conf')
launchSupervisord(socket=os.path.join(instance_root, 'supervisord.socket'), launchSupervisord(socket=os.path.join(instance_root, 'supervisord.socket'),
configuration_file=configuration_file, configuration_file=configuration_file,
logger=self.log) logger=self.app.log)
supervisor.supervisorctl.main(args=['-c', configuration_file] + args.supervisor_args) supervisor.supervisorctl.main(args=['-c', configuration_file] + args.supervisor_args)
......
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
import logging
import os import os
from slapos.cli.command import must_be_root from slapos.cli.command import must_be_root
...@@ -11,12 +10,10 @@ from slapos.grid.svcbackend import launchSupervisord ...@@ -11,12 +10,10 @@ from slapos.grid.svcbackend import launchSupervisord
class SupervisordCommand(ConfigCommand): class SupervisordCommand(ConfigCommand):
"""launch, if not already running, supervisor daemon""" """launch, if not already running, supervisor daemon"""
log = logging.getLogger('supervisord')
@must_be_root @must_be_root
def take_action(self, args): def take_action(self, args):
configp = self.fetch_config(args) configp = self.fetch_config(args)
instance_root = configp.get('slapos', 'instance_root') instance_root = configp.get('slapos', 'instance_root')
launchSupervisord(socket=os.path.join(instance_root, 'supervisord.socket'), launchSupervisord(socket=os.path.join(instance_root, 'supervisord.socket'),
configuration_file=os.path.join(instance_root, 'etc', 'supervisord.conf'), configuration_file=os.path.join(instance_root, 'etc', 'supervisord.conf'),
logger=self.log) logger=self.app.log)
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
import logging
from slapos.cli.config import ClientConfigCommand from slapos.cli.config import ClientConfigCommand
from slapos.client import init, ClientConfig from slapos.client import init, ClientConfig
...@@ -11,8 +9,6 @@ class SupplyCommand(ClientConfigCommand): ...@@ -11,8 +9,6 @@ class SupplyCommand(ClientConfigCommand):
supply a Software to a node supply a Software to a node
""" """
log = logging.getLogger('supply')
def get_parser(self, prog_name): def get_parser(self, prog_name):
ap = super(SupplyCommand, self).get_parser(prog_name) ap = super(SupplyCommand, self).get_parser(prog_name)
......
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