模組 14：配置系統深潛掌握 NautilusTrader 的每一個配置參數，建立可重現、可調優的交易系統

一、為什麼配置系統如此重要？

二、配置層級架構

NautilusTrader 的配置是樹狀結構，最頂層的配置包含所有子系統的配置：

flowchart TD
                        root["🔧 TradingNodeConfig / BacktestEngineConfig"]
                        kernel["NautilusKernelConfig"]
                        cache["CacheConfig"]
                        msgbus["MessageBusConfig"]
                        data["DataEngineConfig"]
                        exec["ExecEngineConfig"]
                        risk["RiskEngineConfig"]
                        log["LoggingConfig"]
                        port["PortfolioConfig"]
                        emu["OrderEmulatorConfig"]
                        stream["StreamingConfig"]
                        ctrl["ControllerConfig"]

                        root --> kernel
                        kernel --> cache
                        kernel --> msgbus
                        kernel --> data
                        kernel --> exec
                        kernel --> risk
                        kernel --> log
                        kernel --> port
                        kernel --> emu
                        kernel --> stream
                        kernel --> ctrl

                        style root fill:#0f1419,stroke:#4fc3f7,stroke-width:2px
                        style kernel fill:#0f1419,stroke:#ab47bc,stroke-width:2px

三、NautilusKernelConfig — 核心配置

這是整個系統的核心配置，所有 TradingNodeConfig 和 BacktestEngineConfig 都繼承自它。

超時參數（實盤必調）

四、子系統配置詳解

4.1 CacheConfig — 緩存配置

from nautilus_trader.cache.config import CacheConfig

cache_config = CacheConfig(
    database=DatabaseConfig(
        type="redis",
        host="localhost",
        port=6379,
    ),
    timestamps_as_iso8601=True,   # 時間戳格式
    buffer_interval_ms=100,       # 批量寫入間隔
)

4.2 MessageBusConfig — 消息總線配置

from nautilus_trader.common.config import MessageBusConfig

msgbus_config = MessageBusConfig(
    database=DatabaseConfig(
        type="redis",
        host="localhost",
        port=6379,
    ),
    stream_per_topic=True,        # 每個主題一個 Redis Stream
    autotrim_size=10000,          # 每個 Stream 最多保留 10000 條消息
    types_filter=[                # 只持久化特定事件類型
        "OrderFilled",
        "PositionChanged",
    ],
)

4.3 LoggingConfig — 日誌配置

from nautilus_trader.common.config import LoggingConfig

logging_config = LoggingConfig(
    log_level="INFO",              # 控制台日誌級別
    log_level_file="DEBUG",        # 文件日誌級別（更詳細）
    log_directory="./logs",        # 日誌文件目錄
    log_file_name="nautilus",      # 日誌文件名
    log_file_format=None,          # 日誌格式（None=預設）
    log_colors=True,               # 控制台彩色輸出
    log_component_levels={
        # 為特定組件設定不同日誌級別
        "RiskEngine": "WARNING",   # 風控引擎只記錄警告以上
        "DataEngine": "INFO",      # 數據引擎記錄所有信息
    },
    bypass_logging=False,          # 完全跳過日誌（極致性能模式）
)

4.4 LiveDataEngineConfig / LiveExecEngineConfig

from nautilus_trader.live.config import (
    LiveDataEngineConfig,
    LiveExecEngineConfig,
    LiveRiskEngineConfig,
)

data_engine = LiveDataEngineConfig(
    qos=True,                     # 數據品質保證（檢查重複、順序）
)

exec_engine = LiveExecEngineConfig(
    reconciliation=True,          # 啟用訂單對帳（強烈建議開啟）
    inflight_check_interval_ms=2000,  # 檢查「飛行中」訂單的間隔
    inflight_check_threshold_ms=5000, # 訂單超過此時間未確認則告警
)

risk_engine = LiveRiskEngineConfig(
    bypass=False,                 # 是否跳過風控（生產環境請勿設 True！）
    max_order_submit_rate="100/00:00:01",     # 每秒最多提交 100 單
    max_order_modify_rate="100/00:00:01",     # 每秒最多修改 100 單
)

五、完整的實盤配置範例

"""完整的 TradingNode 配置 — 生產級別"""
from nautilus_trader.live.node import TradingNode
from nautilus_trader.live.config import (
    TradingNodeConfig,
    LiveDataEngineConfig,
    LiveExecEngineConfig,
    LiveRiskEngineConfig,
)
from nautilus_trader.cache.config import CacheConfig
from nautilus_trader.common.config import (
    DatabaseConfig,
    LoggingConfig,
    MessageBusConfig,
)
from nautilus_trader.adapters.binance.config import (
    BinanceLiveDataClientConfig,
    BinanceLiveExecClientConfig,
)

config = TradingNodeConfig(
    trader_id="LIVE-001",

    # === 緩存 ===
    cache=CacheConfig(
        database=DatabaseConfig(type="redis", host="localhost", port=6379),
    ),

    # === 消息總線 ===
    message_bus=MessageBusConfig(
        database=DatabaseConfig(type="redis", host="localhost", port=6379),
        types_filter=["OrderFilled", "PositionChanged"],
    ),

    # === 日誌 ===
    logging=LoggingConfig(
        log_level="INFO",
        log_level_file="DEBUG",
        log_directory="./logs",
    ),

    # === 引擎配置 ===
    data_engine=LiveDataEngineConfig(qos=True),
    exec_engine=LiveExecEngineConfig(
        reconciliation=True,
        inflight_check_interval_ms=2000,
    ),
    risk_engine=LiveRiskEngineConfig(
        max_order_submit_rate="50/00:00:01",
    ),

    # === 適配器 ===
    data_clients={
        "BINANCE": BinanceLiveDataClientConfig(
            api_key="your-key",
            api_secret="your-secret",
            account_type="USDT_FUTURE",
        ),
    },
    exec_clients={
        "BINANCE": BinanceLiveExecClientConfig(
            api_key="your-key",
            api_secret="your-secret",
            account_type="USDT_FUTURE",
        ),
    },

    # === 超時 ===
    timeout_connection=60.0,
    timeout_reconciliation=30.0,

    # === 狀態持久化 ===
    load_state=True,
    save_state=True,
)

node = TradingNode(config=config)
node.trader.add_strategy(my_strategy)
node.run()

六、回測 vs 實盤 配置對比

七、StreamingConfig — 串流數據導出

from nautilus_trader.common.config import StreamingConfig

streaming = StreamingConfig(
    catalog_path="./catalog",    # 自動存入 DataCatalog
    fs_protocol="file",          # 文件系統協議
    include_types=[              # 只存這些數據類型
        "OrderFilled",
        "PositionChanged",
        "Bar",
    ],
)

# 在 TradingNodeConfig 中使用
config = TradingNodeConfig(
    streaming=streaming,
    # ... 其他配置
)

這樣在實盤運行時，指定的事件和數據會自動寫入 Parquet，回頭就能用 DataCatalog 做離線分析。

八、互動練習

config = TradingNodeConfig(
    trader_id="LIVE-001",
    risk_engine=LiveRiskEngineConfig(
        bypass=True,                          # (1)
    ),
    exec_engine=LiveExecEngineConfig(
        reconciliation=False,                 # (2)
    ),
    logging=LoggingConfig(
        bypass_logging=True,                  # (3)
    ),
    load_state=False,
    save_state=False,
)

九、本模組重點回顧