技术实战：使用API对接东京证券交易所数据

原创

用户11961746

发布于 2026-03-20 18:29:18

1120

技术实战：使用API对接东京证券交易所数据

随着日本股市在全球投资组合中的重要性日益提升，特别是日经225指数近年来的强势表现，越来越多的开发者需要对接东京证券交易所（TSE）的数据。本文将详细介绍如何通过现代化的金融数据API，快速、稳定地接入日本股票市场数据。

一、日本市场概览

东京证券交易所是全球第三大股票市场，拥有丰田、索尼、软银等众多全球知名企业。日本股市的交易时间为东京时间上午9:00-11:30，下午12:30-15:00，主要指数包括日经225指数（Nikkei 225）和东证股价指数（TOPIX）。

二、准备工作

1. 获取API密钥

首先需要获取访问权限，可以通过申请API密钥。

2. 基础配置

日本市场在系统中的国家ID为35，这是对接日本数据的关键参数。

import requests
import pandas as pd

API_KEY = "your_api_key_here"
BASE_URL = "https://api.stocktv.top"
JAPAN_COUNTRY_ID = 35  # 日本市场专有ID

三、核心接口详解

1. 获取日本股票列表

通过指定countryId=35，可以获取日本交易所的全部股票清单。

def get_japan_stocks(page=1, page_size=20):
    """获取日本股票列表"""
    url = f"{BASE_URL}/stock/stocks"
    params = {
        "countryId": JAPAN_COUNTRY_ID,
        "pageSize": page_size,
        "page": page,
        "key": API_KEY
    }
    
    response = requests.get(url, params=params)
    result = response.json()
    
    if result.get("code") == 200:
        stocks = result["data"]["records"]
        df = pd.DataFrame(stocks)
        return df
    else:
        print("请求失败:", result.get("message"))
        return None

# 获取前20只日本股票
japan_stocks = get_japan_stocks()
print(japan_stocks[['symbol', 'name', 'last', 'chgPct']].head())

接口返回的数据包含股票的唯一产品ID（PID）、代码、名称、最新价、涨跌幅等关键信息。

2. 查询特定股票实时行情

如果已知股票代码（如丰田汽车的7203），可以直接查询实时行情。

def get_stock_realtime(symbol):
    """获取特定股票实时行情"""
    url = f"{BASE_URL}/stock/queryStocks"
    params = {
        "symbol": symbol,
        "key": API_KEY
    }
    
    response = requests.get(url, params=params)
    result = response.json()
    
    if result.get("code") == 200:
        data = result["data"][0]
        print(f"股票: {data['name']} ({data['symbol']})")
        print(f"最新价: {data['last']}")
        print(f"涨跌幅: {data['chgPct']}%")
        return data
    else:
        print("请求失败:", result.get("message"))
        return None

# 查询丰田汽车(7203)
toyota_data = get_stock_realtime("7203")

3. 获取K线数据

支持从1分钟到月线的多种时间维度，满足不同分析需求。

def get_kline_data(pid, interval="P1D", limit=100):
    """获取K线数据"""
    url = f"{BASE_URL}/stock/kline"
    params = {
        "pid": pid,  # 股票的唯一标识
        "interval": interval,  # K线周期
        "key": API_KEY
    }
    
    response = requests.get(url, params=params)
    result = response.json()
    
    if result.get("code") == 200:
        kline_data = result["data"]
        df = pd.DataFrame(kline_data)
        
        # 转换时间戳为datetime
        df['datetime'] = pd.to_datetime(df['time'], unit='ms')
        df.set_index('datetime', inplace=True)
        
        return df[['open', 'high', 'low', 'close', 'volume']]
    else:
        print("请求失败:", result.get("message"))
        return None

# 周期参数说明：
# PT1M (1分钟), PT5M (5分钟), PT15M (15分钟)
# PT1H (1小时), P1D (日K), P1W (周K), P1M (月K)

4. 获取日本大盘指数

监控日本市场离不开日经225和TOPIX指数。

def get_japan_indices():
    """获取日本指数数据"""
    url = f"{BASE_URL}/stock/indices"
    params = {
        "countryId": JAPAN_COUNTRY_ID,
        "key": API_KEY
    }
    
    response = requests.get(url, params=params)
    result = response.json()
    
    if result.get("code") == 200:
        indices = result["data"]
        for index in indices:
            print(f"{index['name']}: {index['last']} ({index['chgPct']}%)")
        return indices
    else:
        print("请求失败:", result.get("message"))
        return None

四、WebSocket实时推送

对于需要实时价格变动的应用场景，建议使用WebSocket连接。

const wsUri = "wss://ws-api.stocktv.top/connect?key=YOUR_API_KEY";
const websocket = new WebSocket(wsUri);

// 订阅日本股票
websocket.onopen = function() {
    websocket.send(JSON.stringify({
        action: "subscribe",
        pids: ["8316", "6758", "9430"]  // 丰田、索尼、日经225指数
    }));
};

// 接收实时数据
websocket.onmessage = function(event) {
    const data = JSON.parse(event.data);
    console.log("实时行情:", data);
};

WebSocket推送的数据格式包含最新价、买一卖一价、成交量等关键信息。

五、高级功能

1. IPO新股日历

日本IPO市场非常活跃，可以利用IPO接口构建新股提醒功能。

def get_japan_ipo(type=1):
    """获取日本IPO信息"""
    url = f"{BASE_URL}/stock/getIpo"
    params = {
        "countryId": JAPAN_COUNTRY_ID,
        "type": type,  # 1:未上市, 2:已上市
        "key": API_KEY
    }
    
    response = requests.get(url, params=params)
    result = response.json()
    
    if result.get("code") == 200:
        return result["data"]
    else:
        print("请求失败:", result.get("message"))
        return None

2. 公司基本面信息

获取上市公司的详细背景、所属行业及板块分类。

def get_company_info(country_id=35, page_size=10, page=1):
    """获取公司信息"""
    url = f"{BASE_URL}/stock/companies"
    params = {
        "countryId": country_id,
        "pageSize": page_size,
        "page": page,
        "key": API_KEY
    }
    
    response = requests.get(url, params=params)
    result = response.json()
    
    if result.get("code") == 200:
        return result["data"]["records"]
    else:
        print("请求失败:", result.get("message"))
        return None