告别数据困扰：2025外汇期货实时行情数据接入全指南

# 安装依赖：pip install requests
import requests

# 配置参数
token = "your_token_here"  # 替换为你的实际token
url = "https://api.itick.org/future/tick?region=US&code=NQ"
headers = {
    "token": token
}

try:
    # 发送请求
    response = requests.get(url, headers=headers, timeout=1)
    response.raise_for_status()  # 触发HTTP错误
    # 解析响应
    result = response.json()
    if result["code"] == 0:
        data = result["data"]
        print(f"品种：{data['s']}")
        print(f"最新价格：{data['ld']}")
        print(f"数据时间：{data['t']}")  # 可转换为datetime：datetime.fromtimestamp(data['t']/1000)
        print(f"成交量：{data['v']}")
    else:
        print(f"请求失败：{result['msg']}")
except Exception as e:
    print(f"接口调用异常：{str(e)}")

// Node.js环境需先安装node-fetch：npm install node-fetch
const fetch = typeof window !== 'undefined' ? window.fetch : require('node-fetch');

// 配置参数
const token = "your_token_here"; // 替换为你的实际token
const url = "https://api.itick.org/future/tick?region=US&code=NQ";

async function getFutureTick() {
    try {
        const response = await fetch(url, {
            method: 'GET',
            headers: {
                "token": token
            }
        });
        if (!response.ok) {
            throw new Error(`HTTP错误：${response.status}`);
        }
        const result = await response.json();
        if (result.code === 0) {
            const data = result.data;
            console.log(`品种：${data.s}`);
            console.log(`最新价格：${data.ld}`);
            console.log(`数据时间：${new Date(data.t)})`);
            console.log(`成交量：${data.v}`);
        } else {
            console.log(`请求失败：${result.msg}`);
        }
    } catch (e) {
        console.log(`接口调用异常：${e.message}`);
    }
}

// 执行请求
getFutureTick();

{
  "code": 0,  // 状态码，0表示请求成功，非0可参考文档查询错误原因
  "msg": null,  // 错误信息，成功时为null
  "data": {
    "s": "EURUSD",  // 交易品种代码
    "ld": 1.16429,  // 最新报价
    "t": 1754583901037,  // 数据生成时间戳（毫秒级）
    "v": 1.8  // 成交量（对应品种单位）
  }
}

import requests
import datetime

token = "your_token_here"
url = "https://api.itick.org/future/klines"
# 构造请求参数
params = {
    "region": "US",
    "codes": "NQ,ES",
    "kType": 2,  # 1小时K线
    "limit": 5   # 最近5条数据
}
headers = {
    "token": token
}

try:
    response = requests.get(url, params=params, headers=headers, timeout=2)
    response.raise_for_status()
    result = response.json()
    if result["code"] == 0:
        # 按品种遍历K线数据
        for symbol, kline_list in result["data"].items():
            print(f"\n品种：{symbol}")
            print("时间\t\t开盘价\t最高价\t最低价\t收盘价\t成交量")
            for kline in kline_list:
                # 转换时间戳为可读格式
                kline_time = datetime.datetime.fromtimestamp(kline["t"]/1000).strftime("%Y-%m-%d %H:%M")
                print(f"{kline_time}\t{kline['o']}\t{kline['h']}\t{kline['l']}\t{kline['c']}\t{kline['v']}")
    else:
        print(f"请求失败：{result['msg']}")
except Exception as e:
    print(f"异常：{str(e)}")

{
  "code": 0,
  "msg": null,
  "data": {
    "ES": [
      {
        "tu": 12135305.25,  // 成交总额
        "c": 6381.25,  // 收盘价
        "t": 1754656800000,  // K线结束时间戳
        "v": 1902,  // 成交量
        "h": 6382.25,  // 最高价
        "l": 6377.75,  // 最低价
        "o": 6379.25  // 开盘价
      }
    ],
    "NQ": [
      {
        "tu": 31835798.75,
        "c": 23535,
        "t": 1754656800000,
        "v": 1353,
        "h": 23539.25,
        "l": 23518.5,
        "o": 23527.5
      }
    ]
  }
}

# 安装依赖：pip install websockets
import asyncio
import websockets
import json

token = "your_token_here"
# 期货WebSocket连接地址
ws_url = "wss://api.itick.org/future"

async def subscribe_future_data():
    async with websockets.connect(ws_url, extra_headers={"token": token}}) as websocket:
        # 发送订阅指令：订阅美国区域NQ、ES品种
        subscribe_msg = {
            "action": "subscribe",
            "params":"NQ$US,ES$US"
            "type": "tick,quote"
        }
        await websocket.send(json.dumps(subscribe_msg))
        print("订阅指令已发送，等待接收数据...")

        # 持续接收推送数据
        while True:
            response = await websocket.recv()
            data = json.loads(response)
            if data["code"] == 0:
                print(f"实时推送：{data['data']}")
            else:
                print(f"推送错误：{data['msg']}")

# 启动WebSocket客户端
if __name__ == "__main__":
    try:
        asyncio.run(subscribe_future_data())
    except KeyboardInterrupt:
        print("连接已中断")