当前位置：首页 > news >正文

马来西亚股票数据API对接文档

news 2025/9/23 10:32:27

马来西亚股票数据API对接文档

本文档提供StockTV马来西亚股票市场(Bursa Malaysia)数据API的完整对接指南，包含实时行情、历史数据、公司信息等核心功能

一、接口概览

1.1 支持交易所

交易所代码	交易所名称	覆盖股票数量
MYX	马来西亚交易所	900+

1.2 数据特性

实时行情：毫秒级延迟
历史数据：支持最长10年历史K线
基本面数据：包含PE比率、市值等指标
多维度数据：指数、IPO、公司信息等
数据格式：统一JSON格式
货币单位：所有价格均为马来西亚林吉特(MYR)

二、接入准备

2.1 获取API Key

联系官方获取密钥：https://t.me/CryptoRzz

2.2 请求基础URL

https://api.stocktv.top

2.3 请求头设置

X-Api-Key: YOUR_API_KEY
Content-Type: application/json

三、核心接口说明

3.1 市场列表接口

获取马来西亚交易所股票列表

接口地址：

GET /stock/stocks

请求参数：

参数	必选	说明	示例值
countryId	是	国家ID(马来西亚为42)	42
exchangeId	否	交易所ID(MYX为62)	62
pageSize	否	每页数量	100
page	否	页码	1

响应示例：

{"code": 200,"data": {"records": [{"id": 41602,           // 股票唯一ID"symbol": "MAYBANK",   // 股票代码"name": "Malayan Banking Berhad","last": 9.25,          // 最新价"chgPct": 0.5,         // 涨跌幅%"volume": 1241700,     // 成交量"high": 9.30,          // 当日最高"low": 9.20,           // 当日最低"open": true,          // 是否开市"cfd": false,          // 是否为CFD"marketCap": 105000000000 // 市值(百万MYR)}],"total": 900,"pages": 9}
}

3.2 股票详情查询

获取指定股票实时行情

接口地址：

GET /stock/queryStocks

请求参数：

参数	必选	说明	示例值
id	是	股票ID	41602

响应示例：

{"code": 200,"data": [{"id": 41602,"symbol": "MAYBANK","name": "Malayan Banking Berhad","last": 9.25,"prevClose": 9.20,       // 前收盘价"open": 9.22,            // 开盘价"high": 9.30,"low": 9.20,"volume": 1241700,"avgVolume": 1150000,    // 平均成交量"peRatio": 12.5,         // 市盈率"eps": 0.74,             // 每股收益"dividendYield": 5.4,    // 股息率"beta": 0.92,            // Beta值"sector": "Financial"    // 行业分类}]
}

3.3 指数数据

获取马来西亚主要指数行情

接口地址：

GET /stock/indices

请求参数：

参数	必选	说明	示例值
countryId	是	国家ID(马来西亚为42)	42

响应示例：

{"code": 200,"data": [{"id": 18460,"symbol": "KLSE",       // 吉隆坡综合指数"name": "FTSE Bursa Malaysia KLCI","last": 1605.25,"change": 12.45,        // 涨跌额"changePct": 0.78,      // 涨跌幅%"high": 1608.50,"low": 1598.75,"prevClose": 1592.80,"time": 1716458537      // 更新时间戳}]
}

3.4 历史K线数据

获取股票历史价格数据

接口地址：

GET /stock/kline

请求参数：

参数	必选	说明	示例值
pid	是	股票ID	41602
interval	是	时间粒度	PT15M(15分钟) P1D(日线)

响应示例：

{"code": 200,"data": [{"time": 1725004800000, // 时间戳(ms)"open": 9.22,"high": 9.30,"low": 9.20,"close": 9.25,"volume": 1241700},// 更多K线数据...]
}

四、高级数据接口

4.1 IPO新股日历

获取即将上市的新股信息

接口地址：

GET /stock/getIpo

请求参数：

参数	必选	说明	示例值
countryId	是	国家ID	42
type	否	1=即将上市, 2=已上市	1

响应示例：

{"code": 200,"data": [{"id": 28,"company": "Tech Solutions Malaysia","symbol": "TSM","exchange": "MYX","ipoPrice": "1.20",       // 发行价"listingDate": "2024-10-15", // 上市日期"ipoValue": "500M",       // 发行市值"last": "1.18",           // 最新价"pid": 1218998            // 股票ID}]
}

4.2 涨跌排行榜

获取涨幅榜/跌幅榜数据

接口地址：

GET /stock/updownList

请求参数：

参数	必选	说明	示例值
countryId	是	国家ID	42
type	是	1=涨幅榜, 2=跌幅榜, 3=涨停, 4=跌停	1

响应示例：

{"code": 200,"data": [{"id": 41605,"symbol": "SIME","name": "Sime Darby Berhad","last": 2.85,"change": 0.25,"changePct": 9.62,"volume": 4500000}]
}

4.3 公司基本面数据

获取公司详细信息

接口地址：

GET /stock/companies

请求参数：

参数	必选	说明	示例值
countryId	是	国家ID	42
pageSize	否	每页数量	10
page	否	页码	1

响应示例：

{"code": 200,"data": {"records": [{"companyName": "Malayan Banking Berhad","description": "马来西亚最大的银行集团...","industry": "Banking","sector": "Financial Services","employeeCount": 42000,"market": "Malaysia","url": "/equities/maybank","financials": {"revenue": "52.4B MYR",  // 营收"netIncome": "8.2B MYR",  // 净利润"assets": "890.5B MYR"    // 总资产}}],"total": 900,"pages": 90}
}

五、实时数据推送

5.1 WebSocket连接

wss://ws-api.stocktv.top/connect?key=YOUR_API_KEY

5.2 订阅消息

{"action": "subscribe","pids": [41602, 41605]  // 订阅的股票ID列表
}

5.3 实时数据格式

{"pid": "41602",         // 股票ID"symbol": "MAYBANK",    // 股票代码"last": "9.25",         // 最新价"change": "0.05",       // 涨跌额"changePct": "0.5",     // 涨跌幅%"volume": "1241700",    // 成交量"bid": "9.24",          // 买一价"ask": "9.26",          // 卖一价"high": "9.30",         // 当日最高"low": "9.20",          // 当日最低"open": "9.22",         // 开盘价"prevClose": "9.20",    // 前收盘"timestamp": 1725008213  // 更新时间
}

5.4 心跳机制

客户端需每30秒发送心跳消息：

{"action": "ping"}

六、代码示例

6.1 Python获取股票数据

import requestsdef get_malaysia_stocks():"""获取马来西亚股票列表"""url = "https://api.stocktv.top/stock/stocks"params = {"countryId": 42,    # 马来西亚国家ID"exchangeId": 62,   # MYX交易所"pageSize": 100,"key": "YOUR_API_KEY"}try:response = requests.get(url, params=params)if response.status_code == 200:data = response.json()if data["code"] == 200:for stock in data["data"]["records"]:print(f"{stock['symbol']}: {stock['name']} - {stock['last']} MYR")else:print(f"API Error: {data['message']}")else:print(f"Request failed with status: {response.status_code}")except Exception as e:print(f"Error fetching stock list: {str(e)}")# 调用函数
get_malaysia_stocks()

6.2 Java实时数据订阅

import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;import java.net.URI;public class MalaysiaStockWS extends WebSocketClient {public MalaysiaStockWS(URI serverUri) {super(serverUri);}@Overridepublic void onOpen(ServerHandshake handshakedata) {System.out.println("Connected to Malaysia Stock API");// 订阅MAYBANK和PUBLIC BANK股票send("{\"action\":\"subscribe\",\"pids\":[41602, 41603]}");}@Overridepublic void onMessage(String message) {System.out.println("Received: " + message);// 实际应用中解析JSON并处理实时数据}@Overridepublic void onClose(int code, String reason, boolean remote) {System.out.println("Connection closed: " + reason);}@Overridepublic void onError(Exception ex) {ex.printStackTrace();}public static void main(String[] args) {String wsUrl = "wss://ws-api.stocktv.top/connect?key=YOUR_API_KEY";MalaysiaStockWS client = new MalaysiaStockWS(URI.create(wsUrl));client.connect();}
}

6.3 Node.js获取K线数据

const axios = require('axios');async function getKlineData() {try {const response = await axios.get('https://api.stocktv.top/stock/kline', {params: {pid: 41602,        // MAYBANK股票IDinterval: 'P1D'    // 日线数据},headers: {'X-Api-Key': 'YOUR_API_KEY'}});console.log('MAYBANK Historical Data:');response.data.data.forEach(kline => {const date = new Date(kline.time);console.log(`${date.toISOString().split('T')[0]}: ${kline.open} - ${kline.close}`);});} catch (error) {console.error('API Error:', error.response ? error.response.data : error.message);}
}getKlineData();

七、最佳实践

7.1 数据缓存策略

from cachetools import TTLCache
import time# 创建缓存，有效期5秒
stock_cache = TTLCache(maxsize=100, ttl=5)def get_stock_quote(stock_id):"""获取股票行情（带缓存）"""# 检查缓存if stock_id in stock_cache:return stock_cache[stock_id]# 调用API获取数据quote = fetch_from_api(stock_id)# 存入缓存if quote:stock_cache[stock_id] = quotereturn quote

7.2 错误处理与重试

import requests
import timedef fetch_with_retry(url, params, max_retries=3):"""带重试机制的API请求"""for attempt in range(max_retries):try:response = requests.get(url, params=params, timeout=5)if response.status_code == 200:data = response.json()if data.get("code") == 200:return dataelif data.get("code") == 429:  # 请求过多retry_after = int(data.get("retryAfter", 10))print(f"请求过于频繁，等待 {retry_after} 秒后重试...")time.sleep(retry_after)else:print(f"API返回错误: {data.get('message')}")else:print(f"请求失败，状态码: {response.status_code}")except Exception as e:print(f"请求异常: {str(e)}")if attempt < max_retries - 1:wait = 2 ** attempt  # 指数退避print(f"等待 {wait} 秒后重试 (尝试 {attempt+1}/{max_retries})")time.sleep(wait)print(f"请求失败，已达最大重试次数 {max_retries}")return None

7.3 实时数据批处理

class RealTimeBatchProcessor:def __init__(self, batch_size=10, batch_interval=0.5):self.batch_size = batch_sizeself.batch_interval = batch_intervalself.buffer = {}self.last_process_time = time.time()def add_data(self, symbol, data):"""添加实时数据到缓冲区"""if symbol not in self.buffer:self.buffer[symbol] = []self.buffer[symbol].append(data)# 检查是否达到批处理条件current_time = time.time()if (len(self.buffer[symbol]) >= self.batch_size or current_time - self.last_process_time >= self.batch_interval):self.process_batch(symbol)self.last_process_time = current_timedef process_batch(self, symbol):"""处理缓冲区的数据"""if symbol not in self.buffer or not self.buffer[symbol]:returndata_points = self.buffer[symbol]# 计算统计指标prices = [d["last"] for d in data_points]volumes = [d["volume"] for d in data_points]avg_price = sum(prices) / len(prices)max_price = max(prices)min_price = min(prices)total_volume = sum(volumes)print(f"\n{symbol} 实时数据统计 (最近 {len(data_points)} 个更新):")print(f"平均价格: {avg_price:.2f}, 最高: {max_price:.2f}, 最低: {min_price:.2f}")print(f"总成交量: {total_volume}")# 清空缓冲区self.buffer[symbol] = []

八、数据字典

8.1 马来西亚主要指数

代码	指数名称	说明
KLSE	富时大马综合指数	马来西亚主要股票指数
FBM70	富时大马70指数	70家市值最大的公司
FBMEMAS	富时大马EMAS指数	大马交易所全股指数