Python获取实时股票信息
James.Ying 人气:0如何获取实时股票信息
股票信息的接口有很多，之前大家常用的是新浪的，但在年初的时候，新浪的接口突然不能使用，给大家造成了很大的困扰，为此网上也有很多教程教大家如何从新浪获取数据，跟着教程弄了半天也不行，索性换到126（也就是网易了），感觉速度都还不错。
首先我们看下接口地址：http://api.money.126.net/data/feed/1000001,money.api
其中的1000001就是股票代码了，跟新浪的不同，他的第一位代表交易所，后面6位是股票代码
- 0：上交所
- 1：深交所
- 2：北交所
先通过浏览器看下数据结构：
_ntes_quote_callback({
"1000001": {
"code": "1000001",
"percent": 0.002113,
"high": 14.25,
"askvol3": 1026758,
"askvol2": 810700,
"askvol5": 290493,
"askvol4": 461100,
"price": 14.23,
"open": 14.2,
"bid5": 14.18,
"bid4": 14.19,
"bid3": 14.2,
"bid2": 14.21,
"bid1": 14.22,
"low": 14.11,
"updown": 0.03,
"type": "SZ",
"bidvol1": 323600,
"status": 0,
"bidvol3": 244200,
"bidvol2": 673474,
"symbol": "000001",
"update": "2022/06/25 17:59:57",
"bidvol5": 343500,
"bidvol4": 145200,
"volume": 86604061,
"askvol1": 817268,
"ask5": 14.27,
"ask4": 14.26,
"ask1": 14.23,
"name": "平安银行",
"ask3": 14.25,
"ask2": 14.24,
"arrow": "↑",
"time": "2022/06/24 16:00:58",
"yestclose": 14.2,
"turnover": 1227798687.09
}
});
可以看出_ntes_quote_callback()中的就是标准的json数据，我们只要通过正则表达式就可以取出。
我们先定义一个数据结构：
class NetTick:
def __init__(self, dict={}):
self.name = dict.get('name') # 股票名称
self.yestclose = dict.get('yestclose') # 昨日收盘价
self.bidvol5 = dict.get('bidvol5') # 买5数量
self.bidvol4 = dict.get('bidvol4') # 买4数量
self.bidvol3 = dict.get('bidvol3') # 买3数量
self.bidvol2 = dict.get('bidvol2') # 买2数量
self.bidvol1 = dict.get('bidvol1') # 买1数量
self.bid5 = dict.get('bid5') # 买5价格
self.bid4 = dict.get('bid4') # 买4价格
self.bid3 = dict.get('bid3') # 买3价格
self.bid2 = dict.get('bid2') # 买2价格
self.bid1 = dict.get('bid1') # 买1价格
self.askvol5 = dict.get('askvol5') # 卖5数量
self.askvol4 = dict.get('askvol4') # 卖4数量
self.askvol3 = dict.get('askvol3') # 卖3数量
self.askvol2 = dict.get('askvol2') # 卖2数量
self.askvol1 = dict.get('askvol1') # 卖1数量
self.ask5 = dict.get('ask5') # 卖5价格
self.ask4 = dict.get('ask4') # 卖4价格
self.ask3 = dict.get('ask3') # 卖3价格
self.ask2 = dict.get('ask2') # 卖2价格
self.ask1 = dict.get('ask1') # 卖1价格
self.symbol = dict.get('symbol') # 股票代码 第一位1：深交所 0：上交所 2北交所
self.volume = dict.get('volume') # 成交量
self.price = dict.get('price') # 当前价格
self.open = dict.get('open') # 开盘价
self.low = dict.get('low') # 最低价
self.high = dict.get('high') # 最高价
self.code = dict.get('code') # 去除标记为的股票代码
self.turnover = dict.get('turnover') # 成交额
self.percent = dict.get('percent') # 涨跌幅
self.updown = dict.get('updown') # 涨跌金额
通过研究，我们发现126的接口支持多个股票查询，那我们可以定义两个方法，一个查单个，一个查多个，具体实现如下：
import requests
import re
from models.nettick import NetTick
from utils.packages import *
class NetEaseData:
@staticmethod
def get_realtime_data(symbol):
"""
网易的实时数据接口
:param symbol: 股票代码
:return: Tick
"""
code = NetEaseData.convert_market(symbol)
try:
response = requests.get("http://api.money.126.net/data/feed/{},money.api".format(code)).text
re_find = NetEaseData.__re_find(response)
if re_find is not None:
find_stock = re_find.get(code)
if find_stock is not None:
return NetTick(find_stock)
except Exception as e:
logger.error('请求网易接口出错，错误信息：{}'.format(e))
return None
@staticmethod
def convert_market(other_market_code=str):
"""
转换通用股票代码 sz sh bj开头+股票代码
"""
if other_market_code[0:2].lower() == 'sh':
return '0' + other_market_code[2:]
elif other_market_code[0:2].lower() == 'sz':
return '1' + other_market_code[2:]
else:
return '2' + other_market_code[2:]
@staticmethod
def get_realtime_datas(symbols=[]):
"""
网易的实时数据接口
:param symbols: 股票代码列表
:return: Ticks列表
"""
codes = [NetEaseData.convert_market(code) for code in symbols]
result = []
try:
response = requests.get("http://api.money.126.net/data/feed/{},money.api".format(','.join(codes))).text
re_find = NetEaseData.__re_find(response)
if re_find is not None:
for code in re_find:
item = re_find[code]
result.append(NetTick(item))
except Exception as e:
logger.error('请求网易接口出错，错误信息：{}'.format(e))
return result
@staticmethod
def __re_find(response):
find = re.findall(r"_ntes_quote_callback\((.*)\);", response)
if len(find) >= 1:
return to_obj(find[-1])
return None
if __name__ == '__main__':
ticks = NetEaseData.get_realtime_datas(['sh588000', 'sz000001', 'bj831010'])
[print(tick.symbol, tick.name, tick.price) for tick in ticks]
tick = NetEaseData.get_realtime_data('sz127045')
print(tick.symbol, tick.name, tick.price)
使用也非常简单
NetEaseData.get_realtime_data：获取单个股票NetEaseData.get_realtime_datas： 获取多个股票数据
这里我股票代码用的是兼容原有新浪模式的，你可以自己做下修改。
加载全部内容