用实时社交信号构建 Polymarket 交易机器人

直接回答

TweetStream 提供指定 X 和支持的 Truth Social 社交事件，Polymarket 官方接口单独提供市场数据与执行。维护的本地夹具示例展示映射、时效、去重和仓位限制，并只生成模拟执行意图。

抢在赔率完全反应前捕捉催化剂

新信息进入市场时，赔率就会变化。TweetStream 把指定 X 和支持的 Truth Social 帖子送进策略，Polymarket 官方接口单独提供价格与执行。把边界分开，再缩短从源头帖子到通过风控订单的路径。

• Polymarket API：市场、赔率、流动性、仓位和订单
• TweetStream：指定 X 账号和支持的 Truth Social 帖子
• 策略服务：来源映射、分类、置信度和风控
• 执行服务：订单构建、限额、幂等和对账

把每个市场映射到决定性来源

先为每个市场建立来源映射，再编写关键词规则。如果市场依据机构公告结算，就跟踪该机构和负责官员；如果依据公司行动结算，就跟踪公司、高管和一线记者。对于政治市场，在相关时纳入支持的 Trump 与白宫 Truth Social 帖子。

• 把市场 ID、结算条件、来源账号、关键词和到期时间存储在一起
• 第一方来源的优先级高于评论账号
• 先使用作者身份和发布时间，再解释文本内容
• 市场关闭或交易逻辑改变后立即停用映射

把实时 feed 变成可检查的决策路径

建立一条 TweetStream WebSocket 连接，按作者路由内容事件，并把匹配的帖子关联到实时交易场所市场。第一轮判断应保持确定性：来源匹配、关键词匹配、市场仍开放、事件足够新且尚未处理。维护的本地示例同时演示 Polymarket 与 Kalshi，且不会发送订单。

• 使用 TweetStream v1 WebSocket 子协议认证
• 在产生任何交易副作用前持久化事件 ID
• 当影响市场的信息发布在图片中时使用 OCR 文本
• 消费富化事件，但不要无谓延迟首次内容判断

把帖子转成有边界的决策

分类器应输出一个小型决策对象，而不是自由文本观点：市场 ID、隐含方向、置信度、证据片段、事件时间和到期时间。这样风控规则可以审查，也能防止语言模型本身成为执行策略。

• 拒绝无法映射到明确结算条件的帖子
• 流动性越低或价差越大，要求越高的置信度
• 设置最大事件年龄和入场前最大赔率变动
• 把含义不明确的事件交给人工交易台，不要强行交易

用 AI 编程 agent 加速，但不要交出交易权限

用 AI 编程助手构建适配器；用 Polymarket 智能体框架编排范围明确的工具，而不是掌控资金。框架只应读取结构化市场数据并生成仅模拟意图。调用执行客户端前，由确定性代码验证来源身份、市场状态、时效、流动性、风险敞口和订单幂等性。

• 使用 Claude Code、Codex、Cursor 或其他编程 agent 调整维护的夹具示例
• 只开放市场读取和模拟意图等窄工具，不授予无限制交易权限
• 要求通过 schema 验证的决策，并包含证据片段、置信度和到期时间
• 把 API 凭据、最大亏损和终止开关放在 agent 运行时之外

衡量从信号到成交，而不是单一供应商指标

只有整条链路都被测量，快速提醒才有价值。记录来源帖时间、TweetStream 到达时间、分类完成时间、订单提交、交易所确认和成交时间。TweetStream 公布的服务端检测中位数为 167ms；请用自己的观察列表测试，因为端到端链路仍包括网络、处理和交易场所执行。

先证明策略，再投入资金

实盘前，先用历史市场快照回放捕获的事件，再让生产数据流以影子模式运行而不下单。只有来源映射、过期事件规则和损失上限在两条路径中都经受住验证的策略，才能进入实盘。

• 分别回测市场映射和分类器方向
• 影子运行实时事件，对比理论价格与可执行价格
• 从严格的仓位和单日亏损上限开始
• 把终止开关放在分类器和执行 worker 之外

实施资产：预测市场来源路由器

把已验证的 X 和受支持 Truth Social 事件转换为类型明确、与交易场所无关的路由决策。根据你的策略调整来源列表、市场映射与关键词，并在该模式外围用确定性代码处理重复、过期事件、仓位限制、凭证和执行控制。

type SocialPlatform = "twitter" | "truth_social";
 
type TweetStreamContentEvent = {
  d: {
    author: { handle?: string; platform: SocialPlatform };
    createdAt: number;
    kind: "post" | "quote" | "reply" | "retweet";
    text: string;
    tweetId: string;
  };
  id?: string;
  op: "content";
  t: "tweet";
  ts: number;
  v: 1;
};
 
const sourceRules = [
  {
    handles: ["whitehouse", "potus"],
    platform: "twitter",
    strategy: "policy-markets",
    terms: ["executive order", "tariff"],
    venue: "polymarket",
  },
  {
    handles: ["realdonaldtrump"],
    platform: "truth_social",
    strategy: "trade-policy",
    terms: ["trade policy", "announcement"],
    venue: "kalshi",
  },
] as const;
 
export function routePredictionMarketSourceEvent(event: TweetStreamContentEvent) {
  const handle = event.d.author.handle?.toLowerCase().replace(/^@/, "");
  const platform = event.d.author.platform;
  const text = event.d.text.toLowerCase();
  const rule = sourceRules.find(
    (candidate) =>
      candidate.platform === platform &&
      candidate.handles.some((candidateHandle) => candidateHandle === handle),
  );
  const matchedTerm = rule?.terms.find((term) => text.includes(term));
 
  if (!rule || !matchedTerm) {
    return { deliver: false } as const;
  }
 
  return {
    deliver: true,
    eventId: event.d.tweetId,
    matchedTerm,
    strategy: rule.strategy,
    venue: rule.venue,
  } as const;
}

为什么用 TweetStream 实施

这套流程可以用原始 API、轮询和自建抓取拼出来，但如果你关心速度、删除/置顶提醒、资料/关注信号、代币/OCR 富化和稳定 WebSocket 投递，TweetStream 是更好的起点。开始 3 天试用，把第一组高信号账号接入你的提醒或交易流程。

常见问题