Welcome to Xu’Log

读取 ，行 1 到 50 读取 ，行 1 到 30 读取 ，行 1 到 50 搜索文本 WindPy (**/data/fetcher.py)，3 个结果 读取 ，行 180 到 230 这是一个非常经典且实用的场景。 直接回答： 在 Linux Docker 容器中无法直接调用宿主机（Windows）上的 Wind 终端，因为 Docker 容器是隔离的，且 Wind 的 Python 接口（WindPy）在 Windows 上依赖 COM 组件通信，这在 Linux 环境下是不存在的。 解决方案：搭建 “Wind 桥接器” (Wind Bridge) 我们可以采用 C/S 架构 来解决这个问题： 服务端（Windows）：在你的 Windows 上运行一个简单的 Python 脚本，它负责连接本地的 Wind 终端。 客户端（Docker Linux）：在容器里，我们写一个“伪装”的 Wind 接口，通过网络（RPC）把请求发给 Windows，Windows 执行完后把数据传回来。 这样做的好处是：Docker 里的代码完全不用改（或者改动极小），就像在本地跑 Wind 一样。 我为你准备了全套代码： 第一步：在 Windows 上运行 “服务端” 请在你的 Windows 宿主机 上创建一个文件 wind_server.py，并运行它。 （你需要先在 Windows 上 pip install rpyc WindPy） ...

核心指标组合 1. ATR（平均真实波幅） 定义：衡量市场波动性的指标，计算一定周期内的平均真实波幅。 计算方法：TR（True Range）是以下三者的最大值： 当日最高价 - 当日最低价 |当日最高价 - 昨日收盘价| |当日最低价 - 昨日收盘价| ATR对TR取指数移动平均(EMA)。 作用：衡量市场波动率，ATR值越大说明趋势越强，ATR值小且稳定说明处于震荡 用法：当ATR持续处于低位（如低于近期均值的30%），可判断为震荡市；当ATR快速放大，可能趋势启动 2. 布林带（Bollinger Bands） 作用：识别价格运行区间和突破信号 震荡市特征：价格在布林带上下轨之间来回震荡，布林带收窄 趋势市特征：价格沿布林带上轨或下轨运行，布林带开口扩张 用法： 震荡市：在布林带上轨卖出，下轨买入 趋势市：价格突破布林带后顺势跟进 布林带收窄+价格突破：趋势启动信号 布林带开口+价格沿上轨/下轨运行：趋势延续 布林带收窄+价格在通道内震荡：高抛低吸 3. ADX（平均方向指数） 定义：衡量趋势强度的指标，数值范围0-100; 不判断方向，指衡量强弱。 作用：量化趋势强度 用法： ADX < 20：市场处于震荡或无趋势状态，适合高抛低吸策略 ADX > 25：趋势确立，市场进入单边行情 ADX > 40：强势趋势，可能接近趋势尾声 ADX > 50：极端趋势，需警惕反转风险 4. RSI（相对强弱指标） 定义：通过比较一定周期内上涨幅度和下跌幅度的相对强度来反映市场超买超卖状态，反应多空的动能。 计算方法： $$ RSI = 100 - \frac{100}{1 + RS} $$ 其中，$RS$ 是平均上涨点数与平均下跌点数的比值。 作用：识别超买超卖区域 震荡市用法：在RSI 30-70区间内高抛低吸；突破70或跌破30可能预示趋势转换 实战组合策略 震荡市识别条件： ATR处于近期低位 ADX<20 布林带收窄，价格在上下轨间震荡 RSI在30-70区间运行 趋势市识别条件： ...

ATR指标原理 真实波幅(True Range) 传统波动率计算(最高价-最低价)忽略了跳空缺口。ATR通过 真实波幅(TR) 解决这个问题： $$ TR_t = \max \begin{cases} H_t - L_t \ |H_t - C_{t-1}| \ |L_t - C_{t-1}| \end{cases} $$ 其中： $H_t$: 当前最高价 $L_t$: 当前最低价 $C_{t-1}$: 前一周期收盘价 物理意义: TR捕捉了三种波动来源： 日内波动 ($H_t - L_t$) 向上跳空 ($H_t - C_{t-1}$) 向下跳空 ($L_t - C_{t-1}$) 平均真实波幅(ATR) 对TR取指数移动平均(EMA)： $$ ATR_t = \frac{(N-1) \times ATR_{t-1} + TR_t}{N} $$ 交互演示：ATR 参数的影响 为了更直观地理解 ATR，我制作了一个交互式工具。你可以拖动下面的滑块，改变周期 $N$，观察 ATR 曲线（下方蓝色区域）和基于 ATR 的通道（上方虚线）是如何变化的。 ATR 动态演示 Interactive Demo ATR 周期 (N): 14 💡拖动滑块观察：周期越大，ATR曲线越平滑，对价格波动的反应越迟钝（滞后性）。 ...

系统架构 系统架构 基于 vnpy 4.1.0 构建的生产级量化交易平台，采用分层架构设计： 数据层 Wind API: 历史行情获取与实时数据推送 SQLite: 本地数据存储与索引优化 数据验证: 缺失值检测、异常值过滤、时间序列对齐 交易层 CTP网关: 东方证券期货接口，支持实盘交易 订单管理: 订单验证、重复检测、撤单管理 风控系统: 保证金实时监控 最大持仓限制 单笔订单金额限制 策略层 CTA引擎: 基于vnpy_ctastrategy的策略框架 回测引擎: 支持参数优化和多策略组合 性能分析: 夏普比率、最大回撤、盈亏比、胜率等 监控层 Rich终端: 实时持仓、PnL、订单状态 日志系统: 分级日志记录和错误追踪 可视化: Plotly交互式图表 + Matplotlib静态图表 策略分类体系 量化策略按交易逻辑可分为四大类： 1. 趋势跟踪策略 核心思想: 识别趋势方向，顺势交易。 策略 信号来源 适用市场 ATR波动率突破 价格突破 + ATR过滤 趋势初期、波动率扩大 动量反转组合 短期动量 + 长期反转 趋势延续但有回调 均线交叉 快慢均线金叉/死叉 明确趋势行情 通道突破 唐奇安通道/布林带上下轨 区间震荡后的突破 国债期货特点: 趋势持续性强（政策驱动） 单日波动小，需持仓数日至数周 适合中长期趋势策略 2. 均值回归策略 核心思想: 价格偏离均值后会回归。 ...

📝 创建新文章 使用 Hugo 命令创建 1 2 3 4 # 创建新文章 hugo new posts/my-article.md # 文章会自动应用 archetypes/default.md 模板 文件命名建议 ✅ 推荐：使用小写字母 + 连字符：how-to-write-hugo.md ✅ 可选：使用下划线：my_first_post.md ⚠️ 支持但不推荐：中文文件名 我的文章.md 🎯 Front Matter 配置详解 Front Matter 是文章开头的元数据部分，Hugo 支持 YAML 和 TOML 两种格式。 YAML 格式（推荐） 使用 --- 包裹，更易读，是本博客的标准格式： 1 2 3 4 5 6 7 8 9 --- title: "文章标题" date: 2025-11-15T14:30:00+08:00 draft: false author: "LexHsu" categories: ["tech", "life"] tags: ["hugo", "markdown"] description: "文章摘要，显示在列表页和搜索结果中" --- TOML 格式（备选） 使用 +++ 包裹： ...

源码文件：vnpy_spreadtrading.strategies.basic_spread_strategy 1. 策略概述 BasicSpreadStrategy 与其说是一个自动策略，不如说是一个智能执行工具。 它不包含任何指标计算或预测逻辑，而是完全按照用户在参数中指定的固定价格进行挂单交易。它适合那些通过主观判断或外部计算得出目标价差，然后希望程序自动完成“腿A+腿B”复杂下单过程的交易员。 基类：SpreadStrategyTemplate 核心逻辑：固定点位开平 + 时间过滤 适用场景：主观套利、跨期移仓 2. 核心参数 参数名 含义 buy_price 买入开仓触发价 sell_price 卖出平仓触发价 short_price 卖出开仓触发价 cover_price 买入平仓触发价 max_pos 目标持仓量 start_time 每日开始交易时间 (如 “9:00:00”) end_time 每日停止交易时间 (如 “15:00:00”) 3. 策略逻辑详解 3.1 时间过滤器 策略首先检查当前时间是否在允许的交易时段内。如果不在，会强制停止所有正在运行的算法。 1 2 3 4 5 self.update_time = self.spread.datetime.time() if self.update_time < self.start_t or self.update_time >= self.end_t: self.stop_open_algos() self.stop_close_algos() return 3.2 状态机逻辑 策略根据当前的持仓状态 (spread_pos) 决定启动哪种算法。 空仓 (spread_pos == 0)： 检查是否已启动买入算法 (buy_algoid)，若无则启动。 检查是否已启动卖出算法 (short_algoid)，若无则启动。 注意：这里是同时监控双向开仓机会。 持有多头 (spread_pos > 0)： 停止开仓算法。 启动卖出平仓算法 (sell_algoid)，目标价为 sell_price。 持有空头 (spread_pos < 0)： ...

源码文件：vnpy_spreadtrading.strategies.statistical_arbitrage_strategy 1. 策略概述 StatisticalArbitrageStrategy 是一个经典的 均值回归 (Mean Reversion) 策略，应用于价差交易。 其核心假设是：两个相关性极高的品种（如豆油/棕榈油，螺纹/热卷），它们的价差会围绕一个均值波动。当价差偏离均值过大（突破布林带上轨/下轨）时，大概率会回归。 基类：SpreadStrategyTemplate 核心指标：Bollinger Bands (布林带) 交易逻辑：逆势交易（高抛低吸） 2. 核心参数 参数名 默认值 含义 boll_window 20 布林带均线周期 boll_dev 2 布林带标准差倍数 max_pos 10 最大持仓量 payup 10 算法执行时的超价跳数 interval 5 算法撤单重发间隔(秒) 3. 策略逻辑详解 3.1 K 线合成与指标计算 策略使用 BarGenerator 合成价差的 K 线（注意：是价差本身的 K 线，不是单腿的）。 在 on_spread_bar 中计算布林带： 1 2 self.boll_mid = self.am.sma(self.boll_window) self.boll_up, self.boll_down = self.am.boll(self.boll_window, self.boll_dev) 3.2 交易信号 策略逻辑非常清晰，分为三种状态： 空仓时 (spread_pos == 0)： 做空价差：价差 > 上轨 (boll_up)。预期价差回归下跌。 做多价差：价差 < 下轨 (boll_down)。预期价差回归上涨。 1 2 3 4 if bar.close_price >= self.boll_up: self.start_short_algo(bar.close_price - 10, self.max_pos, ...) elif bar.close_price <= self.boll_down: self.start_long_algo(bar.close_price + 10, self.max_pos, ...) 持有空头 (spread_pos < 0)： ...

在进行价差交易（套利）开发前，必须理解 vnpy_spreadtrading.template 提供的基础框架。与 CTA 策略不同，价差交易涉及多条腿（Legs）的同步操作，因此引入了“算法执行”的概念。 1. SpreadStrategyTemplate：策略的大脑 所有价差策略都继承自 SpreadStrategyTemplate。 1.1 核心回调函数 回调函数 触发时机 典型用途 on_init 策略初始化 初始化变量，加载历史数据 on_start 策略启动 标记状态 on_spread_data 价差行情更新 核心逻辑区：判断价差是否满足开平仓条件 on_spread_pos 价差持仓更新 监听持仓变化，决定下一步动作 on_spread_algo 算法状态更新 监听算法执行进度（如算法完成、停止） 1.2 算法启动接口 价差交易不直接发单（不调用 buy/sell），而是启动一个算法 (Algo) 来负责执行。 这是因为买入一个价差通常意味着“买入腿A + 卖出腿B”，必须保证原子性或滑点控制。 买入价差 (Long Spread): 1 self.start_long_algo(price, volume, payup, interval, lock) price: 价差限价 volume: 数量 payup: 超价跳数（用于保证成交） interval: 撤单重发间隔 lock: 是否锁仓（针对上期所） 卖出价差 (Short Spread): 1 self.start_short_algo(price, volume, payup, interval, lock) 1.3 停止算法 stop_algo(algoid): 停止特定算法 stop_all_algos(): 停止所有正在运行的算法 2. SpreadAlgoTemplate：执行的手脚 策略只负责“决定要做什么”，而 SpreadAlgoTemplate 负责“具体怎么做”。 ...

源码文件：vnpy_ctastrategy.strategies.test_strategy 1. 策略概述 TestStrategy 并不是一个用于实盘获利的交易策略，而是一个调试工具。 它的主要作用是帮助开发者验证： 交易接口（Gateway）是否连接正常。 策略引擎（CtaEngine）是否能正确收发订单。 测试下单函数的执行耗时。 基类：CtaTemplate 触发机制：基于 Tick 计数，每隔 N 个 Tick 执行一个测试动作。 2. 测试流程 策略内部维护了一个函数列表 self.test_funcs，按顺序存放了要测试的动作： 市价单测试 (test_market_order)： 以涨停价 (limit_up) 发出买单，模拟市价成交（在期货中通常用对手价或超价模拟市价）。 限价单测试 (test_limit_order)： 以跌停价 (limit_down) 发出买单，模拟挂单（通常不会立即成交）。 全撤测试 (test_cancel_all)： 调用 cancel_all() 撤销之前挂出的所有未成交订单。 停止单测试 (test_stop_order)： 发出本地停止单（Stop Order），验证策略引擎的触发机制。 3. 核心代码逻辑 在 on_tick 中，每收到 test_trigger (默认10) 个 Tick，就弹出一个测试函数执行，并计算耗时。 1 2 3 4 5 6 7 8 9 10 11 self.tick_count += 1 if self.tick_count >= self.test_trigger: self.tick_count = 0 if self.test_funcs: test_func = self.test_funcs.pop(0) # 取出下一个测试任务 start = time() test_func() # 执行 time_cost = (time() - start) * 1000 # 计算耗时(ms) self.write_log(f"耗时{time_cost}毫秒") 4. 使用场景 当你刚配置好一个新的交易接口（比如连接到一个新的仿真环境），或者修改了底层引擎代码后，可以先运行这个策略： ...

源码文件：vnpy_ctastrategy.strategies.turtle_signal_strategy 1. 策略概述 TurtleSignalStrategy 是大名鼎鼎的 海龟交易法则 (Turtle Trading Rules) 的完整复现。 它不仅仅是一个简单的突破策略，而是一套完整的资金管理系统，包含了： 入场：唐奇安通道 (Donchian Channel) 突破。 仓位管理：基于 ATR (N值) 的加仓 (Pyramiding)。 止损：基于 ATR 的移动止损。 离场：反向通道突破。 基类：CtaTemplate 核心指标：Donchian Channel, ATR 复杂度：高（涉及分批加仓逻辑） 2. 核心参数 参数名 默认值 含义 entry_window 20 入场通道周期 (20日高点) exit_window 10 离场通道周期 (10日低点) atr_window 20 ATR 计算周期 3. 策略逻辑详解 3.1 信号计算 策略使用 am.donchian 计算唐奇安通道，使用 am.atr 计算波动率 N 值。 1 2 3 self.entry_up, self.entry_down = self.am.donchian(self.entry_window) # 20日 self.exit_up, self.exit_down = self.am.donchian(self.exit_window) # 10日 self.atr_value = self.am.atr(self.atr_window) 3.2 初始入场 当空仓时，在 20 日高点挂买入停止单，在 20 日低点挂卖出停止单。 ...