用途:针对已知的 Kalshi 预测市场(或一组市场)拉取数据,包括订单簿、成交、价格、K 线、预测百分位历史与赛事实时数据,可作为快照、历史区间或实时流获取。
前置条件:需按仓库 README 安装 DFlow 文档 MCP(https://pond.dflow.net/mcp),参数、分页、载荷结构、WebSocket 快照与增量语义等以该 MCP 为准。所有数据端点走 Metadata API(https://pond.dflow.net/resources/metadata-api),REST 用于快照与历史,WebSocket 用于实时流;可从 curl、Node/Python 脚本、定时任务、后端或 Next.js 代理调用。若用户要求从终端运行,不要用 dflow CLI(无市场数据子命令),应写 HTTP/WS 脚本。
主要能力与端点:订单簿 GET /api/v1/orderbook/{ticker} 或 /by-mint/{mint},流为 orderbook 频道;成交有 /api/v1/trades(完整市场成交带,含 DFlow 链上成交)与 /api/v1/onchain-trades(仅链上成交,含 wallet、transactionSignature、inputAmount、outputAmount 等字段,无 WS);最优价从 GET /api/v1/market/{ticker} 的 yesBid/yesAsk/noBid/noAsk 读取,流为 prices 频道;K 线 GET /api/v1/market/{ticker}/candlesticks 或事件级 /api/v1/event/{ticker}/candlesticks;预测百分位历史 GET /api/v1/event/{seriesTicker}/{eventId}/forecast_percentile_history;实时数据 GET /api/v1/live_data 等,details 字段随里程碑类型变化。
使用方式:先判断快照/历史/流三种意图再选端点。流式生命周期为连接、订阅、处理、重连;开发环境 wss://dev-prediction-markets-api.dflow.net/api/v1/ws 无需鉴权,生产环境 wss://prediction-markets-api.dflow.net/api/v1/ws 需在升级头带 x-api-key。订阅消息形如 { type: "subscribe", channel: "prices" | "trades" | "orderbook", all: true | tickers: [...] }。断线需指数退避重连并重发全部订阅。
限制与注意:订单簿只返回买盘阶梯,最优 YES 卖价需推导为 1 - max(no_bids keys);价格存在概率字符串与 0–10000 整数两种刻度,计算前需归一化;K 线每次请求上限 5000 根,超出返回 400 且无部分结果;periodInterval 单位为分钟;live_data.details 按类别分支处理;all: true 为全量洪流,建议用 ticker 列表;每周四 3:00–5:00 AM ET 维护窗口数据稀疏;CLI 存储的密钥不会自动进入脚本 HTTP 客户端。需向用户确认是否持有 DFlow API key,有则用生产主机并在每次请求带 x-api-key,无则用开发主机(限流),申请见 https://pond.dflow.net/get-started/api-key。本技能为只读公开数据,不涉及 RPC、钱包、签名、结算、滑点或费用;下单请转 dflow-kalshi-trading。