如何接入美股行情API（2025最新教程）

​美股行情API产品存在几种不同的类型，每种接口都有其特定的功能和用途：

延迟行情接口：顾名思义，行情数据存在延迟，一般是15分钟，也就是说你看到的成交价格是发生在15分钟之前的。这种是最常见的接口，比如你在雪球，证券交易app中看到的行情价格都是存在延迟的。

实时行情接口：这种接口提供即时更新的股票行情数据，包括股票的实时价格、成交量、涨跌幅等信息。一般做量化交易的对延迟会比较敏感，这就需要用到实时行情接口。

历史行情接口：历史行情接口提供过去某段时间内的股票行情数据，包括开盘价、收盘价、最高价、最低价等信息。这种接口对于进行技术分析和制定投资策略非常有用。

在当今全球化的金融市场中，美股行情API已经成为许多应用的重要组成部分。通过接入美股行情API，用户能够获取实时、准确的市场数据，从而在各类场景中获得竞争优势。例如，量化交易团队利用美股行情API来开发和优化交易策略，以确保决策基于最新的市场动态。个人投资者和金融分析师则可通过这些数据进行深度的市场分析和趋势预测。此外，投资应用和财经新闻平台也需要实时的行情数据来为用户提供及时的市场信息，提升用户体验和信任度。无论是机构投资还是个人交易者，美股行情API都为他们提供了关键的市场洞察力，使他们能够在瞬息万变的市场中做出更明智的决策。

HTTP请求示例

代码语言：txt复制

import requests

api_url = '.SZ%2C00285.HK%2CTSLA.US'

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

# 申请免费API Key：

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

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

港股和美股都可以，把股票代码带入参数即可。

Websocket查询美股K线

代码语言：txt复制

import asyncio
import json
import websockets

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

# 请先在官网 申请免费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())

返回示例

代码语言：txt复制

{
    "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"  // 加权平均价格
}

查询盘口数据

代码语言：txt复制

import asyncio
import json
import websockets

WS_URL = "wss://data.infoway.io/ws?business=stock&apikey=yourApiKey"

# 请先在官网 申请免费API key

async def connect_and_receive():
    async with websockets.connect(WS_URL) as websocket:
        # 发送初始化消息，订阅的是苹果股票的盘口数据
        init_message = {
            "code": 10002,  # 盘口订阅的请求协议号
            "trace": "423afec425004bd8a5e02e1ba5f9b2b0",  # 可追溯ID（随机字符串）
            "data": {
                "codes": "AAPL"  # 订阅的股票代码，这里是苹果股票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())

返回示例

代码语言：txt复制

{
    "a": [
        [
            "150.00",    // 卖盘价格1
            "150.10",    // 卖盘价格2
            "150.20",    // 卖盘价格3
            "150.30",    // 卖盘价格4
            "150.40"     // 卖盘价格5
        ],
        [
            "10.0000",   // 卖盘数量1
            "5.0000",    // 卖盘数量2
            "3.0000",    // 卖盘数量3
            "1.0000",    // 卖盘数量4
            "2.0000"     // 卖盘数量5
        ]
    ],
    "b": [
        [
            "149.90",    // 买盘价格1
            "149.80",    // 买盘价格2
            "149.70",    // 买盘价格3
            "149.60",    // 买盘价格4
            "149.50"     // 买盘价格5
        ],
        [
            "8.0000",    // 买盘数量1
            "4.0000",    // 买盘数量2
            "2.5000",    // 买盘数量3
            "1.5000",    // 买盘数量4
            "3.0000"     // 买盘数量5
        ]
    ],
    "s": "AAPL",           // 股票代码
    "t": 1747553102161     // 时间戳
}