Use centralized logging setup

Author: haiqi96

components/clp-package-utils/clp_package_utils/__init__.py

@@ -0,0 +1,12 @@
+import logging
+
+# Set up console logging
+logging_console_handler = logging.StreamHandler()
+logging_formatter = logging.Formatter(
+    "%(asctime)s.%(msecs)03d %(levelname)s [%(module)s] %(message)s", datefmt="%Y-%m-%dT%H:%M:%S"
+)
+logging_console_handler.setFormatter(logging_formatter)
+# Set up root logger
+root_logger = logging.getLogger()
+root_logger.setLevel(logging.INFO)
+root_logger.addHandler(logging_console_handler)

components/clp-package-utils/clp_package_utils/scripts/compress.py

@@ -18,15 +18,8 @@
     validate_and_load_db_credentials_file,
 )
 
-# Setup logging
 # Create logger
 logger = logging.getLogger(__file__)
-logger.setLevel(logging.INFO)
-# Setup console logging
-logging_console_handler = logging.StreamHandler()
-logging_formatter = logging.Formatter("%(asctime)s [%(levelname)s] [%(name)s] %(message)s")
-logging_console_handler.setFormatter(logging_formatter)
-logger.addHandler(logging_console_handler)
 
 
 def main(argv):

components/clp-package-utils/clp_package_utils/scripts/decompress.py

@@ -24,15 +24,8 @@
     validate_path_could_be_dir,
 )
 
-# Setup logging
 # Create logger
-logger = logging.getLogger("clp")
-logger.setLevel(logging.DEBUG)
-# Setup console logging
-logging_console_handler = logging.StreamHandler()
-logging_formatter = logging.Formatter("%(asctime)s [%(levelname)s] [%(name)s] %(message)s")
-logging_console_handler.setFormatter(logging_formatter)
-logger.addHandler(logging_console_handler)
+logger = logging.getLogger(__file__)
 
 
 def validate_and_load_config(

components/clp-package-utils/clp_package_utils/scripts/del_archives.py

@@ -16,15 +16,8 @@
     validate_and_load_db_credentials_file,
 )
 
-# Setup logging
 # Create logger
 logger = logging.getLogger(__file__)
-logger.setLevel(logging.INFO)
-# Setup console logging
-logging_console_handler = logging.StreamHandler()
-logging_formatter = logging.Formatter("%(asctime)s [%(levelname)s] [%(name)s] %(message)s")
-logging_console_handler.setFormatter(logging_formatter)
-logger.addHandler(logging_console_handler)
 
 
 def main(argv):

components/clp-package-utils/clp_package_utils/scripts/native/compress.py

@@ -23,15 +23,8 @@
     load_config_file,
 )
 
-# Setup logging
 # Create logger
 logger = logging.getLogger(__file__)
-logger.setLevel(logging.INFO)
-# Setup console logging
-logging_console_handler = logging.StreamHandler()
-logging_formatter = logging.Formatter("%(asctime)s [%(levelname)s] [%(name)s] %(message)s")
-logging_console_handler.setFormatter(logging_formatter)
-logger.addHandler(logging_console_handler)
 
 
 def print_compression_job_status(job_row, current_time):

components/clp-package-utils/clp_package_utils/scripts/native/decompress.py

@@ -27,15 +27,8 @@
     wait_for_query_job,
 )
 
-# Setup logging
 # Create logger
 logger = logging.getLogger(__file__)
-logger.setLevel(logging.INFO)
-# Setup console logging
-logging_console_handler = logging.StreamHandler()
-logging_formatter = logging.Formatter("%(asctime)s [%(levelname)s] [%(name)s] %(message)s")
-logging_console_handler.setFormatter(logging_formatter)
-logger.addHandler(logging_console_handler)
 
 
 def get_orig_file_id(db_config: Database, path: str) -> Optional[str]:

components/clp-package-utils/clp_package_utils/scripts/native/del_archives.py

@@ -15,15 +15,8 @@
     load_config_file,
 )
 
-# Setup logging
 # Create logger
 logger = logging.getLogger(__file__)
-logger.setLevel(logging.INFO)
-# Setup console logging
-logging_console_handler = logging.StreamHandler()
-logging_formatter = logging.Formatter("%(asctime)s [%(levelname)s] [%(name)s] %(message)s")
-logging_console_handler.setFormatter(logging_formatter)
-logger.addHandler(logging_console_handler)
 
 
 def main(argv):

components/clp-package-utils/clp_package_utils/scripts/native/search.py

@@ -26,15 +26,8 @@
     wait_for_query_job,
 )
 
-# Setup logging
 # Create logger
 logger = logging.getLogger(__file__)
-logger.setLevel(logging.INFO)
-# Setup console logging
-logging_console_handler = logging.StreamHandler()
-logging_formatter = logging.Formatter("%(asctime)s [%(levelname)s] [%(name)s] %(message)s")
-logging_console_handler.setFormatter(logging_formatter)
-logger.addHandler(logging_console_handler)
 
 
 def create_and_monitor_job_in_db(

components/clp-package-utils/clp_package_utils/scripts/search.py

@@ -20,15 +20,8 @@
     validate_and_load_db_credentials_file,
 )
 
-# Setup logging
 # Create logger
 logger = logging.getLogger(__file__)
-logger.setLevel(logging.INFO)
-# Setup console logging
-logging_console_handler = logging.StreamHandler()
-logging_formatter = logging.Formatter("%(asctime)s [%(levelname)s] [%(name)s] %(message)s")
-logging_console_handler.setFormatter(logging_formatter)
-logger.addHandler(logging_console_handler)
 
 
 def main(argv):

components/clp-package-utils/clp_package_utils/scripts/start_clp.py

@@ -59,15 +59,8 @@
     validate_worker_config,
 )
 
-# Setup logging
 # Create logger
-logger = logging.getLogger("clp")
-logger.setLevel(logging.INFO)
-# Setup console logging
-logging_console_handler = logging.StreamHandler()
-logging_formatter = logging.Formatter("%(asctime)s [%(levelname)s] [%(name)s] %(message)s")
-logging_console_handler.setFormatter(logging_formatter)
-logger.addHandler(logging_console_handler)
+logger = logging.getLogger(__file__)
 
 
 def container_exists(container_name):