在流上原型
用服务端过滤抽样大额权利金或短期限流,避免笔记本被全量成交淹没。
在 WebSocket 成交上设计特征,并用历史 RAW 逐笔成交验证。比较结果前,请明确映射派生字段和聚合模式。
既需要实时期权成交流(日均约 1000 万),又需要 SQL 数仓(滚动 15 天窗口,约 1 亿笔成交),并要求 Greeks/IV/权利金语义一致的量化研究员。
在流与 SQL 上保持权利金、delta 区间与剩余天数过滤的同一套定义。
用服务端过滤抽样大额权利金或短期限流,避免笔记本被全量成交淹没。
按将要上线的同一公式持久化分钟线或事件特征(权利金、|delta|、IV)。
通过历史 SQL 回放多周窗口,并使用适合研究任务的行数/超时防护。
把过滤提升为生产 WebSocket 参数,并对照 SQL 基线监控漂移。
SELECT
toStartOfMinute(time) AS minute,
sumIf(toFloat64(price) * size * 100, put_call = 'CALL') AS call_premium,
sumIf(toFloat64(price) * size * 100, put_call = 'PUT') AS put_premium,
avg(abs(delta)) AS avg_abs_delta
FROM RawOptionTrades
WHERE date = (
SELECT max(date) FROM RawOptionTrades
WHERE symbol = 'AAPL' AND date >= today() - 7
)
AND symbol = 'SPY'
AND toFloat64(price) * size * 100 >= 50000
GROUP BY minute
ORDER BY minute
LIMIT 1000另见量化总览与面向量化的 UOA 页。
可以。许多研究从 SQL 开始。转为实时处理前,需要映射派生字段,并核对 RAW 逐笔成交与 AGGREGATED 合并事件的差别。
会。AGGREGATED 合并同时段同合约成交;RAW 保留每条交易所打印。从回测到生产请固定一种模式。
付费历史 SQL 可查询过去 15 天的期权成交(滚动 360 小时窗口,约 1 亿行量级),通过 REST 上的 ClickHouse SQL 访问。
Greeks 与 IV 是在模型假设下的分析估计。应作为特征使用,而非对盈亏的保证。