当前位置: 首页 > ai >正文

对接印度股票数据实战 - Python实现完整指南


对接印度股票数据实战 - Python实现完整指南

一、API接口概述

根据提供的JSON文档,印度股票数据接口主要包含以下功能:

功能模块接口描述核心参数示例
市场列表获取指定国家的股票列表countryId=14(印度国家ID)
股票查询根据ID或名称查询个股id=7310
K线数据获取不同时间粒度的K线interval=PT15M(15分钟)
实时行情WebSocket推送实时数据wss协议
涨跌排行榜获取涨幅/跌幅排行type=1(涨幅榜)
IPO新股日历获取新股上市信息countryId=14

二、Python对接实战

1. 环境准备

# 安装依赖
pip install requests websocket-client pandas

2. 基础配置

import requests
import json
import pandas as pd
from datetime import datetimeBASE_URL = "https://api.stocktv.top/stock"
API_KEY = "MY4b781f618e3f43c4b055f25fa61941ad"  # 替换为实际keyHEADERS = {"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) PythonStockClient/1.0","Accept-Encoding": "gzip"
}

3. 核心接口封装

def get_market_list(country_id=14, page=1, page_size=10):"""获取印度股票市场列表"""params = {"countryId": country_id,"page": page,"pageSize": page_size,"key": API_KEY}try:response = requests.get(f"{BASE_URL}/stocks",params=params,headers=HEADERS,timeout=10)response.raise_for_status()# 转换数据为DataFramedata = response.json()['data']['records']df = pd.DataFrame(data)# 处理时间戳df['time'] = pd.to_datetime(df['time'], unit='s') return df[['id', 'symbol', 'name', 'last', 'chgPct', 'volume', 'time']]except requests.exceptions.RequestException as e:print(f"请求失败: {str(e)}")return Nonedef get_kline(pid, interval="PT15M"):"""获取股票K线数据"""params = {"pid": pid,"interval": interval,"key": API_KEY}response = requests.get(f"{BASE_URL}/kline",params=params,headers=HEADERS)if response.status_code == 200:kline_data = response.json()['data']df = pd.DataFrame(kline_data)df['time'] = pd.to_datetime(df['time'], unit='ms')return dfreturn Nonedef search_stock(search_term):"""多条件搜索股票"""params = {"id": search_term if search_term.isdigit() else "","name": search_term if not search_term.isdigit() else "","key": API_KEY}response = requests.get(f"{BASE_URL}/queryStocks",params=params,headers=HEADERS)return response.json()['data'] if response.ok else []

4. WebSocket实时数据

import websocket
import threading
import timedef on_message(ws, message):"""处理实时行情推送"""data = json.loads(message)print(f"\n实时行情更新 [{data['symbol']}]:")print(f"最新价: {data['last_numeric']}")print(f"涨跌幅: {data['pcp']}%")print(f"成交量: {data['turnover_numeric']}")def on_error(ws, error):print(f"WebSocket错误: {str(error)}")def on_close(ws, close_status_code, close_msg):print("WebSocket连接关闭")def ws_heartbeat(ws):"""保持心跳连接"""while True:time.sleep(30)ws.send(json.dumps({"action": "ping"}))def start_websocket():ws_url = f"wss://ws-api.stocktv.top/connect?key={API_KEY}"ws = websocket.WebSocketApp(ws_url,on_message=on_message,on_error=on_error,on_close=on_close)# 启动心跳线程threading.Thread(target=ws_heartbeat, args=(ws,)).start()ws.run_forever()

三、使用示例

1. 获取Nifty50指数

nifty50 = get_market_list().query('name.str.contains("Nifty 50")')
print(nifty50[['symbol', 'last', 'chgPct']])

2. 分析TATA Motors的K线

tata_motors_kline = get_kline(7310)
tata_motors_kline.set_index('time')['close'].plot(title='TATA Motors 15分钟K线'
)

3. 实时监控(需要单独线程运行)

# start_websocket()

四、开发注意事项

  1. 参数验证
def validate_country_id(country_id):valid_ids = [14,42,36]  # 印度、马来西亚、印尼等if country_id not in valid_ids:raise ValueError("非法的国家ID")
  1. 错误重试机制
from tenacity import retry, stop_after_attempt, wait_exponential@retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1))
def safe_api_call(url, params):return requests.get(url, params=params, timeout=5)
  1. 数据缓存策略
from cachetools import cached, TTLCachestock_cache = TTLCache(maxsize=100, ttl=300)@cached(stock_cache)
def get_cached_stock_data(pid):return get_kline(pid)

备注说明

  1. 实际开发时需要处理API限流(建议QPS控制在5次/秒以下)
  2. 时间参数注意转换为Unix时间戳格式
  3. WebSocket连接建议增加异常重连机制
  4. 生产环境建议使用连接池管理HTTP请求

希望这篇实战指南能帮助您快速对接印度股票数据!在实际使用中如遇到问题,欢迎在评论区交流讨论。

http://www.xdnf.cn/news/4245.html

相关文章:

  • 结构体内存对齐规则与优化
  • iPaaS核心解析与牧场场景应用方案
  • 前端正则学习记录
  • 2025Mapbox零基础入门教程(8)geojson加载点要素
  • MySQL数据库中篇
  • python简易实现勒索病毒
  • 最小方差自校正调节器设计
  • Python: pipx详细解释
  • 【Day 20】HarmonyOS多语言适配开发实战
  • 使用OpenCV 和 Dlib 实现年龄性别预测
  • Spring AI系列——大模型驱动的自然语言SQL引擎:Java技术实现详解
  • 用DEEPSEEK做开发辅助应该注意什么
  • Nyx-1 思路整理
  • 【Python】--装饰器
  • Coding Practice,48天强训(30)
  • 2. H264编码
  • 垂直领域知识图谱构建与大模型融合技术方案
  • 达梦DM数据库安装步骤
  • 普通IT的股票交易成长史--20250506午复盘
  • Leetcode - 周赛448
  • 分割回文串例题-区分组合回溯与最优动态规划
  • 主数据 × 知识图谱:打造企业认知智能的核心基础设施
  • C++GO语言微服务项目之 go语言基础语法
  • pcl平面投影
  • 解锁科研文献检索密码:多工具协同攻略
  • 代码规范总结
  • 推导部分和-图论+dfs+连通块
  • 【MongoDB篇】MongoDB的聚合框架!
  • 【区块链】Uniswap详细介绍
  • HTML07:表格标签