Tushare 获取股票实时数据
自己实现了一个能获取股票实时交易数据的脚本，功能是每3秒钟获取当前大盘涨跌，和自己添加股票的价格和涨跌幅
原理是通过获取Tushare 平台提供的api，来获取股票数据，可以通过
https://tushare.pro/register?reg=376628
访问平台，第一次访问需要注册
codes就表示要实时监控的股票代码，sh表示上证指数，sz表示深成指数，cyb就是创业板的指数，后面是我加的两个自选股，如果想加其他的，在后边依次添加代码就好
codes = ['sh', 'sz', 'cyb', '000100', '002958']
运行后会显示如下：
完整代码如下：
import tushare as ts
import time
import os
codes = ['sh', 'sz', 'cyb', '000100', '002958']
while 1:
data = ts.get_realtime_quotes(codes)
# print(len(data))
sh_price = round(float(data['price'].values[0]), 2)
sh_pre_close = round(float(data['pre_close'].values[0]), 2)
sz_price = round(float(data['price'].values[1]), 2)
sz_pre_close = round(float(data['pre_close'].values[1]), 2)
cyb_price = round(float(data['price'].values[2]), 2)
cyb_pre_close = round(float(data['pre_close'].values[2]), 2)
sh = round(sh_price - sh_pre_close, 2)
sz = round(sz_price - sz_pre_close, 2)
cyb = round(cyb_price - cyb_pre_close, 2)
sh_percent = round(sh / sh_pre_close * 100, 2)
sz_percent = round(sz / sz_pre_close * 100, 2)
cyb_percent = round(cyb / cyb_pre_close * 100, 2)
# print('(', sh_price, sh, sh_percent, ')', '(', sz_price, sz, sz_percent, ')', '(', cyb_price, cyb, cyb_percent, ')')
print('(%.2f %.2f %.2f) (%.2f %.2f %.2f) (%.2f %.2f %.2f)'%(sh_price, sh, sh_percent, sz_price, sz, sz_percent, cyb_price, cyb, cyb_percent))
for i in range(3, len(data)):
price = float(data['price'].values[i])
pre_close = float(data['pre_close'].values[i])
print(data.name.values[i], data.open.values[i], data.price.values[i], round((price-pre_close)/pre_close*100, 2))
time.sleep(3)
原文链接:https://blog.csdn.net/weixin_39839293/article/details/107143289

Tushare 获取股票实时数据

自己实现了一个能获取股票实时交易数据的脚本，功能是每3秒钟获取当前大盘涨跌，和自己添加股票的价格和涨跌幅

原理是通过获取Tushare 平台提供的api，来获取股票数据，可以通过

https://tushare.pro/register?reg=376628

访问平台，第一次访问需要注册
codes就表示要实时监控的股票代码，sh表示上证指数，sz表示深成指数，cyb就是创业板的指数，后面是我加的两个自选股，如果想加其他的，在后边依次添加代码就好
codes = ['sh', 'sz', 'cyb', '000100', '002958']

运行后会显示如下：


完整代码如下：
import tushare as ts
import time
import os

codes = ['sh', 'sz', 'cyb', '000100', '002958']

while 1:
    data = ts.get_realtime_quotes(codes)
    # print(len(data))
    sh_price = round(float(data['price'].values[0]), 2)
    sh_pre_close = round(float(data['pre_close'].values[0]), 2)
    sz_price = round(float(data['price'].values[1]), 2)
    sz_pre_close = round(float(data['pre_close'].values[1]), 2)
    cyb_price = round(float(data['price'].values[2]), 2)
    cyb_pre_close = round(float(data['pre_close'].values[2]), 2)
    sh = round(sh_price - sh_pre_close, 2)
    sz = round(sz_price - sz_pre_close, 2)
    cyb = round(cyb_price - cyb_pre_close, 2)
    sh_percent = round(sh / sh_pre_close * 100, 2)
    sz_percent = round(sz / sz_pre_close * 100, 2)
    cyb_percent = round(cyb / cyb_pre_close * 100, 2)
    # print('(', sh_price, sh, sh_percent, ')', '(', sz_price, sz, sz_percent, ')', '(', cyb_price, cyb, cyb_percent, ')')
    print('(%.2f %.2f %.2f) (%.2f %.2f %.2f) (%.2f %.2f %.2f)'%(sh_price, sh, sh_percent, sz_price, sz, sz_percent, cyb_price, cyb, cyb_percent))
    for i in range(3, len(data)):
        price = float(data['price'].values[i])
        pre_close = float(data['pre_close'].values[i])
        print(data.name.values[i], data.open.values[i], data.price.values[i], round((price-pre_close)/pre_close*100, 2))
    time.sleep(3)

一 操作手册

引导用户顺利开始使用Tushare Pro数据，以下步骤将带您开始Tushare数据之旅：

用户注册登录后可调用数据：https://tushare.pro/register?reg=399205

 

二 如何获取TOKEN凭证

1、登录成功后，点击右上角->个人主页



2、 在“用户中心”中点击“接口TOKEN”



3、 可以点击右侧复制按钮复制token



 

  一键注册即可免费调用以下数据：



 

三 通过Python SDK 调取数据

导入tushare

import tushare as ts

初始化pro接口

pro = ts.pro_api()

注册后，在「个人信息」里查看你的 token :

pro = ts.pro_api('your token')


数据调取

以获取交易日历信息为例：

df = pro.trade_cal(exchange='', start_date='20180901', end_date='20181001', fields='exchange,cal_date,is_open,pretrade_date', is_open='0')

调取结果：

    exchange  cal_date    is_open pretrade_date
0          SSE       20180901        0      20180831
1          SSE       20180902        0      20180831
2          SSE       20180908        0      20180907
3          SSE       20180909        0      20180907
4          SSE       20180915        0      20180914
5          SSE       20180916        0      20180914
6          SSE       20180922        0      20180921
7          SSE       20180923        0      20180921
8          SSE       20180924        0      20180921
9          SSE       20180929        0      20180928
10         SSE       20180930        0      20180928
11         SSE       20181001        0      20180928

 

 

tushare是一个免费开源的财经数据接口包，通过tushare这个模块，可以实现对采集、存储股票等金融数据，能够为金融分析人员提供快速、整洁、和多样的便于分析的数据。

案例说明：通过获取股票的实时数据，取出股票代码对应的信息以及股票数据状态对比，发送邮箱提醒。

案例代码：

import tushare
import time
import smtplib
from email.mime.text import MIMEText


class StockClass():
    '股票类'

    def __init__(self, stockCode, buyPoint, SellingPoint):
        self.stockName = ''
        self.price = ''
        self.highPrice = ''
        self.lowPrice = ''
        self.StockTime = ''
        self.StockCode = stockCode
        self.buyPoint = buyPoint
        self.SellingPoint = SellingPoint


def getStockData(StockClass):
    '获取股票数据'
    stockData = tushare.get_realtime_quotes(StockClass.StockCode)  # 获取股票的实时数据。
    # stockCod=tushare.get_realtime_quotes('000519')#获取股票的实时数据。
    # print(str(stockData))

    StockClass.stockName = stockData.loc[0][0]  # 股票名
    StockClass.stockCode = stockData.loc[0][-1]  # 股票代码
    StockClass.price = float(stockData.loc[0][3])  # 股票价格
    StockClass.highPrice = stockData.loc[0][4]  # 最高价
    StockClass.lowPrice = stockData.loc[0][5]  # 最低价
    StockClass.StockTime = stockData.loc[0][-2]  # 日期
    StockClass.getContent = '股票名：' + StockClass.stockName \
                            + '\n当前价格：' + str(StockClass.price) + '\n最高价格：' \
                            + str(StockClass.highPrice) + '\n时间：' + str(StockClass.StockTime)
    # print('股票名：',stockClass.stockName,'\n当前价格：',stockClass.price,
    #       '\n最高价格：',stockClass.highPrice,'\n时间：',stockClass.StockTime)
    # print(StockClass.getContent)
    return StockClass


def SendEmail(msgSubject, msgContent):
    '''
    发送邮件提醒
    :param msgSubject:邮件主题
    :param msgContent:邮件内容
    :return:邮件
    '''
    msgFrom = 'XXXXX@qq.com'
    msgPassWord = 'XXXXX'  #发送方

    msgT0 = 'XXXXX@qq.com'  # 接收方

    msgEmail = MIMEText(msgContent, 'utf-8')  # 构造邮件
    msgEmail['msgSubject'] = msgSubject
    msgEmail['msgContent'] = msgContent
    msgEmail['msgT0'] = msgT0

    try:
        ss = smtplib.SMTP('smtp.qq.com', 587)
        ss.ehlo()
        ss.starttls()  # 启动安全传输模式。
        ss.login(msgFrom, msgPassWord)
        ss.sendmail(msgFrom, msgT0, msgEmail.as_string())  # 发送邮件
        print('邮件发送成功..')
        ss.quit()
    except Exception as e:
        print('邮件发送失败：', e)


def main(ShareList):
    for i in ShareList:
        sss = getStockData(i)
        # print(sss.getContent)

    if sss.price <= sss.buyPoint:
        # print('\033[32m'+'%s达到买点,当前价格为%s。'%(sss.stockName,sss.price)+'\033[0m')
        SendEmail('达到买点', sss.getContent)
    elif sss.price >= sss.SellingPoint:
        # print('\033[31m'+'%s达到卖点，当前价格为%s。'%(sss.stockName,sss.price)+'\033[0m')
        SendEmail('达到卖点', sss.getContent)
    else:
        print('再等等。')


while True:
    i_1 = StockClass('600106', 3.1, 3.18)
    # i_2=StockClass('601988',3.4,3.5)
    # i_3=StockClass('000591',3.0,3.7)

    # list=[i_1,i_2,i_3]
    list = [i_1]
    # print('-----------')
    main(list)

    time.sleep(600)