Migrate and merge logging_utils from swarming_bot into client/utils.

client/utils/logging_utils.py

-# Copyright 2014 The Swarming Authors. All rights reserved.
-# Use of this source code is governed by the Apache v2.0 license that can be
-# found in the LICENSE file.
+# Copyright 2015 The Swarming Authors. All rights reserved.
+# Use of this source code is governed under the Apache License, Version 2.0 that
+# can be found in the LICENSE file.
 
-"""Utility relating to logging.
+"""Utility relating to logging."""
 
-TODO(maruel): Merge buffering and output related code from client/utils/tools.py
-in a single file.
-"""
-
+import argparse
 import codecs
 import logging
 import logging.handlers
+import optparse
 import os
 import sys
 import tempfile
 import time
 
 
 # This works around file locking issue on Windows specifically in the case of
 # long lived child processes.
 #
 # Python opens files with inheritable handle and without file sharing by
@@ skipping 27 matching lines @@
           return os.fdopen(new_fd, self.mode)
       return codecs.open(self.baseFilename, self.mode, self.encoding)
 
 
 else:  # Not Windows.
 
 
   NoInheritRotatingFileHandler = logging.handlers.RotatingFileHandler
 
 
+# Levels used for logging.
+LEVELS = [logging.ERROR, logging.INFO, logging.DEBUG]
+
+
 class CaptureLogs(object):
   """Captures all the logs in a context."""
   def __init__(self, prefix, root=None):
     handle, self._path = tempfile.mkstemp(prefix=prefix, suffix='.log')
     os.close(handle)
     self._handler = logging.FileHandler(self._path, 'w')
     self._handler.setLevel(logging.DEBUG)
     formatter = UTCFormatter(
         '%(process)d %(asctime)s: %(levelname)-5s %(message)s')
     self._handler.setFormatter(formatter)
@@ skipping 56 matching lines @@
     if getattr(log, 'stream', None) is sys.stderr:
       return log
 
 
 def prepare_logging(filename, root=None):
   """Prepare logging for scripts.
 
   Makes it log in UTC all the time. Prepare a rotating file based log.
   """
   assert not find_stderr(root)
+  # Other options are:
+  #   '%(levelname)5s %(relativeCreated)6d %(module)15s(%(lineno)3d): '
+  #   '%(message)s'
+  # or:
+  #   '%(asctime)s %(levelname)-8s %(module)15s(%(lineno)3d): %(message)s'))
   formatter = UTCFormatter(
       '%(process)d %(asctime)s: %(levelname)-5s %(message)s')

[Vadim Sh., 2015/07/15 18:46:38]

consider also
https://chromium.googlesource.com/infra/infra/+/master/infra_libs/logs/logs.p...
for consistency with infra.git code.

 
   # It is a requirement that the root logger is set to DEBUG, so the messages
   # are not lost. It defaults to WARNING otherwise.
   logger = root or logging.getLogger()
   logger.setLevel(logging.DEBUG)
 
   stderr = logging.StreamHandler()
   stderr.setFormatter(formatter)
   # Default to ERROR.
   stderr.setLevel(logging.ERROR)
   logger.addHandler(stderr)
 
   # Setup up logging to a constant file so we can debug issues where
   # the results aren't properly sent to the result URL.
   if filename:
     try:
       rotating_file = NoInheritRotatingFileHandler(
-          filename, maxBytes=10 * 1024 * 1024, backupCount=5)
+          filename, maxBytes=10 * 1024 * 1024, backupCount=5,
+          encoding='utf-8')
       rotating_file.setLevel(logging.DEBUG)
       rotating_file.setFormatter(formatter)
       logger.addHandler(rotating_file)
     except Exception:
       # May happen on cygwin. Do not crash.
       logging.exception('Failed to open %s', filename)
 
 
 def set_console_level(level, root=None):
   """Reset the console (stderr) logging level."""
   handler = find_stderr(root)
   handler.setLevel(level)
+
+
+class OptionParserWithLogging(optparse.OptionParser):
+  """Adds --verbose option."""
+
+  # Set to True to enable --log-file options.
+  enable_log_file = True
+
+  # Set in unit tests.
+  logger_root = None
+
+  def __init__(self, verbose=0, log_file=None, **kwargs):
+    kwargs.setdefault('description', sys.modules['__main__'].__doc__)
+    optparse.OptionParser.__init__(self, **kwargs)
+    self.group_logging = optparse.OptionGroup(self, 'Logging')
+    self.group_logging.add_option(
+        '-v', '--verbose',
+        action='count',
+        default=verbose,
+        help='Use multiple times to increase verbosity')
+    if self.enable_log_file:
+      self.group_logging.add_option(
+          '-l', '--log-file',
+          default=log_file,
+          help='The name of the file to store rotating log details')
+      self.group_logging.add_option(
+          '--no-log', action='store_const', const='', dest='log_file',
+          help='Disable log file')
+
+  def parse_args(self, *args, **kwargs):
+    # Make sure this group is always the last one.
+    self.add_option_group(self.group_logging)
+
+    options, args = optparse.OptionParser.parse_args(self, *args, **kwargs)
+    prepare_logging(self.enable_log_file and options.log_file, self.logger_root)
+    set_console_level(
+        LEVELS[min(len(LEVELS) - 1, options.verbose)], self.logger_root)
+    return options, args
+
+
+class ArgumentParserWithLogging(argparse.ArgumentParser):
+  """Adds --verbose option."""
+
+  # Set to True to enable --log-file options.
+  enable_log_file = True
+
+  def __init__(self, verbose=0, log_file=None, **kwargs):
+    kwargs.setdefault('description', sys.modules['__main__'].__doc__)
+    kwargs.setdefault('conflict_handler', 'resolve')
+    self.__verbose = verbose
+    self.__log_file = log_file
+    super(ArgumentParserWithLogging, self).__init__(**kwargs)
+
+  def _add_logging_group(self):
+    group = self.add_argument_group('Logging')
+    group.add_argument(
+        '-v', '--verbose',
+        action='count',
+        default=self.__verbose,
+        help='Use multiple times to increase verbosity')
+    if self.enable_log_file:
+      group.add_argument(
+          '-l', '--log-file',
+          default=self.__log_file,
+          help='The name of the file to store rotating log details')
+      group.add_argument(
+          '--no-log', action='store_const', const='', dest='log_file',
+          help='Disable log file')
+
+  def parse_args(self, *args, **kwargs):
+    # Make sure this group is always the last one.
+    self._add_logging_group()
+
+    args = super(ArgumentParserWithLogging, self).parse_args(*args, **kwargs)
+    prepare_logging(self.enable_log_file and args.log_file, self.logger_root)
+    set_console_level(
+        LEVELS[min(len(LEVELS) - 1, args.verbose)], self.logger_root)
+    return args