2026-02-25 20:49:56 +08:00
|
|
|
|
# coding: utf-8
|
|
|
|
|
|
"""
|
|
|
|
|
|
QMT (Quantitative Trading) Module
|
|
|
|
|
|
|
2026-02-25 21:48:10 +08:00
|
|
|
|
提供量化交易相关的功能:
|
|
|
|
|
|
- Redis Stream 消息处理
|
|
|
|
|
|
- 交易信号发送
|
|
|
|
|
|
- 回测消息消费
|
|
|
|
|
|
- 细粒度日志记录
|
|
|
|
|
|
- 强类型配置校验
|
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
|
|
from .message_processor import StreamMessageProcessor, send_qmt_signal_to_stream
|
|
|
|
|
|
from .logger import QMTLogger, get_qmt_logger
|
|
|
|
|
|
from .config_models import (
|
|
|
|
|
|
QMTConfig,
|
|
|
|
|
|
QMTTerminalConfig,
|
|
|
|
|
|
StrategyConfig,
|
|
|
|
|
|
RedisConfig,
|
|
|
|
|
|
AutoReconnectConfig,
|
|
|
|
|
|
load_config,
|
|
|
|
|
|
ConfigError,
|
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
__all__ = [
|
|
|
|
|
|
"StreamMessageProcessor",
|
|
|
|
|
|
"send_qmt_signal_to_stream",
|
|
|
|
|
|
"QMTLogger",
|
|
|
|
|
|
"get_qmt_logger",
|
|
|
|
|
|
"QMTConfig",
|
|
|
|
|
|
"QMTTerminalConfig",
|
|
|
|
|
|
"StrategyConfig",
|
|
|
|
|
|
"RedisConfig",
|
|
|
|
|
|
"AutoReconnectConfig",
|
|
|
|
|
|
"load_config",
|
|
|
|
|
|
"ConfigError",
|
|
|
|
|
|
]
|
|
|
|
|
|
"""
|
|
|
|
|
|
QMT (Quantitative Trading) Module
|
|
|
|
|
|
|
2026-02-25 20:49:56 +08:00
|
|
|
|
提供量化交易相关的功能:
|
|
|
|
|
|
- Redis Stream 消息处理
|
|
|
|
|
|
- 交易信号发送
|
|
|
|
|
|
- 回测消息消费
|
|
|
|
|
|
- 细粒度日志记录
|
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
|
|
from .message_processor import StreamMessageProcessor, send_qmt_signal_to_stream
|
|
|
|
|
|
from .logger import QMTLogger, get_qmt_logger
|
|
|
|
|
|
|
|
|
|
|
|
__all__ = [
|
|
|
|
|
|
"StreamMessageProcessor",
|
|
|
|
|
|
"send_qmt_signal_to_stream",
|
|
|
|
|
|
"QMTLogger",
|
|
|
|
|
|
"get_qmt_logger",
|
|
|
|
|
|
]
|