Chainlink TWAP 价格

时间加权平均价格（TWAP）表示资产在一段回看窗口内的价格。本页介绍 Chainlink 计算的 30 秒和 60 秒 TWAP。

持有已授权凭证即可使用 Chainlink Data Streams 测试网。Polymarket RTDS 是推荐的生产集成，计划于 2026 年 8 月 4 日上线。

通过 Chainlink Data Streams 测试

如需实时测试网数据、订阅前的最新报告或原始签名报告，请使用 Chainlink Data Streams。请仅在可信后端运行，切勿向浏览器或移动应用暴露 Chainlink 凭证。

这些 URL 和 Feed ID 仅用于测试网。主网访问（包括生产环境 URL 和 TWAP Feed ID）将于 2026 年 8 月 4 日开放。

安装并连接

使用 Node.js 20+ 和 TypeScript 5.3+。安装 Chainlink SDK：

npm install --save-exact @chainlink/data-streams-sdk@1.2.1

创建测试网客户端：

import {
  createClient,
  decodeReport,
  type Report,
} from "@chainlink/data-streams-sdk";

type TwapFeed = {
  symbol: string;
  windowSeconds: 30 | 60;
};

function requireEnv(name: string): string {
  const value = process.env[name];

  if (!value) {
    throw new Error(`Missing required environment variable: ${name}`);
  }

  return value;
}

const client = createClient({
  apiKey: requireEnv("CHAINLINK_CLIENT_ID"),
  userSecret: requireEnv("CHAINLINK_CLIENT_SECRET"),
  endpoint: "https://api.testnet-dataengine.chain.link",
  wsEndpoint: "wss://ws.testnet-dataengine.chain.link",
  haMode: false,
});

SDK 会为请求签名。请确保服务器时间与 Chainlink 服务器时间相差不超过五秒。

映射并解码报告

将每个 Feed ID 映射到资产和窗口。保留有符号 E18 价格，不要转换为 JavaScript number：

const feeds = new Map<string, TwapFeed>([
  [
    "0x00027603752fe85a4c86c3adcc71abcb5ed826831d8afd4fd746a11c10cee188",
    { symbol: "btc/usd", windowSeconds: 30 },
  ],
  [
    "0x0002e64f0b0166fa748cc05cd510a11442be16279873574f98c8cfa06b42b3dd",
    { symbol: "btc/usd", windowSeconds: 60 },
  ],
]);

const E18 = 10n ** 18n;

function formatE18(value: bigint): string {
  const sign = value < 0n ? "-" : "";
  const absolute = value < 0n ? -value : value;
  const whole = absolute / E18;
  const fraction = (absolute % E18)
    .toString()
    .padStart(18, "0")
    .replace(/0+$/, "");

  return `${sign}${whole}${fraction ? `.${fraction}` : ""}`;
}

function readTwap(report: Report) {
  const feed = feeds.get(report.feedID.toLowerCase());

  if (!feed) {
    throw new Error(`Unexpected Chainlink feed ID: ${report.feedID}`);
  }

  const decoded = decodeReport(report.fullReport, report.feedID);

  if (decoded.version !== "V2") {
    throw new Error(`Expected a V2 report, received ${decoded.version}`);
  }

  return {
    feedID: report.feedID,
    symbol: feed.symbol,
    windowSeconds: feed.windowSeconds,
    value: formatE18(decoded.price),
    observedAt: new Date(report.observationsTimestamp * 1_000).toISOString(),
  };
}

获取最新 TWAP

在订阅前获取每个 Feed 的最新报告：

const latestReports = await Promise.all(
  [...feeds.keys()].map((feedID) => client.getLatestReport(feedID)),
);

for (const report of latestReports) {
  console.log(readTwap(report));
}

输出：Chainlink TWAP

{
  "feedID": "0x00027603752fe85a4c86c3adcc71abcb5ed826831d8afd4fd746a11c10cee188",
  "symbol": "btc/usd",
  "windowSeconds": 30,
  "value": "65000.5",
  "observedAt": "2026-07-27T19:00:00.000Z"
}

订阅更新

订阅所选 Feed ID：

const stream = client.createStream([...feeds.keys()]);

stream.on("report", (report) => {
  try {
    console.log(readTwap(report));
  } catch (error) {
    console.error("Failed to decode Chainlink report:", error);
  }
});

stream.on("disconnected", () => {
  console.warn("Chainlink stream disconnected");
});

stream.on("reconnecting", ({ attempt, delayMs }) => {
  console.warn(`Reconnecting: attempt ${attempt} in ${delayMs}ms`);
});

stream.on("error", (error) => {
  console.error("Chainlink stream error:", error);
});

await stream.connect();

process.once("SIGINT", async () => {
  await stream.close();
  process.exit(0);
});

SDK 会自动验证身份并重连。请监控 error、disconnected 和 reconnecting；如果重试耗尽，请重新启动数据流。

读取 Chainlink 报告

以下测试网 TWAP Feed 使用 Chainlink V2 报告架构。decodeReport() 会将编码后的 benchmarkPrice 暴露为 decoded.price。

值	用法
`report.feedID`	将报告映射到对应资产以及 30 秒或 60 秒窗口
`decoded.price`	将精确的有符号 E18 值保留为 `bigint` 或十进制字符串
`report.validFromTimestamp`	读取报告开始生效的 Unix 秒时间戳
`report.observationsTimestamp`	读取 Chainlink 观测时间的 Unix 秒时间戳
`decoded.expiresAt`	读取报告过期时间的 Unix 秒时间戳
`report.fullReport`	访问 Chainlink 的原始签名报告

报告不包含交易对或窗口标签。请自行维护映射，切勿根据更新频率推断窗口，并使用 observationsTimestamp 检查新鲜度。

decodeReport() 只解析报告字段，不验证 DON 签名。在将报告用于结算或其他对信任要求较高的操作前，请遵循 Chainlink 的验证要求。

测试网 Feed ID

查看 30 秒和 60 秒 Feed ID

资产	30 秒 Feed ID	60 秒 Feed ID
BTC/USD	`0x00027603752fe85a4c86c3adcc71abcb5ed826831d8afd4fd746a11c10cee188`	`0x0002e64f0b0166fa748cc05cd510a11442be16279873574f98c8cfa06b42b3dd`
ETH/USD	`0x000257bd0c11555619448f31c8bbf36250ffdcd8de0d7bf8ab21af804d7a6142`	`0x00022f7f59660d2caf1665dc08976707de45b58518b68bb91cb499182448ae85`
XRP/USD	`0x00027cb2f348a92be0397eba6fdfa814a8473180c56ea4190272ac8e2430df12`	`0x000242f2ce7651c59f07907fa6fa7bccff0405327abffaa09e39a559ce25dc2d`
SOL/USD	`0x0002f6123d7f4f61d213f9bdd10256dc19978f61a74797b1e3479053429f20c8`	`0x0002990595e444f1c3aee99bb78536b8b8c137cfe2f01696df69a045207654c9`
HYPE/USD	`0x0002a498f26948f15e1f00af0330d8fef5ea53fffe4a0bf3f7f31fc2a371ae04`	`0x00027163e67ed79a3b7d67ef68073e1d54745de32fdff1ca68b79f1e0489732a`
DOGE/USD	`0x000234a7d46f9b7a6568ad7d2677a0c0028744d06ece3cc4a006201cf9a76453`	`0x00025ad76902e0d91491abfd13fa5a7320d3248ee7b030a059bd1fd35b601e0c`
ZEC/USD	`0x0002b6a49760c664e68653b4cced722239400b46905e1c1ce45733bd42d7f669`	`0x00024785f38aa028dcbdd32b24a5851c689c7a9db4924ab08480df11ec7c3949`
LINK/USD	`0x0002a1d9e5e117e7627594ac561da02d6777bc170e41a90c21897a02645bd883`	`0x00021c115fafdbf603d36e1d09d7f1f837a43e464eedb382ed8344dd6e5906ce`
TRX/USD	`0x00021a7256522fbd2c5505067cdd6a37a7556d36bcb98467fbe24734527e86fd`	`0x00027d3ec00c5bb657c1b32e19e8b67d14b2ffd25632346ebf6338eb31288463`
BNB/USD	`0x00028242b80742c99e3cfed3b8f9dd48d6dfc449ffb4a4623b129c85b7a19270`	`0x0002b653f2b9497c3c798440729d52f6eaf16f37bc8edb177bf6bbd345d443e1`

请直接使用这些 Feed ID。即使凭证有权获取和订阅自定义 TWAP Feed，它们也可能不会出现在 listFeeds() 中。

主网可用时间

环境	可用时间	REST URL	WebSocket URL
测试网	现在可用	`https://api.testnet-dataengine.chain.link`	`wss://ws.testnet-dataengine.chain.link`
主网	2026 年 8 月 4 日	`https://api.dataengine.chain.link`	`wss://ws.dataengine.chain.link`

8 月 4 日，请将测试网 Feed ID 替换为 Chainlink 发布的主网 ID。复用解码逻辑前，请确认主网报告架构和价格精度。高可用模式仅适用于主网；测试网请保持 haMode: false。 30 秒和 60 秒表示回看窗口，而不是发布频率。Chainlink 负责计算并签名 TWAP。请定义新鲜度阈值和报告中断时的回退行为，不要尝试根据传入更新推断计算方式。Chainlink 目前未公开此自定义数据流的采样边界、权重、舍入或输入缺失处理方式，因此请勿在没有 Chainlink 规范的情况下自行复现该值。有关生产环境要求，请参阅 Chainlink 的 TypeScript SDK 参考、身份验证参考和开发者责任。

使用 Polymarket RTDS

RTDS 是推荐的生产集成。从 2026 年 8 月 4 日起，它将无需凭证即可转发 Chainlink 计算的主网 TWAP 更新。

RTDS TWAP 计划于 2026 年 8 月 4 日上线。启用前，订阅可能返回 topic not found 且不会产生事件。现在即可安装和部署，但请在上线后创建或重新创建订阅；被拒绝的上线前订阅可能不会在现有连接上重试。使用下方 SDK 版本时，RTDS 启用无需再次升级。

请使用小写、斜杠分隔的交易对，例如 btc/usd。省略符号筛选条件即可接收所有可用交易对。

TypeScript
Python
API

需要 Node.js 24+ 和 @polymarket/client@0.3.0-beta.0：

npm install --save-exact @polymarket/client@0.3.0-beta.0

匹配的 Polymarket bindings 会自动安装。常规设置请参阅 TypeScript SDK 指南。使用明确的窗口和所需交易对进行订阅：

import { createPublicClient } from "@polymarket/client";

const client = createPublicClient();

const stream = await client.subscribe([
  {
    topic: "prices.crypto.chainlink.twap",
    windowSeconds: 30,
    symbols: ["btc/usd"],
  },
]);

try {
  for await (const event of stream) {
    console.log({
      symbol: event.payload.symbol,
      value: event.payload.value,
      windowSeconds: event.payload.windowSeconds,
      observedAt: new Date(event.payload.timestamp).toISOString(),
    });
  }
} finally {
  await stream.close();
}

将 windowSeconds 设置为 30 或 60。省略 symbols 即可接收所有可用交易对。该订阅也适用于 SecureClient。

RTDS 启用后的示例输出

type CryptoPricesChainlinkTwapThirtyEvent = {
  topic: "prices.crypto.chainlink.twap";
  type: "update";
  timestamp: EpochMilliseconds;
  payload: {
    symbol: string;
    timestamp: EpochMilliseconds;
    value: DecimalString;
    windowSeconds: 30;
  };
};

type CryptoPricesChainlinkTwapSixtyEvent = {
  topic: "prices.crypto.chainlink.twap";
  type: "update";
  timestamp: EpochMilliseconds;
  payload: {
    symbol: string;
    timestamp: EpochMilliseconds;
    value: DecimalString;
    windowSeconds: 60;
  };
};

type CryptoPricesChainlinkTwapEvent =
  | CryptoPricesChainlinkTwapThirtyEvent
  | CryptoPricesChainlinkTwapSixtyEvent;

{
  "topic": "prices.crypto.chainlink.twap",
  "type": "update",
  "timestamp": 1785178800123,
  "payload": {
    "symbol": "btc/usd",
    "timestamp": 1785178800000,
    "value": "65000.5",
    "windowSeconds": 30
  }
}

payload.value 是根据 Chainlink 定点值转换得到的精确十进制字符串。请将其保留为十进制字符串，不要转换为 JavaScript number。使用 payload.timestamp 作为 Chainlink 观测时间；外层 timestamp 是发布方将更新提交到 RTDS 的时间。RTDS 接受订阅后，SDK 会在断开时恢复订阅，但不会在连接保持打开时重试上线前被拒绝的订阅。

需要 Python 3.11+ 和 polymarket-client==0.3.0b1：

python -m pip install --upgrade "polymarket-client==0.3.0b1"

常规设置请参阅 Python SDK 指南。使用 CryptoPricesChainlinkTwapSpec 订阅：

import asyncio

from polymarket import AsyncPublicClient
from polymarket.streams import CryptoPricesChainlinkTwapSpec


async def main() -> None:
    async with AsyncPublicClient() as client:
        async with await client.subscribe(
            CryptoPricesChainlinkTwapSpec(
                window_seconds=30,
                symbols=["btc/usd"],
            )
        ) as stream:
            async for event in stream:
                print(
                    event.payload.symbol,
                    event.payload.value,
                    event.payload.window_seconds,
                    event.payload.timestamp,
                )


asyncio.run(main())

将 window_seconds 设置为 30 或 60。省略 symbols 即可接收所有可用交易对。该订阅也适用于 AsyncSecureClient。同步客户端不支持实时订阅。

RTDS 启用后的示例输出

class CryptoPricesChainlinkTwapPayload:
    symbol: str
    timestamp: int
    value: Decimal
    window_seconds: Literal[30, 60]

class CryptoPricesChainlinkTwapEvent:
    topic: Literal["prices.crypto.chainlink.twap"]
    type: Literal["update"]
    timestamp: datetime | None
    payload: CryptoPricesChainlinkTwapPayload

{
  "topic": "prices.crypto.chainlink.twap",
  "type": "update",
  "timestamp": "2026-07-27T19:00:00.123000Z",
  "payload": {
    "symbol": "btc/usd",
    "timestamp": 1785178800000,
    "value": "65000.5",
    "window_seconds": 30
  }
}

payload.value 是根据 Chainlink 定点值转换得到的精确 Decimal。使用 payload.timestamp 作为 Chainlink 观测时间；外层 timestamp 是发布方将更新提交到 RTDS 的时间。RTDS 接受订阅后，SDK 会在断开时恢复订阅，但不会在连接保持打开时重试上线前被拒绝的订阅。

如需更底层的控制，可直接连接 RTDS：

wss://ws-live-data.polymarket.com

RTDS 使用应用层心跳。每 5 秒发送一次文本帧 PING 以维持连接。

为所需的回看窗口发送订阅帧：

{
  "action": "subscribe",
  "subscriptions": [
    {
      "topic": "crypto_prices_twap_thirty",
      "type": "update",
      "filters": "{\"symbol\":\"btc/usd\"}"
    },
    {
      "topic": "crypto_prices_twap_sixty",
      "type": "update",
      "filters": "{\"symbol\":\"btc/usd\"}"
    }
  ]
}

回看窗口	RTDS 主题
30 秒	`crypto_prices_twap_thirty`
60 秒	`crypto_prices_twap_sixty`

filters 必须使用上例所示的精确紧凑 JSON 格式，包含一个小写符号且不能有空格，例如 {"symbol":"btc/usd"}。省略该字段即可接收所有可用符号。如果同一窗口需要多个符号，请省略 filters，并在应用中按 payload.symbol 筛选更新。

RTDS 启用后的示例输出

{
  "topic": "crypto_prices_twap_thirty",
  "type": "update",
  "timestamp": 1785178800123,
  "payload": {
    "symbol": "btc/usd",
    "value": 65000.5,
    "full_accuracy_value": "65000500000000000000000",
    "timestamp": 1785178800000,
    "window_s": 30
  }
}

full_accuracy_value 是精确的有符号 E18 定点值。请使用整数或十进制运算将其除以 10¹⁸。数值 value 仅用于便捷显示。使用 payload.timestamp 作为 Chainlink 观测时间；外层 timestamp 是发布方将更新提交到 RTDS 的时间。直接连接的客户端必须在断开连接或收到上线前的 topic not found 响应后重新连接并重新订阅。

选择窗口

每次订阅选择 30 秒或 60 秒窗口。如需两个值，请订阅两次。

数据流行为

订阅从下一次更新开始，不提供快照、历史数据或断开后的重放。

入门指南

核心概念

市场数据

交易

计划

资源

通过 Chainlink Data Streams 测试

读取 Chainlink 报告

测试网 Feed ID

主网可用时间

使用 Polymarket RTDS

选择窗口

数据流行为

​通过 Chainlink Data Streams 测试

​读取 Chainlink 报告

​测试网 Feed ID

​主网可用时间

​使用 Polymarket RTDS

​选择窗口

​数据流行为

通过 Chainlink Data Streams 测试

读取 Chainlink 报告

测试网 Feed ID

主网可用时间

使用 Polymarket RTDS

选择窗口

数据流行为