DEV Community: PeakLine

(实时)贵金属行情接口详细接入指南【2025最新教程】

PeakLine — Fri, 12 Sep 2025 03:41:20 +0000

在本文中，我们将通过C++接入Infoway API的贵金属实时行情数据接口，帮助你获取黄金和白银等贵金属的K线数据。我们会使用 libcurl 库进行HTTP请求，并处理API返回的数据。

一、API请求地址

Infoway API主要提供实时行情数据，详细的对比可以参考这篇文章。贵金属的实时行情通过如下API获取：

https://data.infoway.io/common/batch_kline/{klineType}/{klineNum}/{codes}

## 官网：www.infoway.io

入参说明：

{klineType} 是K线的时间周期，传入不同的值代表不同周期的K线：
| ID | K线周期 |
|----|-------------|
| 1 | 1分钟k线 |
| 2 | 5分钟k线 |
| 3 | 15分钟k线 |
| 4 | 30分钟k线 |
| 5 | 1小时k线 |
| 6 | 2小时k线 |
| 7 | 4小时k线 |
| 8 | 1日k线 |
| 9 | 1周k线 |
| 10 | 1月k线 |
| 11 | 1季k线 |
| 12 | 1年k线 |

{klineNum} 是需要的K线数量，这个接口支持能查询最近的500根K线。

{codes} 是资产代码，比如黄金是XAUUSD

二、代码示例

假设我们需要查询黄金和白银的1分钟K线，请求地址是：

https://data.infoway.io/common/batch_kline/1/2/XAUUSD%2CXAGUSD
// 这个地址能返回黄金和白银最近的2根1分钟K线

完整代码如下：

#include <iostream>
#include <string>
#include <curl/curl.h>

// 回调函数，用来接收HTTP响应的数据
size_t WriteCallback(void* contents, size_t size, size_t nmemb, std::string* out) {
    size_t total_size = size * nmemb;
    out->append((char*)contents, total_size);
    return total_size;
}

int main() {
    CURL* curl;
    CURLcode res;

    // 设置 API URL 和请求头
    // 申请API Key: www.infoway.io
    const std::string api_url = "https://data.infoway.io/common/batch_kline/1/2/XAUUSD%2CXAGUSD";

    // 初始化 libcurl
    curl_global_init(CURL_GLOBAL_DEFAULT);
    curl = curl_easy_init();

    if (curl) {
        // 设置 URL
        curl_easy_setopt(curl, CURLOPT_URL, api_url.c_str());

        // 设置请求头
        struct curl_slist* headers = NULL;
        headers = curl_slist_append(headers, "User-Agent: Mozilla/5.0");
        headers = curl_slist_append(headers, "Accept: application/json");
        headers = curl_slist_append(headers, "apiKey: yourApikey");
        curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);

        // 存储响应结果
        std::string response_string;
        curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, WriteCallback);
        curl_easy_setopt(curl, CURLOPT_WRITEDATA, &response_string);

        // 发送 GET 请求
        res = curl_easy_perform(curl);

        if (res != CURLE_OK) {
            std::cerr << "Curl request failed: " << curl_easy_strerror(res) << std::endl;
        } else {
            // 输出 HTTP 状态码
            long http_code = 0;
            curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &http_code);
            std::cout << "HTTP code: " << http_code << std::endl;
            std::cout << "Message: " << response_string << std::endl;
        }

        // 清理请求头
        curl_slist_free_all(headers);
        curl_easy_cleanup(curl);
    }

    // 清理 libcurl
    curl_global_cleanup();

    return 0;
}

三、返回示例

{
  "ret": 200,
  "msg": "success",
  "traceId": "43fe7163-abb2-4a59-b6b2-2af4dc8c4141",
  "data": [
    {
      "s": "XAUUSD",
      "respList": [
        {
          "t": "1750177320",
          "h": "1950.07400",
          "o": "1949.17600",
          "l": "1948.17600",
          "c": "1950.07400",
          "v": "15.0",
          "vw": "1950.7220",
          "pc": "0.12%",
          "pca": "2.78600"
        },
        {
          "t": "1750177260",
          "h": "1949.41400",
          "o": "1948.28800",
          "l": "1948.28800",
          "c": "1949.41400",
          "v": "10.0",
          "vw": "1949.1220",
          "pc": "0.03%",
          "pca": "0.52400"
        }
      ]
    },
    {
      "s": "XAGUSD",
      "respList": [
        {
          "t": "1750177320",
          "h": "25.07400",
          "o": "25.17600",
          "l": "25.17600",
          "c": "25.07400",
          "v": "30.0",
          "vw": "25.7220",
          "pc": "0.10%",
          "pca": "0.78600"
        },
        {
          "t": "1750177260",
          "h": "25.01400",
          "o": "25.04800",
          "l": "25.04800",
          "c": "25.01400",
          "v": "20.0",
          "vw": "25.3220",
          "pc": "0.02%",
          "pca": "0.52400"
        }
      ]
    }
  ]
}

字段说明：

返回的字段包含周期内的高开低收数据，比如我们查询的是1分钟K线，那么返回的数据就是1分钟内的高开低收。
| 字段名 | 类型 | 必填 | 描述 | 示例值 |
|--------|--------|------|----------|----------------|
| t | String | 是 | 成交时间 | 1747382898892 |
| h | String | 是 | 最高价 | 18.01 |
| o | String | 是 | 开盘价 | 18.01 |
| l | String | 是 | 最低价 | 18.01 |
| c | String | 是 | 收盘价 | 18.01 |
| v | String | 是 | 成交量 | 18000 |
| vm | String | 是 | 成交额 | 20000 |
| pc | String | 是 | 涨跌幅 | 0.12% |
| pca | String | 是 | 涨跌额 | 0.11 |

常见问题

1. 如何优化 libcurl 请求以处理高频 K 线数据（如 1 分钟 K 线）在高并发场景下的性能？

在高频 K 线数据请求场景下，建议以下优化措施：

连接复用：使用 curl_easy_init() 和 curl_easy_cleanup() 创建的 CURL 句柄可以通过设置 CURLOPT_TCP_KEEPALIVE 和 CURLOPT_KEEPALIVE 启用 TCP 连接复用，减少每次请求的连接建立开销。
示例代码：

curl_easy_setopt(curl, CURLOPT_TCP_KEEPALIVE, 1L);
curl_easy_setopt(curl, CURLOPT_KEEPALIVE_TIME, 60L);

异步请求：对于高并发场景，建议使用 libcurl 的多接口（multi interface）结合 curl_multi_perform 实现异步请求，允许多个请求并行处理。

批量请求：将多个资产代码（如 XAUUSD、XAGUSD）合并到单次请求中，减少 API 调用次数，降低服务器压力。

错误重试机制：实现指数退避重试策略，处理因网络波动或 API 限频导致的失败（如 HTTP 429 错误）。可以使用 curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &http_code) 检查状态码并设置重试逻辑。

2. API 返回的成交时间（t）字段是 Unix 时间戳，如何确保时间戳与本地时区的同步？

API 返回的 t 字段为 Unix 时间戳（秒或毫秒，需参考文档确认）。为确保与本地时区同步：

确认时间戳单位：如果 t 是毫秒（如 1747382898892），需除以 1000 转换为秒。

使用 C++ 的 chrono 库或 gmtime/localtime 函数将时间戳转换为本地时间。例如：

#include <chrono>
#include <iomanip>
#include <sstream>

std::string timestampToLocalTime(const std::string& timestamp) {
    auto ts = std::stoll(timestamp) / 1000; // 假设毫秒
    auto time = std::chrono::system_clock::from_time_t(ts);
    auto local_time = std::chrono::system_clock::to_time_t(time);
    std::stringstream ss;
    ss << std::put_time(std::localtime(&local_time), "%Y-%m-%d %H:%M:%S");
    return ss.str();
}

3. 如何处理 API 返回数据中可能出现的缺失 K 线（如非交易时段的空数据）？

贵金属市场（如 XAUUSD）在周末或节假日可能存在非交易时段，导致 K 线数据缺失。处理方式包括：

预检查时间范围：在请求前，排除非交易时段（如周六、周日或特定市场假期）。可通过查询 API 文档或历史数据确定交易时间窗口。

数据补全逻辑：对于缺失的 K 线，可用前一根 K 线的收盘价c补全缺失数据的 o、h、l、c 字段，设置成交量 v 为 0。示例：

if (kline_data.empty()) {
    // 假设 last_kline 是前一根 K 线数据
    kline_data.o = last_kline.c;
    kline_data.h = last_kline.c;
    kline_data.l = last_kline.c;
    kline_data.c = last_kline.c;
    kline_data.v = "0";
}

WebSocket 订阅：相比 HTTP 轮询，WebSocket 可实时检测市场状态变化，减少对空数据的处理需求。参考 Infoway API 官网的 WebSocket 文档。

4. 如何在多线程环境中安全地复用 libcurl 句柄以提高吞吐量？

libcurl 本身是线程安全的，但需注意以下事项：

每个线程独立句柄：为每个线程创建独立的 CURL* 句柄，避免共享同一句柄导致竞争条件。不要在多线程间共享 curl_easy_init() 返回的句柄。

全局初始化线程安全：调用 curl_global_init(CURL_GLOBAL_ALL) 时确保只调用一次，通常在程序启动时完成，且使用互斥锁保护：

#include <mutex>
static std::once_flag curl_init_flag;
std::call_once(curl_init_flag, []() { curl_global_init(CURL_GLOBAL_ALL); });

连接池管理：使用 libcurl 的 curl_share_init创建共享对象，共享 DNS 缓存、连接池等资源，减少开销。示例：

CURLSH* share = curl_share_init();
curl_share_setopt(share, CURLSHOPT_SHARE, CURL_LOCK_DATA_DNS);
curl_easy_setopt(curl, CURLOPT_SHARE, share);

清理资源：确保每个线程在完成请求后调用 curl_easy_cleanup，程序退出时调用 curl_global_cleanup。

5. API 返回的成交量（v）和成交额（vm）字段如何用于计算市场活跃度？

成交量v和成交额vm可用于分析市场活跃度和流动性：

成交量加权价格（VWAP）：通过 vw 字段（成交量加权平均价）直接获取周期内的 VWAP，或手动计算：VWAP = vm / v。VWAP 可用于评估市场价格趋势的稳定性。

活跃度指标：比较多周期的成交量（如 1 分钟 vs. 5 分钟 K 线），若短周期成交量激增，可能表示市场短期活跃或突发事件。

异常检测：设置阈值（如 v 超过历史均值的 2 倍标准差），检测异常交易活动。示例：

double calculateActivity(const std::string& volume, double avg_volume, double stddev_volume) {
    double v = std::stod(volume);
    return (v - avg_volume) / stddev_volume; // Z 分数
}

6. 如何通过 WebSocket 订阅降低延迟并处理断线重连？

WebSocket 订阅可显著降低数据获取延迟，适合实时交易场景：

订阅实现：参考 API 官网 WebSocket 文档，使用库如 libwebsocket 或 cpprestsdk 建立连接，订阅特定资产和 K 线类型（如 wss://data.infoway.io/ws/kline/1/XAUUSD）。

断线重连：实现心跳机制（如每 30 秒发送 PING 消息），检测连接状态。若断线，设置指数退避重试（初始 1 秒，最大 60 秒）。示例：

void reconnectWebSocket() {
    int retry_delay = 1;
    while (!connect()) {
        std::this_thread::sleep_for(std::chrono::seconds(retry_delay));
        retry_delay = std::min(retry_delay * 2, 60); // 指数退避
    }
}

数据一致性：断线后重新订阅时，需通过 HTTP API 拉取断线期间的 K 线数据，合并到本地数据流，确保数据连续性。

更多详细接入步骤，可以参考官方文档，或者Github。

Go 如何接入实时外汇行情 API

PeakLine — Mon, 07 Jul 2025 07:34:19 +0000

外汇行情接口是比较小众的工具，在网络上的教程并不多，这部分是因为外汇并不是一个统一的大市场，它的报价会比较分散，要聚合这些报价是比较困难的，市面上的实时外汇行情API也不常见。如果你在用 Go 写交易系统、监控工具或市场数据采集模块，很可能会遇到通过 WebSocket 实时获取外汇行情的需求。下面是一份实用的接入教程，使用的是infoway.io提供的实时行情 API。本文以 EURUSD 的 1 分钟 K 线为例。

第一步：准备工作

确保你已安装 Go 环境，并获取了 API Key（可在官网免费申请）。

安装 WebSocket 客户端库：

go get nhooyr.io/websocket

我们使用的是 nhooyr.io/websocket，它轻量、现代、支持上下文控制。

第二步：建立连接

WebSocket 地址如下：

wss://data.infoway.io/ws?business=forex&apikey=YourAPIKey

你需要在地址中替换为你自己的 API key。

连接代码：

conn, _, err := websocket.Dial(ctx, url, nil)
if err != nil {
    log.Fatalf("WebSocket连接失败: %v", err)
}
defer conn.Close(websocket.StatusNormalClosure, "关闭连接")

第三步：发送订阅消息

你需要发送一条初始化消息，告诉服务器你要订阅哪个品种、哪种周期的 K 线。例如，订阅 EURUSD 的 1 分钟 K 线：

initMsg := map[string]interface{}{
    "code":  10004,
    "trace": "your-trace-id", // 可使用uuid
    "data": map[string]interface{}{
        "arr": []map[string]interface{}{
            {
                "type":  1,
                "codes": "EURUSD",
            },
        },
    },
}
msgBytes, _ := json.Marshal(initMsg)
conn.Write(ctx, websocket.MessageText, msgBytes)

第四步：设置心跳 Ping

WebSocket 连接需要保持活跃状态，推荐每 30 秒发送一次 ping：

go func() {
    ticker := time.NewTicker(30 * time.Second)
    defer ticker.Stop()
    for range ticker.C {
        pingMsg := map[string]interface{}{
            "code":  10010,
            "trace": "your-trace-id",
        }
        pingBytes, _ := json.Marshal(pingMsg)
        conn.Write(ctx, websocket.MessageText, pingBytes)
    }
}()

第五步：接收行情数据

WebSocket 会持续推送行情数据。你只需监听并处理消息：

for {
    _, msg, err := conn.Read(ctx)
    if err != nil {
        log.Printf("读取消息失败: %v", err)
        break
    }
    fmt.Printf("收到消息: %s\n", string(msg))
}

返回示例

收到的 JSON 格式数据包含开盘价、最高价、最低价、收盘价、时间戳等字段:

{
    "c": "1.0845",         // 当前价格（收盘价）
    "h": "1.0852",         // 该分钟内的最高价
    "l": "1.0839",         // 该分钟内的最低价
    "o": "1.0840",         // 开盘价
    "pca": "0.0005",       // 价格变化
    "pfr": "0.05%",        // 价格变化百分比
    "s": "EURUSD",         // 外汇货币对代码
    "t": 1747550648097,    // 时间戳（毫秒）
    "ty": 1,               // K线类型：1 表示1分钟K线
    "v": "2.4",            // 成交量（在外汇中通常是报价量或模拟值）
    "vw": "1.0843"         // 加权平均价格
}

常见问题

连接失败：检查 API key 是否正确，网络是否支持 WebSocket。

收不到数据：确认订阅的品种代码无误，例如 EURUSD，并确保服务器返回了确认消息。

连接断开：可能是长时间无 Ping 消息，确保 Ping 机制正确运行。

利用Infoway API接入实时股票行情API的方法

PeakLine — Wed, 02 Jul 2025 07:13:33 +0000

随着金融科技的发展，越来越多的投资者、交易平台和量化交易团队开始使用股票行情API来获取市场数据。然而，很多人虽然听说过行情API，却并不清楚不同类型的接口之间有何区别，适合用于哪些场景。本文将系统地介绍几种常见的股票行情接口，帮助您建立对行情API的全面理解。

一、延迟行情接口：主流平台的默认选择

延迟行情（Delayed Market Data）是最普遍、成本最低的行情接口形式。其核心特征是存在时间延迟，通常为15分钟。这意味着，当你在查看一只股票的价格时，实际成交可能已经发生在15分钟前。

这种数据类型广泛应用于：

投资者教育平台
免费的行情展示网站
证券公司App的普通行情模块（如雪球、同花顺等）

延迟行情对普通散户投资者来说已经足够使用，但对于需要及时决策的量化交易者、套利系统或高频交易场景来说，这类数据明显滞后，不具备实战价值。

二、实时行情接口：交易系统的核心基础

实时行情接口（Real-Time Market Data API）是专业交易系统必不可少的组成部分。该接口可以提供毫秒级更新的市场数据，涵盖以下常见字段：

实时价格（Last Price）
实时成交量（Volume）
涨跌幅、涨跌额
委买委卖盘数据（可选）

实时数据的价值主要体现在：

量化交易与高频交易：策略对数据延迟极其敏感，实时性直接影响盈利能力。
自动化交易系统：用于触发买卖信号，实现毫秒级下单。
智能投顾与算法模型：模型需要即时反馈市场变化做出响应。

值得注意的是，实时行情往往涉及更高的数据费用和技术门槛，需要考虑数据许可和合规问题。

三、历史行情接口：回测与策略开发的必备工具

历史行情接口（Historical Market Data API）用于获取某一资产过去特定时间段内的市场表现。典型的数据字段包括：

开盘价（Open）
收盘价（Close）
最高价（High）
最低价（Low）
成交量（Volume）
调整收盘价（Adjusted Close）

主要应用场景包括：

策略回测：验证某一量化策略在过去市场中的表现。
技术分析：构建技术指标，如MACD、RSI、均线等。
因子研究：提取基本面、情绪面或技术因子进行选股模型开发。

高质量的历史数据是构建稳健交易系统的基础，其准确性与完整性尤为重要。

四、实时聚合行情接口：跨市场、多资产的一体化数据服务

在更专业的应用场景中，实时聚合行情接口（Real-Time Aggregated Market Data API）应运而生。该类接口不仅提供单一市场的实时数据，更支持跨资产类型、跨市场的一站式数据获取。

主要特征包括：

多市场支持：股票、外汇、期货、加密资产等
多品种聚合：统一接口获取多个标的
深度数据整合：Level 2订单簿、逐笔成交（Tick-by-Tick）

应用场景主要包括：

跨市场套利策略：需要同时获取多个市场的价格数据进行比较与交易。
全球量化交易平台：在一个策略框架中集成多个国家的金融市场。
终端资讯系统：为投资者提供全资产数据聚合视图。

实时聚合接口是机构级客户的首选，但同时也对数据处理能力、网络性能和授权合规提出更高要求。

五、代码示例

下面我们展示的是实时聚合行情接口Infoway API的调用示例，使用前请在官网申请免费的API Key。

HTTP请求

import requests

api_url = 'https://data.infoway.io/stock/batch_kline/1/10/002594.SZ%2C00285.HK%2CTSLA.US'

# 设置请求头
# 需在官网申请免费API Key: www.infoway.io
headers = {
    'User-Agent': 'Mozilla/5.0',
    'Accept': 'application/json',
    'apiKey': 'yourApikey'
}

# 发送GET请求
response = requests.get(api_url, headers=headers)

# 输出结果
print(f"HTTP code: {response.status_code}")
print(f"message: {response.text}")

WebSocket

import asyncio
import json
import websockets

# 美股行情的websocket订阅地址
WS_URL = "wss://data.infoway.io/ws?business=stock&apikey=yourApiKey"

# 请先在官网https://infoway.io 申请免费API key

async def connect_and_receive():
    async with websockets.connect(WS_URL) as websocket:
        # 发送初始化消息，这里订阅的是苹果股票的1分钟K线数据
        init_message = {
            "code": 10004,  # K线请求协议号
            "trace": "423afec425004bd8a5e02e1ba5f9b2b0",  # 可追溯ID（随机字符串）
            "data": {
                "arr": [
                    {
                        "type": 1,  # 1分钟K线
                        "codes": "AAPL"  # 订阅的股票代码
                    }
                ]
            }
        }
        await websocket.send(json.dumps(init_message))

        # 设置ping任务
        async def send_ping():
            while True:
                await asyncio.sleep(30)
                ping_message = {
                    "code": 10010,
                    "trace": "423afec425004bd8a5e02e1ba5f9b2b0"
                }
                await websocket.send(json.dumps(ping_message))

        # 启动ping任务协程
        ping_task = asyncio.create_task(send_ping())

        try:
            # 持续接收消息
            while True:
                message = await websocket.recv()
                print(f"Message received: {message}")
        except websockets.exceptions.ConnectionClosedOK:
            print("Connection closed normally")
        finally:
            # 取消ping任务
            ping_task.cancel()

# 运行主函数
asyncio.run(connect_and_receive())

返回示例

{
    "c": "150.00",         // 当前价格
    "h": "150.20",         // 最高价
    "l": "149.80",         // 最低价
    "o": "149.90",         // 开盘价
    "pca": "0.00",         // 价格变化
    "pfr": "0.00%",        // 价格变化百分比
    "s": "AAPL",           // 股票代码
    "t": 1747550648097,    // 时间戳
    "ty": 1,               // K线类型：1 表示1分钟K线
    "v": "0.34716",        // 交易量
    "vw": "35923.5149678"  // 加权平均价格
}

股票API怎么选 - 2025最新推荐

PeakLine — Mon, 30 Jun 2025 06:22:19 +0000

股票行情API是金融科技领域常见的应用之一，但今天介绍的是实时数据接口，它和普通的行情接口的区别主要在于数据的实时性，基本搞量化交易的都会用到。我们对国内外比较知名的实时接口做了详细的对比测评，可以直接看以下结果：

1、Alpha Vantage

Alpha Vantage是YCombinator孵化的项目，在国外量化圈的知名度比较高，它支持多个市场，包括股票、指数、外汇和加密货币等。缺点是只支持HTTP，没有WebSocket订阅。

价格：149.99美金/月，无HTTP请求次数限制

2、Infoway

Infoway API提供了港股、美股、A股、外汇、期货、加密货币的实时报价与历史数据拉取，它的优点是有免费套餐，而且同时支持HTTP和Websocket，个人和企业都能用。详情请查看Infoway API官网

3、Yahoo Finance API

老牌的股票行情API，数据齐全，但延时非常高。

价格：35美金/月，每个月15万次HTTP请求（没有WS订阅）

4、IEX Cloud

IEX Cloud是一个专注于美国市场的股票行情API，提供HTTP+Websock订阅，但价格太贵。

价格：1500美金/月，不包含历史数据，历史数据要加200刀。

6、Xignite

Xignite是面向B端的产品，它的优点是数据覆盖面广，提供了全球范围内的资产类别，包括股票、债券、期货、外汇等都有。但如果没有美国公司主体是无法申请的。

价格：$12000/年，包含一年的历史数据，5年数据$17000/年。注意是美金，价格很贵。

7、Intrinio

Intrinio也是面向企业客户的，个人或者没有资质无法申请，而且只有纳斯达克的数据，所以比Xignite要便宜。

价格：美股实时数据$2100/年，不包含历史数据。高频数据接口$6000刀一年。

股票API接口如何选？

首先看你的查询方法，获取实时行情可以通过HTTP请求或者WS订阅。这两者的主要区别是频次和延迟。HTTP的请求频次是有限制的，延时会高一点，适合用来拉取一些历史数据、日K线等，而WS是长连接，只要连接没有断开（你可以向服务端发送心跳保持连接），行情价格有更新会直接推送过来，适合用来做实盘交易。而我们上面提到的产品中，并不是每家都支持websocket。所以挑选行情API时最好搞清楚你需要使用哪种查询方式，如果不确定，那无脑选择两种都支持的。

【推荐阅读】Java接入实时外汇行情API - 原创教程

要注意请求频率

此外，也要看你的请求频率，各家的接口一般都会对查询频率做限制，否则服务器会绷不住。比如HTTP请求，一般会限制一分钟60次，也就是理论上来说一秒可以查一次，但是有些服务商会对每天的请求数量做个上限，比如Alpha Vantage，一天是10万次请求就封顶了。如果你请求得比较频繁，建议选择限制比较宽松的，比如Infoway API，最高能一分钟1200次请求，不设每日上限。

对于WebSocket连接，各家的限制也不一样，一般是限制一个连接能订阅的股票数量，比如IEX Cloud只运行一个WS查询10个股票，Infoway API根据套餐不同可支持50-500个。

代码示例

下面给出HTTP和WS订阅的代码示例，供各位参考。

HTTP请求

import requests

api_url = 'https://data.infoway.io/stock/batch_kline/1/10/002594.SZ%2C00285.HK%2CTSLA.US'

# 请先在官网申请免费Token: https://infoway.io
# 详细对接文档：https://docs.infoway.io

# 设置请求头
headers = {
    'User-Agent': 'Mozilla/5.0',
    'Accept': 'application/json',
    'apiKey': 'yourApikey'
}

# 发送GET请求
response = requests.get(api_url, headers=headers)

# 输出结果
print(f"HTTP code: {response.status_code}")
print(f"message: {response.text}")

Websocket

import asyncio
import json
import websockets

WS_URL = "wss://data.infoway.io/ws?business=crypto&apikey=yourApikey"

# 请先在官网申请免费Token: https://infoway.io
# 详细对接文档：https://docs.infoway.io

async def connect_and_receive():
    async with websockets.connect(WS_URL) as websocket:
        # 发送初始消息
        init_message = {
            "code": 10000,
            "trace": "01213e9d-90a0-426e-a380-ebed633cba7a",
            "data": {"codes": "BTCUSDT"}
        }
        await websocket.send(json.dumps(init_message))

        # 设置ping任务
        async def send_ping():
            while True:
                await asyncio.sleep(30)
                ping_message = {
                    "code": 10010,
                    "trace": "01213e9d-90a0-426e-a380-ebed633cba7a"
                }
                await websocket.send(json.dumps(ping_message))

        # 启动ping任务协程
        ping_task = asyncio.create_task(send_ping())

        try:
            # 持续接收消息
            while True:
                message = await websocket.recv()
                print(f"Message received: {message}")
        except websockets.exceptions.ConnectionClosedOK:
            print("Connection closed normally")
        finally:
            # 取消ping任务
            ping_task.cancel()

# 运行主函数
asyncio.run(connect_and_receive())

常见问题

是否有完全免费的接口？

如果是延时接口，是有免费的，比如雅虎的yfinance，数据量比较全面，但是行情数据并非实时，一般存在5-10分钟的延迟。如果是做量化研究，yfinance完全可以满足要求。而实盘交易，或者是交易所，则不建议使用免费的接口。商用的实时接口一般有提供免费试用，可以先从试用开始。

个人是否能开商用接口？

个人使用的话建议避开Xignite和Intrinio，这两个都只服务企业客户，个人是无法通过他们的审核的。如果不想走麻烦的审核流程，可以选择Infoway API，也能商用，无需审核。

有没有能查询多个市场的接口？

Infoway API可以查询多个市场，包含A股，港股，美股，外汇，加密货币，商品期货等。一个接口就能查询多个市场。具体教程可以看这篇文章。

DEV Community: PeakLine

(实时)贵金属行情接口 详细接入指南【2025最新教程】

一、API请求地址

二、代码示例

三、返回示例

字段说明：

常见问题

1. 如何优化 libcurl 请求以处理高频 K 线数据（如 1 分钟 K 线）在高并发场景下的性能？

2. API 返回的成交时间（t）字段是 Unix 时间戳，如何确保时间戳与本地时区的同步？

3. 如何处理 API 返回数据中可能出现的缺失 K 线（如非交易时段的空数据）？

4. 如何在多线程环境中安全地复用 libcurl 句柄以提高吞吐量？

5. API 返回的成交量（v）和成交额（vm）字段如何用于计算市场活跃度？

6. 如何通过 WebSocket 订阅降低延迟并处理断线重连？

Go 如何接入实时外汇行情 API

第一步：准备工作

第二步：建立连接

第三步：发送订阅消息

第四步：设置心跳 Ping

第五步：接收行情数据

返回示例

常见问题

利用Infoway API接入实时股票行情API的方法

一、延迟行情接口：主流平台的默认选择

二、实时行情接口：交易系统的核心基础

三、历史行情接口：回测与策略开发的必备工具

四、实时聚合行情接口：跨市场、多资产的一体化数据服务

五、代码示例

HTTP请求

WebSocket

返回示例

股票API怎么选 - 2025最新推荐

1、Alpha Vantage

2、Infoway

3、Yahoo Finance API

4、IEX Cloud

6、Xignite

7、Intrinio

股票API接口如何选？

要注意请求频率

代码示例

HTTP请求

Websocket

常见问题

是否有完全免费的接口？

个人是否能开商用接口？

有没有能查询多个市场的接口？

(实时)贵金属行情接口详细接入指南【2025最新教程】