fix sql echo logging levels

Author: davidgamez

api/src/feeds/impl/feeds_api_impl.py

@@ -137,7 +137,6 @@ def _get_gtfs_feed(
         query = get_gtfs_feeds_query(
             db_session=db_session, stable_id=stable_id, include_options_for_joinedload=include_options_for_joinedload
         )
-        self.logger.debug("Query: %s", str(query.statement.compile(compile_kwargs={"literal_binds": True})))
         results = query.all()
         if len(results) == 0:
             return None

api/src/shared/database/database.py

@@ -11,6 +11,8 @@
 from sqlalchemy.orm import sessionmaker
 import logging
 
+from utils.logger import get_env_logging_level
+
 
 def generate_unique_id() -> str:
     """
@@ -99,14 +101,15 @@ def with_db_session(func=None, db_url: str | None = None):
           exception occurs, and closed in either case.
         - The session is then passed to the decorated function as the 'db_session' keyword argument.
         - If 'db_session' is already provided, it simply calls the decorated function with the existing session.
+        - The echoed SQL queries will be logged if the environment variable LOGGING_LEVEL is set to DEBUG.
     """
     if func is None:
         return lambda f: with_db_session(f, db_url=db_url)
 
     def wrapper(*args, **kwargs):
         db_session = kwargs.get("db_session")
         if db_session is None:
-            db = Database(feeds_database_url=db_url)
+            db = Database(echo_sql=get_env_logging_level() == 'DEBUG', feeds_database_url=db_url)
             with db.start_db_session() as session:
                 kwargs["db_session"] = session
                 return func(*args, **kwargs)

api/src/utils/logger.py

@@ -1,6 +1,7 @@
 import asyncio
 import json
 import logging
+import os
 from dataclasses import dataclass
 from typing import Final, Optional
 
@@ -127,6 +128,12 @@ async def async_emit(self, record):
         self.logger.info(json.dumps(log_record.__dict__))
 
 
+def get_env_logging_level():
+    """
+    Get the logging level from the environment via OS variable LOGGING_LEVEL. Returns INFO if not set.
+    """
+    return os.getenv("LOGGING_LEVEL", "INFO")
+
 class Logger:
     """
     Util class for logging information, errors or warnings
@@ -143,7 +150,7 @@ def __init__(self, name):
 
         self.logger = logging.getLogger(name)
         self.logger.addHandler(console_handler)
-        self.logger.setLevel(logging.DEBUG)
+        self.logger.setLevel(get_env_logging_level())
 
     def get_logger(self):
         """