Rekey
039bfb5075
- engine/__init__.py: 包入口，导出 Kline/KlineInterval/OrderBook/Ticker/Trade - common/base.py: BaseStrategy 抽象基类，定义 on_kline/on_ticker/on_orderbook 回调 - common/models.py: Pydantic 数据模型，与 TS 侧 types 字段对齐，支持字段校验 - common/config.py: 全局配置加载（YAML），统一 engine/env.yaml 读取 - common/logger.py: 结构化日志，支持 JSON/pretty print 输出
31 lines
726 B
Python
31 lines
726 B
Python
"""
|
|
日志模块 — 系统级结构化日志
|
|
|
|
基于标准库 logging + 结构化格式，支持按级别、模块过滤。
|
|
"""
|
|
|
|
import logging
|
|
import sys
|
|
|
|
# ── 日志器 ──
|
|
|
|
logger = logging.getLogger("trade")
|
|
"""全局日志器，策略代码通过 `from .logger import logger` 使用"""
|
|
|
|
# ── 控制台输出 ──
|
|
|
|
_handler = logging.StreamHandler(sys.stdout)
|
|
_handler.setLevel(logging.DEBUG)
|
|
|
|
_formatter = logging.Formatter(
|
|
fmt="%(asctime)s | %(levelname)-7s | %(name)s | %(message)s",
|
|
datefmt="%Y-%m-%d %H:%M:%S",
|
|
)
|
|
_handler.setFormatter(_formatter)
|
|
|
|
logger.addHandler(_handler)
|
|
logger.setLevel(logging.DEBUG)
|
|
|
|
# 避免日志向上传播到 root logger 导致重复输出
|
|
logger.propagate = False
|