python股票接口_Python3利用Tushare接口结合mysql进行股票量化分析入门

2024-02-24 01:20
文章标签 python 分析 进行 股票 mysql 接口 入门 结合 量化 python3 database tushare

本文主要是介绍python股票接口_Python3利用Tushare接口结合mysql进行股票量化分析入门，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

本帖最后由 sirius0427 于 2019-12-14 17:02 编辑

Tushare给一些对量化分析有兴趣的朋友提供了非常方便的接口，使大家可以进入量化分析的门槛，但在实际应用过程中，发现很多朋友在用文件作为存储股票信息的介质。

这里介绍一种通过mysql数据库存放信息的方式，使用了python语言作为Tushare的接口语言，入库后各位可自行使用喜欢的语言进行分析。

第一步，注册tushare.pro账号,注册链接https://tushare.pro/register

第二步，找到自己账号的接口TOKEN，保存下来，后面代码内要用。账号积分的高低会对接口有不同的限制，详细可以观看积分说明。

第三步：在mysql中创新tushare数据库，我这里用的是navicat，图形化管理比较方便。

none.gif

image.png (43.29 KB, 下载次数: 0)

2019-12-14 16:26 上传

none.gif

image.png (17.58 KB, 下载次数: 0)

2019-12-14 16:27 上传

建库语句如下：

[SQL] 纯文本查看 复制代码CREATE DATABASE `tushare` CHARACTER SET 'utf8mb4' COLLATE 'utf8mb4_general_ci';

第四步：建立相应的表，首先建立trade_cal表，用于记录交易日信息；建立stock_list表，用于存放股票信息；建立stock_daily表，用于存放股票日交易数据。

[SQL] 纯文本查看 复制代码/*

Navicat Premium Data Transfer

Source Server : Quantization

Source Server Type : MySQL

Source Server Version : 80018

Source Host : 127.0.0.1:3306

Source Schema : tushare

Target Server Type : MySQL

Target Server Version : 80018

File Encoding : 65001

Date: 14/12/2019 16:31:24

*/

SET NAMES utf8mb4;

SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------

-- Table structure for trade_cal

-- ----------------------------

DROP TABLE IF EXISTS `trade_cal`;

CREATE TABLE `trade_cal` (

`cal_date` date NOT NULL COMMENT '日历日期',

`is_open` int(1) NULL DEFAULT NULL COMMENT '是否交易 0休市 1交易',

`pretrade_date` date NULL DEFAULT NULL COMMENT '上一个交易日',

PRIMARY KEY (`cal_date`) USING BTREE

) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;

SET FOREIGN_KEY_CHECKS = 1;

[SQL] 纯文本查看 复制代码/*

Navicat Premium Data Transfer

Source Server : Quantization

Source Server Type : MySQL

Source Server Version : 80018

Source Host : 127.0.0.1:3306

Source Schema : tushare

Target Server Type : MySQL

Target Server Version : 80018

File Encoding : 65001

Date: 14/12/2019 16:34:11

*/

SET NAMES utf8mb4;

SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------

-- Table structure for stock_list

-- ----------------------------

DROP TABLE IF EXISTS `stock_list`;

CREATE TABLE `stock_list` (

`ts_code` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'TS代码',

`symbol` varchar(6) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '股票代码',

`name` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '股票名称',

`area` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '所在地域',

`industry` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '所属行业',

`fullname` varchar(60) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '股票全称',

`enname` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '英文全称',

`market` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '市场类型 （主板/中小板/创业板）',

`exchange` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '交易所代码',

`curr_type` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '交易货币',

`list_status` varchar(2) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT ' 上市状态： L上市 D退市 P暂停上市',

`list_date` date NULL DEFAULT NULL COMMENT '上市日期',

`delist_date` date NULL DEFAULT NULL COMMENT '退市日期',

`is_hs` varchar(2) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '是否沪深港通标的，N否 H沪股通 S深股通',

PRIMARY KEY (`ts_code`, `symbol`) USING BTREE

) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;

SET FOREIGN_KEY_CHECKS = 1;

[SQL] 纯文本查看 复制代码/*

Navicat Premium Data Transfer

Source Server : Quantization

Source Server Type : MySQL

Source Server Version : 80018

Source Host : 127.0.0.1:3306

Source Schema : tushare

Target Server Type : MySQL

Target Server Version : 80018

File Encoding : 65001

Date: 14/12/2019 16:34:55

*/

SET NAMES utf8mb4;

SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------

-- Table structure for stock_daily

-- ----------------------------

DROP TABLE IF EXISTS `stock_daily`;

CREATE TABLE `stock_daily` (

`ts_code` varchar(10) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '股票代码',

`trade_date` date NOT NULL COMMENT '交易日期',

`open` double NULL DEFAULT NULL COMMENT '开盘价',

`high` double NULL DEFAULT NULL COMMENT '最高价',

`low` double NULL DEFAULT NULL COMMENT '最低价',

`close` double NULL DEFAULT NULL COMMENT '收盘价',

`pre_close` double NULL DEFAULT NULL COMMENT '昨日收盘价',

`change` double NULL DEFAULT NULL COMMENT '涨跌额',

`pct_chg` double NULL DEFAULT NULL COMMENT '涨跌幅',

`vol` double NULL DEFAULT NULL COMMENT '成交量 （手）',

`amount` double NULL DEFAULT NULL COMMENT '成交额 （千元）',

`turnover_rate` double NULL DEFAULT NULL COMMENT '换手率',

`volume_ratio` double NULL DEFAULT NULL COMMENT '量比',

UNIQUE INDEX `ts_code_date`(`ts_code`, `trade_date`) USING BTREE COMMENT '以股票代码和日期作为主键',

INDEX `ts_code`(`ts_code`) USING BTREE,

INDEX `trade_date`(`trade_date`) USING BTREE

) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;

SET FOREIGN_KEY_CHECKS = 1;

第五步，安装python3，因为不同平台的安装方法不一致，所以不在赘述，可自行查询相关平台的安装方法。

通过pip安装PyMysql、tushare、numpy、pandas，方法很简单，pip install +所需要安装的包名即可。

第六步，写Python代码，取交易日期存入trade_cal表中

[Python] 纯文本查看 复制代码# coding:utf-8

import tushare as ts

import pymysql

import numpy as np

ts.set_token('你的接口TOKEN')

pro = ts.pro_api()

#调用trade_cal接口，设置起始日期和终止日期

data = pro.query('trade_cal', start_date='20190101', end_date='20201231', fields='cal_date,is_open,pretrade_date')

print(data)

dataset = np.array(data)

datalist = dataset.tolist()

# 打开数据库连接

db = pymysql.connect(host='localhost', port=3306, user='mysql用户名', passwd='mysql密码', db='tushare', charset='utf8mb4')

cursor = db.cursor()

# SQL 插入语句

sql = "INSERT INTO trade_cal (cal_date,is_open,pretrade_date) VALUES (%s,%s,%s)"

try:

# 执行sql语句

cursor.executemany(sql, datalist)

# 提交到数据库执行

db.commit()

except Exception as e:

print(e)

# 如果发生错误则回滚

db.rollback()

# 关闭游标

cursor.close()

# 关闭数据库连接

db.close()

第七步，取股票列表存入stock_list表中。

[Python] 纯文本查看 复制代码# coding:utf-8

import tushare as ts

import pymysql

import numpy as np

ts.set_token('你的TOKEN')

pro = ts.pro_api()

#查询当前所有正常上市交易的股票列表

data = pro.stock_basic(exchange='', list_status='L', fields='ts_code,symbol,name,area,industry,fullname,enname,market,exchange,curr_type,list_status,list_date,delist_date,is_hs' )

print(data)

dataset = np.array(data)

datalist = dataset.tolist()

# 打开数据库连接

db = pymysql.connect(host='localhost', port=3306, user='mysql用户名', passwd='mysql密码', db='tushare', charset='utf8mb4')

# 使用cursor()方法获取操作游标

cursor = db.cursor()

sql = "delete from stock_list"

try:

# 执行sql语句

cursor.execute(sql)

# 提交到数据库执行

db.commit()

except Exception as e:

print(e)

# 如果发生错误则回滚

db.rollback()

# 关闭游标

cursor.close()

cursor = db.cursor()

# SQL 插入语句

sql = "INSERT INTO stock_list (ts_code, symbol, name, area, industry, fullname, enname, market, exchange, curr_type, list_status, list_date, delist_date, is_hs) VALUES (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)"

try:

# 执行sql语句

cursor.executemany(sql, datalist)

# 提交到数据库执行

db.commit()

except Exception as e:

print(e)

# 如果发生错误则回滚

db.rollback()

# 关闭游标

cursor.close()

# 关闭数据库连接

#查询当前所有正常上市交易的股票列表

data1 = pro.stock_basic(exchange='', list_status='P', fields='ts_code,symbol,name,area,industry,fullname,enname,market,exchange,curr_type,list_status,list_date,delist_date,is_hs' )

print(data1)

dataset1 = np.array(data1)

datalist1 = dataset1.tolist()

cursor = db.cursor()

try:

# 执行sql语句

cursor.executemany(sql, datalist1)

# 提交到数据库执行

db.commit()

except Exception as e:

print(e)

# 如果发生错误则回滚

db.rollback()

# 关闭游标

cursor.close()

# 关闭数据库连接

db.close()

第八步：取股票当日交易信息，放入stock_daily表中。

[Python] 纯文本查看 复制代码# coding:utf-8

import tushare as ts

import pymysql

import numpy as np

import datetime

import time

import pandas as pd

import sys

ts.set_token('你的token')

pro = ts.pro_api()

db = pymysql.connect(host='localhost', port=3306, user='mysql用户名', passwd='mysql密码', db='tushare', charset='utf8mb4')

db1 = pymysql.connect(host='localhost', port=3306, user='mysql用户名', passwd='mysql密码', db='tushare', charset='utf8mb4')

cursor = db1.cursor()

sql = "select cal_date from trade_cal where cal_date ='" + str(sys.argv[1]) + "' and is_open=1 order by cal_date"

cursor.execute(sql)

print("cursor.excute:", cursor.rowcount)

for each in cursor.fetchall():

print(datetime.datetime.strftime(each[0], "%Y%m%d"))

data = pro.daily(trade_date=datetime.datetime.strftime(each[0], "%Y%m%d"))

cursor = db.cursor()

datalist = np.array(data).tolist()

sql = "insert into stock_daily( ts_code, trade_date, `open`, high, low, `close`, pre_close, `change`, pct_chg, vol, amount) values ( %s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s )"

print(sql)

try:

# 执行sql语句

cursor.executemany(sql, datalist)

# 提交到数据库执行

db.commit()

except Exception as e:

print(e)

# 如果发生错误则回滚

db.rollback()

最后，执行上面的三个python文件，注意取stock_daily的python是需要加日期作为参数的，这样可以灵活的取一天的数据入表，或写一个批处理，将一年的数据一次性存入表中。

结尾，这样，最基础的股票交易日期、股票列表、股票日K线，就已经存入数据库表中了，后面即可按自己的想法进行量化分析。

Tushare的接口远不止以上三种，各位可自行参阅网站上的股票接口文档，进行相应的资料获取和存放。

进坛潜水多年，第一次发帖，如有不当之处，请版主指正。

这篇关于python股票接口_Python3利用Tushare接口结合mysql进行股票量化分析入门的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/740512。

相关文章

kotlin中const 和val的区别及使用场景分析

kotlin中const 和val的区别及使用场景分析

《kotlin中const和val的区别及使用场景分析》在Kotlin中,const和val都是用来声明常量的,但它们的使用场景和功能有所不同,下面给大家介绍kotlin中const和val的区别,... 目录kotlin中const 和val的区别1. val:2. const:二 代码示例1 Java
阅读更多...
Python基础文件操作方法超详细讲解(详解版)

Python基础文件操作方法超详细讲解(详解版)

《Python基础文件操作方法超详细讲解(详解版)》文件就是操作系统为用户或应用程序提供的一个读写硬盘的虚拟单位,文件的核心操作就是读和写,：本文主要介绍Python基础文件操作方法超详细讲解的相... 目录一、文件操作1. 文件打开与关闭1.1 打开文件1.2 关闭文件2. 访问模式及说明二、文件读写1.
阅读更多...
Ubuntu中远程连接Mysql数据库的详细图文教程

Ubuntu中远程连接Mysql数据库的详细图文教程

《Ubuntu中远程连接Mysql数据库的详细图文教程》Ubuntu是一个以桌面应用为主的Linux发行版操作系统,这篇文章主要为大家详细介绍了Ubuntu中远程连接Mysql数据库的详细图文教程,有... 目录1、版本2、检查有没有mysql2.1 查询是否安装了Mysql包2.2 查看Mysql版本2.
阅读更多...
基于SpringBoot+Mybatis实现Mysql分表

基于SpringBoot+Mybatis实现Mysql分表

《基于SpringBoot+Mybatis实现Mysql分表》这篇文章主要为大家详细介绍了基于SpringBoot+Mybatis实现Mysql分表的相关知识,文中的示例代码讲解详细,感兴趣的小伙伴可... 目录基本思路定义注解创建ThreadLocal创建拦截器业务处理基本思路1.根据创建时间字段按年进
阅读更多...
Python3.6连接MySQL的详细步骤

Python3.6连接MySQL的详细步骤

《Python3.6连接MySQL的详细步骤》在现代Web开发和数据处理中,Python与数据库的交互是必不可少的一部分,MySQL作为最流行的开源关系型数据库管理系统之一,与Python的结合可以实... 目录环境准备安装python 3.6安装mysql安装pymysql库连接到MySQL建立连接执行S
阅读更多...
Python将博客内容html导出为Markdown格式

Python将博客内容html导出为Markdown格式

《Python将博客内容html导出为Markdown格式》Python将博客内容html导出为Markdown格式,通过博客url地址抓取文章,分析并提取出文章标题和内容,将内容构建成html,再转... 目录一、为什么要搞？二、准备如何搞？三、说搞咱就搞！抓取文章提取内容构建html转存markdown
阅读更多...
Python获取中国节假日数据记录入JSON文件

Python获取中国节假日数据记录入JSON文件

《Python获取中国节假日数据记录入JSON文件》项目系统内置的日历应用为了提升用户体验,特别设置了在调休日期显示“休”的UI图标功能,那么问题是这些调休数据从哪里来呢？我尝试一种更为智能的方法：P... 目录节假日数据获取存入jsON文件节假日数据读取封装完整代码项目系统内置的日历应用为了提升用户体验，
阅读更多...
Go标准库常见错误分析和解决办法

Go标准库常见错误分析和解决办法

《Go标准库常见错误分析和解决办法》Go语言的标准库为开发者提供了丰富且高效的工具,涵盖了从网络编程到文件操作等各个方面,然而,标准库虽好,使用不当却可能适得其反,正所谓工欲善其事,必先利其器,本文将... 目录1. 使用了错误的time.Duration2. time.After导致的内存泄漏3. jsO
阅读更多...
Python FastAPI+Celery+RabbitMQ实现分布式图片水印处理系统

Python FastAPI+Celery+RabbitMQ实现分布式图片水印处理系统

《PythonFastAPI+Celery+RabbitMQ实现分布式图片水印处理系统》这篇文章主要为大家详细介绍了PythonFastAPI如何结合Celery以及RabbitMQ实现简单的分布式... 实现思路FastAPI 服务器Celery 任务队列RabbitMQ 作为消息代理定时任务处理完整
阅读更多...
使用Jackson进行JSON生成与解析的新手指南

使用Jackson进行JSON生成与解析的新手指南

《使用Jackson进行JSON生成与解析的新手指南》这篇文章主要为大家详细介绍了如何使用Jackson进行JSON生成与解析处理,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1. 核心依赖2. 基础用法2.1 对象转 jsON（序列化）2.2 JSON 转对象（反序列化）3.
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2