345cc73965
P0-1 SqlCredentialStore/save_draft 由自提交改 flush，端点/服务统一 commit （新增 CredentialStore.commit() 统一提交点；token 刷新落库显式提交）； 补多凭据一请求中途失败整体回滚集成测试。 P0-2 启动校验 _fernet(enc_key) 快速失败 + catch-all Exception → ErrorEnvelope； credential_enc_key 改 SecretStr。 P0-3 run_job 异常分类：AppError 存 code+message，其余存通用文案不泄 str(exc)。 P0-4 评审/正文 SSE 失败先发 error 事件，尾部 commit 包 try/except。 P1-4 max_version 加 FOR UPDATE 行锁消除 TOCTOU。 P1-5 scan_overdue 谓词下推 + 批量 UPDATE RETURNING。 P1-10 移除 OAuth user_code 日志。 P2 provider_deps 改调网关 build_adapter；accept_service Committable Protocol； CORS 白名单收窄；request_id 安全字符集白名单；stdlib 日志接管；读端点 404 校验； httpx timeout；测试用合法 Fernet key；类型化响应模型(JobResponse/DimensionEntry/ ReviewConflictView/selling_points)+路由 ErrorEnvelope responses（供 codegen）。
53 lines
1.7 KiB
Python
53 lines
1.7 KiB
Python
"""structlog 结构化日志（ARCH §9.3）。dev 走彩色 console，其余 JSON。"""
|
||
|
||
from __future__ import annotations
|
||
|
||
import logging
|
||
|
||
import structlog
|
||
from structlog.typing import Processor
|
||
from ww_config import get_settings
|
||
|
||
|
||
def configure_logging() -> None:
|
||
settings = get_settings()
|
||
shared: list[Processor] = [
|
||
structlog.contextvars.merge_contextvars,
|
||
structlog.processors.add_log_level,
|
||
structlog.processors.TimeStamper(fmt="iso"),
|
||
]
|
||
renderer: Processor = (
|
||
structlog.processors.JSONRenderer()
|
||
if settings.log_json
|
||
else structlog.dev.ConsoleRenderer()
|
||
)
|
||
structlog.configure(
|
||
processors=[
|
||
*shared,
|
||
# 交给 stdlib：ProcessorFormatter 在 root handler 上做最终渲染，统一结构化输出。
|
||
structlog.stdlib.ProcessorFormatter.wrap_for_formatter,
|
||
],
|
||
logger_factory=structlog.stdlib.LoggerFactory(),
|
||
wrapper_class=structlog.make_filtering_bound_logger(logging.INFO),
|
||
cache_logger_on_first_use=True,
|
||
)
|
||
# 接管 stdlib root：SQLAlchemy/httpx/uvicorn 等绕过 structlog 的日志也走同一 formatter
|
||
# → 统一 JSON/console 输出（P2：日志接管 stdlib root）。
|
||
formatter = structlog.stdlib.ProcessorFormatter(
|
||
foreign_pre_chain=shared,
|
||
processors=[
|
||
structlog.stdlib.ProcessorFormatter.remove_processors_meta,
|
||
renderer,
|
||
],
|
||
)
|
||
handler = logging.StreamHandler()
|
||
handler.setFormatter(formatter)
|
||
root = logging.getLogger()
|
||
root.handlers = [handler]
|
||
root.setLevel(logging.INFO)
|
||
|
||
|
||
def get_logger(name: str = "ww") -> structlog.stdlib.BoundLogger:
|
||
logger: structlog.stdlib.BoundLogger = structlog.get_logger(name)
|
||
return logger
|