Python股票处理之七_数据库存储

2023年9月26日 226次阅读 来源: xieyan0811

1. 说明

股票数据无需每次都从网上下载，像日线级别的历史数据会常常用到，使用多线程下载一般也需要几个小时，最好存储到本地，除了已有的特征值，还有清洗后的数据，和计算出的新特征值，以及需要与其它程序共享数据。相对于数据文件，使用数据库更合适。
本文介绍pandas（数据结构支持）通过sqlalchemy与数据库连接，存储tushare下载的日线数据，用一套代码操作不同数据库（Mysql/sqlite）。

2. 安装数据库

1) Sqlalchemy工具

$ pip install sqlalchemy

2) Mysql数据库

$ sudo apt-get install mysql-server
$ sudo apt-get install mysql-client
$ mysql -u root –p
mysql> create database stock    # 建立名为stock的数据库，之后程序中会用到
mysql> show databases;  # 显示已有的数据库

3) Sqlite数据库

$ sudo apt install sqlite3  
$ sqlite stock.db   # stock.db是数据库文件，将在运行示例程序时生成
sqlite > .tables        # 查看数据表
sqlite > select * from s002230; # 遍历表s002230中的数据

（也可使用图形界面工具sqliteman查看数据库）

3. 程序

# -*- coding: utf-8 -*-

import tushare as ts
from sqlalchemy import create_engine
import pandas as pd

#ADDR = 'mysql://root:1234@localhost:3306/stock?charset=utf8'   # 使用mysql，用户名root,密码1234，库名为stock，端口3306为mysql默认端口
ADDR = 'sqlite:///stock.db'     # 使用sqlite，当前目录的stock.db作为数据库文件

engine = create_engine(ADDR)
stocklist = ['002230','601318']

def save(code):
    print "save code:",code
    try:
        df = ts.get_h_data(code, start='1990-01-01', retry_count = 5)
        df = df.sort_index(ascending=True)
        name = 's'+code
        df.to_sql(name, engine, if_exists='fail')
    except:
        print code, " save failed"

for i in range(0, len(stocklist)):
    save(stocklist[i])

4. 其它

1) 运行SQL语句

sqlalchemy也支持直接运行SQL语句，形如：

result = engine.execute(‘select * from stock’)

使用sqlalchemy后，除了方便与pandas中的数据对接以外，也基本屏蔽了不同数据库之间的差异，换库时无需大量调整代码，十分方便。

2) 多线程下载

历史日线数据量较大，可使用python中的multiprocessing.dummy.Pool多线程下载。

3) 从数据库中读出数据

和to_sql相对的是read_sql，它可以从数据库中读出数据，并转换成DataFrame的格式。具体使用形如：
stocklist = pd.read_sql(‘table1’,engine) # 其中stocklist是DataFrame格式数据，pd是import pandas as pd，table1是库名，engine同上例一样，指向数据库。

    原文作者：xieyan0811
    原文地址: https://www.jianshu.com/p/424d16bb15a7
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞