jyapayne/langflow
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

loguru support standout logging with json and csv (#2415)

Browse source 
support standout logging with json and csv

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
This commit is contained in:
ming 2024-07-01 12:36:30 -04:00 • committed by GitHub
commit 46f9f8c852
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 51 additions and 37 deletions
Download patch file Download diff file Expand all files Collapse all files

88
src/backend/base/langflow/utils/logger.py
View file

@ -1,5 +1,6 @@
import logging import logging
import os import os
import sys
from pathlib import Path from pathlib import Path
from typing import Optional from typing import Optional
@ -11,7 +12,7 @@ from rich.logging import RichHandler
VALID_LOG_LEVELS = ["DEBUG", "INFO", "WARNING", "ERROR", "CRITICAL"] VALID_LOG_LEVELS = ["DEBUG", "INFO", "WARNING", "ERROR", "CRITICAL"]
def serialize(record): def serialize_log(record):
subset = { subset = {
"timestamp": record["time"].timestamp(), "timestamp": record["time"].timestamp(),
"message": record["message"], "message": record["message"],
@ -22,54 +23,67 @@ def serialize(record):
def patching(record): def patching(record):
record["extra"]["serialized"] = serialize(record) record["extra"]["serialized"] = serialize_log(record)
def configure(log_level: Optional[str] = None, log_file: Optional[Path] = None, disable: Optional[bool] = False): def configure(
log_level: Optional[str] = None,
log_file: Optional[Path] = None,
disable: Optional[bool] = False,
log_env: Optional[str] = None,
):
if disable and log_level is None and log_file is None: if disable and log_level is None and log_file is None:
logger.disable("langflow") logger.disable("langflow")
if os.getenv("LANGFLOW_LOG_LEVEL", "").upper() in VALID_LOG_LEVELS and log_level is None: if os.getenv("LANGFLOW_LOG_LEVEL", "").upper() in VALID_LOG_LEVELS and log_level is None:
log_level = os.getenv("LANGFLOW_LOG_LEVEL") log_level = os.getenv("LANGFLOW_LOG_LEVEL")
if log_level is None: if log_level is None:
log_level = "ERROR" log_level = "ERROR"
# Human-readable
log_format = (
"<green>{time:YYYY-MM-DD HH:mm:ss}</green> - <level>"
"{level: <8}</level> - {module} - <level>{message}</level>"
)
# log_format = log_format_dev if log_level.upper() == "DEBUG" else log_format_prod if log_env is None:
log_env = os.getenv("LANGFLOW_LOG_ENV", "")
logger.remove() # Remove default handlers logger.remove() # Remove default handlers
logger.patch(patching) logger.patch(patching)
# Configure loguru to use RichHandler if log_env.lower() == "container" or log_env.lower() == "container_json":
logger.configure( logger.add(sys.stdout, format="{message}", serialize=True)
handlers=[ elif log_env.lower() == "container_csv":
{ logger.add(sys.stdout, format="{time:YYYY-MM-DD HH:mm:ss.SSS} {level} {file} {line} {function} {message}")
"sink": RichHandler(rich_tracebacks=True, markup=True), else:
"format": log_format, # Human-readable
"level": log_level.upper(), log_format = (
} "<green>{time:YYYY-MM-DD HH:mm:ss}</green> - <level>"
] "{level: <8}</level> - {module} - <level>{message}</level>"
)
if not log_file:
cache_dir = Path(user_cache_dir("langflow"))
logger.debug(f"Cache directory: {cache_dir}")
log_file = cache_dir / "langflow.log"
logger.debug(f"Log file: {log_file}")
try:
log_file = Path(log_file)
log_file.parent.mkdir(parents=True, exist_ok=True)
logger.add(
sink=str(log_file),
level=log_level.upper(),
format=log_format,
rotation="10 MB", # Log rotation based on file size
serialize=True,
) )
except Exception as exc:
logger.error(f"Error setting up log file: {exc}") # Configure loguru to use RichHandler
logger.configure(
handlers=[
{
"sink": RichHandler(rich_tracebacks=True, markup=True),
"format": log_format,
"level": log_level.upper(),
}
]
)
if not log_file:
cache_dir = Path(user_cache_dir("langflow"))
logger.debug(f"Cache directory: {cache_dir}")
log_file = cache_dir / "langflow.log"
logger.debug(f"Log file: {log_file}")
try:
log_file = Path(log_file)
log_file.parent.mkdir(parents=True, exist_ok=True)
logger.add(
sink=str(log_file),
level=log_level.upper(),
format=log_format,
rotation="10 MB", # Log rotation based on file size
serialize=True,
)
except Exception as exc:
logger.error(f"Error setting up log file: {exc}")
logger.debug(f"Logger set up with log level: {log_level}") logger.debug(f"Logger set up with log level: {log_level}")