如何从Tushare获取股票数据存到MySQL？-量化交易-财云量化

摘要：

主要内容为从Tushare获取上市股票每日行情数据并存入MySQL的步骤、准备工作与注意事项，包含获取APIToken等重要信息。

一、准备工作的重要性

在开始从Tushare获取股票数据并存储到MySQL的旅程之前，准备工作就像是盖房子打地基一样，是整个过程的关键。

（一）Python环境与相关库的安装

我们得确保Python环境已经安装好。Python就像是一个万能的工具包，很多数据处理相关的任务都依赖它。然后呢，要安装Tushare库。这就好比是打开Tushare数据宝藏的钥匙。通过简单的命令pipinstalltushare-pro就能把这个钥匙拿到手。

如何从Tushare获取股票数据存到MySQL？

还需要安装pandas和mysql-connector-python这两个库。pandas是处理数据的小能手，能让数据的整理、分析变得轻松自如。而mysql-connector-python则是连接Python和MySQL数据库的桥梁，没有它，数据就没办法顺利地从Tushare跑到MySQL里。安装这两个库也很简单，同样使用pip命令，像pipinstallpandasmysql-connector-python这样就搞定了。

（二）MySQL数据库的准备

MySQL数据库就像是一个巨大的数据仓库，我们要把从Tushare获取到的数据存放在这里。要先确保这个仓库已经搭建好，而且我们有足够的权限往里面写入数据。如果没有做好这些准备，后续的工作就像是在没有路的荒野上开车，根本走不通。

二、获取TushareAPIToken

（一）注册账号

要从Tushare获取数据，APIToken是必不可少的。这就需要我们到Tushare的官网去注册一个账号。这个过程就像是去一个神秘的俱乐部办理会员卡一样，只有有了会员卡（APIToken），我们才能进入这个数据的世界。

（二）保管好Token

注册成功后得到的APIToken一定要妥善保管。这个Token就像是一把独一无二的钥匙，一旦丢失或者泄露，可能会带来一些不必要的麻烦，比如数据安全问题或者无法正常获取数据等。我们要把它放在一个安全的地方，并且在编写代码的时候准确无误地使用它。

三、编写Python脚本的奥秘

（一）导入必要的库

在Python脚本的开头，我们要导入几个重要的库。tushare库用来获取股票数据，pandas库用于数据处理，mysql.connector库用于连接MySQL数据库。就像是召集一群各有所长的小伙伴来一起完成一个大项目。

importtushareastsimportpandasaspdimportmysql.connectorfrommysql.connectorimportError

（二）设置TusharePro的Token

我们要把之前获取到的APIToken告诉Tushare，这样它才知道是我们在请求数据。通过ts.set_token('你的Token')这行代码就能做到，不过要记得把'你的Token'替换成真正的Token哦。然后再创建一个pro对象，这个对象就像是我们和Tushare交流的使者。

ts.set_token('你的Token')pro=ts.pro_api()

（三）连接到MySQL数据库

接下来就是连接MySQL数据库啦。这就像是在两座岛屿之间架起一座桥梁。我们需要提供数据库的地址、名称、用户名和密码等信息。如果连接成功，我们就能得到关于数据库服务器的一些信息，像版本号之类的。然后创建一个游标（cursor），这个游标就像是一个小指针，它能帮助我们在数据库里执行各种操作。

try:connection=mysql.connector.connect(host='你的数据库地址',database='你的数据库名',user='你的用户名',password='你的密码')ifconnection.is_connected():db_Info=connection.get_server_info()print(f"成功连接到MySQL数据库，服务器版本：{db_Info}")cursor=connection.cursor()

（四）获取股票列表并创建数据表

我们要先获取所有正常上市交易的股票列表。通过pro.stock_basic(list_status='L')['ts_code'].tolist()这行代码就能得到股票代码的列表。然后呢，我们要在MySQL数据库里创建一个数据表来存放这些股票的行情数据。这个数据表的结构要根据Tushare提供的数据结构来设计，就像盖房子要按照设计图纸来一样。

#获取所有正常上市交易的股票列表stock_list=pro.stock_basic(list_status='L')['ts_code'].tolist()#创建数据表（如果不存在）create_table_query="""CREATETABLEIFNOTEXISTSstock_daily(ts_codeVARCHAR(20)PRIMARYKEY,trade_dateDATE,openFLOAT,highFLOAT,lowFLOAT,closeFLOAT,volumeBIGINT,amountFLOAT,adj_factorFLOAT,...)"""cursor.execute(create_table_query)

（五）循环获取和存储数据

这是整个脚本的核心部分。我们要对每一只股票进行操作，先获取它的日线行情数据，然后对数据进行一些处理，确保它的格式适合存储到MySQL数据库里。接着把数据转换成可以插入数据库的记录条目，再通过SQL语句把数据插入到数据库中。如果插入成功就皆大欢喜，如果失败了就要进行回滚操作，避免数据出现混乱。

forts_codeinstock_list:#获取日线行情数据data=pro.daily(ts_code=ts_code,start_date='开始日期',end_date='结束日期')ifnotdata.empty:#数据处理，确保格式适合MySQLdata['trade_date']=data['trade_date'].astype(str)data['ts_code']=data['ts_code'].astype(str)#将数据转换为记录条目，准备插入forindex,rowindata.iterrows():insert_query=f"""INSERTINTOstock_daily(ts_code,trade_date,open,high,low,close,volume,amount,adj_factor)VALUES('{row['ts_code']}','{row['trade_date']}',{row['open']},{row['high']},{row['low']},{row['close']},{row['volume']},{row['amount']},{row['adj_factor']})"""try:cursor.execute(insert_query)connection.commit()print(f"插入数据成功：{ts_code}{row['trade_date']}")exceptErrorase:connection.rollback()print(f"插入数据失败：{e}")else:print(f"没有找到数据：{ts_code}")

四、注意事项要牢记

（一）代码中的替换内容

在我们编写的代码里，有很多地方需要替换成我们自己的信息。比如'你的Token'要换成真正的APIToken，数据库连接信息（host、database、user、password）也要根据实际情况填写正确。还有日期范围也要根据我们的需求设定好，这就像是在给一个精密的仪器调整参数一样，一点都不能马虎。

（二）表结构与数据类型的匹配

MySQL表的结构一定要和Tushare提供的数据字段相匹配，包括数据类型。如果不匹配的话，就像把不合适的零件硬塞到机器里一样，肯定会出问题的。这就需要我们仔细地研究Tushare的数据结构，然后合理地设计MySQL表的结构。

（三）提高效率的方法

考虑到数据量可能非常大，循环插入数据的方式可能会很慢。这时候我们可以考虑批量插入来提高效率。就像一次搬很多东西比一次搬一个东西要快很多一样。

（四）数据处理的全面性

在实际应用中，处理大量数据时，要考虑很多方面的问题。异常处理是很重要的，如果出现了错误，我们要有应对的方法，不能让程序直接崩溃。数据清洗也不能忽视，要把一些错误的数据或者不需要的数据清理掉。还有性能优化，要让整个程序运行得又快又好。

（五）Tushare的访问限制

Tushare有访问频率的限制，如果我们频繁地请求数据，可能会导致API调用受限。这就像是一个商店规定了每人每天只能购买一定数量的商品一样。我们要合理地安排请求间隔，或者如果有条件的话，可以使用Tushare的高级服务来避免这个问题。这样才能持续稳定地获取到我们需要的数据。

万一免五开户