课程行情数据的消息与流式处理 · 量化开发的软件工程
量化管道中的 Kafka
上海一家 私募 的数据工程主管在晨会上只放了一张幻灯片：沪深300 ETF 的 ticker plant 已经连续运行 19 个月没有漏一条 tick。那张图背后只有一件基础设施：三节点 Kafka 集群、按 symbol 做 partition key、replication factor 3、 min.insync.replicas=2 ，再加一个「处理...
打开 →找到 17 个结果
中文题目课程可观测性与系统设计 · 量化开发的软件工程
Prometheus、Grafana 与交易栈监控
沪深300 期权做市的私募，盘中 14:23 出现单边行情，CFFEX IF 主力合约成交骤增。值班 quant developer 在飞书智能助手里收到一条钉钉机器人推送：『KafkaConsumerLagHigh：feedhandler warehouse 消费组 lag 10000，持续 5m』。打开 Grafana，dashboard 名字叫 fee...
打开 →课程行情数据的消息与流式处理 · 量化开发的软件工程
低延迟消息：ZeroMQ、多播与共享内存
上海一家 私募 的电子交易主管把一名资深工程师拉到一边：「期权做市新策略要求 沪深300 ETF 的 top of book 在策略线程内到达延迟不超过 50 微秒。我们现在跑 Kafka 是 3 毫秒——差了三个数量级。怎么办？」诚实的答案是「先量，再按 rung 一级一级往下挪」。L2 把你留在 Kafka 这一级—— acks='all' 端到端毫秒级...
打开 →课程行情数据的消息与流式处理 · 量化开发的软件工程
流式行情接入端到端实战
上海一家 私募 中等频率股票策略团队的量化开发收到任务：两周内从零搭一条 沪深300 ETF 的 ticker plant。手头握住 3.6.3 的仓库（TimescaleDB hypertable， ticks raw(symbol, ts, price, size, side) ， (symbol, ts) 主键）、L1 的消息词汇、L2 的 Kafka...
打开 →模块3.6.4 · 编程 · 量化开发的软件工程
行情数据的消息与流式处理
messaging · streaming · pub-sub · queue · kafka · zeromq · delivery-semantics · at-least-once
打开 →课程行情数据的消息与流式处理 · 量化开发的软件工程
行情数据的消息传递基础
周二早上，上海一家中等频率股票策略的 私募 量化开发被呼叫：沪深300 ETF 行情入库链路安静了 90 秒，交易室监控屏幕冻在最后一根 K 线上。生产者（producer）——解码 vendor 推送的 normalised 行情的 feed handler——状态正常；消费者（consumer）——把每条 tick 落进数据仓库的 writer——也正常...
打开 →课程可观测性与系统设计 · 量化开发的软件工程
系统设计、运维手册与事故响应实战
国内私募量化的早盘 09:18，CFFEX IF 主力合约 tick 经过 feed handler 落入 TimescaleDB，过去三周一切正常。今早值班手机突然弹一条飞书电话呼叫：『KafkaConsumerLagHigh：feedhandler warehouse lag 10000，持续 5m，runbook 见 https://runbooks....
打开 →课程实盘交易与运营 · 策略类型与业绩
OMS、EMS 与交易系统架构
OMS、EMS 与交易系统架构 某五因子多空股票私募在多策略平台回测夏普 1.8(扣除模型化成本)。周一以 5 亿美元名义本金上线、通过国信证券执行,中信证券 PB 提供融资。三十个交易日后,实盘夏普 0.4。这不是单一 bug —— 它是回测忽略的每一层运营基础设施合并的滑点:目标组合差分延迟到 OMS;OMS 合规闸门拒绝 20% 转入覆盖;EMS 切片...
打开 →课程可观测性与系统设计 · 量化开发的软件工程
分布式追踪、OpenTelemetry 与日志聚合
国内私募的 50ETF 期权做市，盘中 13:47 SSE 一条 IF 主力 tick 的入库延迟从平均 80 毫秒跳到 1.8 秒。L1 的结构化日志能告诉你这一笔 tick 落在 feed handler consumer 7c4f9d8b6 x2k4l 这个 pod 的某条 offset；L2 的 dashboard 能告诉你 p99 延迟在过去 5 ...
打开 →课程设计模式与工具 · 高级 Python
同步原语：threading 与 asyncio
开场 某私募周二上午九点三十一，沪深300 ETF（510300.SH）刚收完集合竞价，团队的 tick 处理器跑了九十秒。两个生产者线程在排空一个 Tushare 风格的行情 websocket——一个分片走 SSE（上海）回报，一个分片走 SZSE（深圳）回报——四个消费者线程各跑一个下游策略。九十三秒时，四个策略共写的盈亏累计器显示 1400000 元...
打开 →课程构建、部署与容器化 · 量化开发的软件工程
容器编排：Compose 与 Kubernetes
上海一家 私募 的 quant 把 L2 产出的 feed handler:1.0.0 镜像推到 内部 registry，问 平台 组 怎么 把 它 部署 到 测试 集群。负责 工程师 直接 反 问：「你 的 docker compose.yml 本地 长 什么 样？你 的 manifests/ 在 测试 集群 长 什么 样？」quant 两份 都 没有，手...
打开 →课程基本面、另类数据与数据基础设施 · 量化数据
数据供应商接口与数据采集
周二早上 8:47。某上海私募的股票策略组组长在数据团队飞书里点了 @：「我们 fundamentals pit 表里 600519 以后的股票全部缺失。今早策略对沪深300 后 30% 的标的完全没头寸。」值班数据工程师调出昨晚的入库日志。Wind 数据 服务 SFTP 文件 02:14 完成下载——SFTP close() 返回成功、cron 日志写「入...
打开 →课程SQL 与时序数据库 · 量化开发的软件工程
时序数据库：TimescaleDB、QuestDB、InfluxDB 与 kdb+
某 沪深 300 私募 的 交易员 提单：『上 一 季 在 ticks 表 上 15 秒 出结果 的 1 分钟 VWAP per symbol 查询，今天 跑 了 11 分钟。Postgres 仓库 正在 维持 每秒 9 万 写入 来自 沪深 行情 网关，EXPLAIN 在 一条 仅 触 三日 数据 的 查询 上 报 1.8 亿 缓冲 读取』。L2 的 卫生...
打开 →课程构建、部署与容器化 · 量化开发的软件工程
构建部署流水线端到端实战
上海一家 私募 的 风控 主管 批准 了 你 的 L3 manifest，但 在 部署 步 上 停 住：「开发者 把 一行 修复 合 入 main，这 时 镜像 从 哪 来？谁 打 tag？谁 扫描？谁 推 到 Aliyun ACR？谁 对 feed dev 跑 kubectl apply ？明天 生产 上 在 1.0.1 里 发现 bug，谁 把 它 翻 ...
打开 →课程可观测性与系统设计 · 量化开发的软件工程
结构化日志、指标与追踪：可观测性三支柱
凌晨 02:14，沪深300 期权做市的私募量化值班手机响起。一条 SSE 50ETF 的报价在落库前出现了 11 秒延迟，下一档 CFFEX IF 主力的对冲单也跟着卡住。你打开堡垒机，登进 feed handler consumer 的容器，敲下熟悉的 tail f /var/log/... ——什么都没有，因为容器里根本没有 /var/log/ 。再敲...
打开 →课程构建、部署与容器化 · 量化开发的软件工程
量化服务的容器化
上海一家 私募 的风控工程主管把你写的第一份 Containerfile 拿出来评审，还没读到第一行指令就问三个问题：「这镜像里有什么是 root 跑的？」「最终镜像 多大？」「构建是 在 镜像构建时 重新解析依赖，还是 直接 消费 L1 的 wheel？」每个问题都有一个 错答案 平台组 不会 部署——所有进程都跑 root、镜像 800 MB、 RUN ...
打开 →课程构建、部署与容器化 · 量化开发的软件工程
量化部署中的 Python 项目打包
上海一家 私募 的初级 quant 刚完成 3.6.4 的 capstone：三个 Python 文件、一个 run.sh 、一份装满了沪深300 ETF tick 的 TimescaleDB 仓库。PM 很满意；平台组不太满意。部署评审会上他们问的第一个问题是「wheel 在哪？」第二个问题是「锁定文件 在哪？」那段在开发者笔记本上跑得完美的脚本，没有办法...
打开 →