TuShare(2):使用TuShare,抓取股票数据并存储到数据库

简介: 本文的原文连接是: http://blog.csdn.net/freewebsys/article/details/50904965 未经博主允许不得转载。 博主地址是:http://blog.csdn.net/freewebsys1,关于股票数据存储股票数据比较特殊,需要做数据统计的。都需要一次进行批量查询多个数据,然后进行分析。 所以股票数据不一定要放到数

本文的原文连接是: http://blog.csdn.net/freewebsys/article/details/50904965 未经博主允许不得转载。
博主地址是:http://blog.csdn.net/freewebsys

1,关于股票数据存储


股票数据比较特殊,需要做数据统计的。都需要一次进行批量查询多个数据,然后进行分析。
所以股票数据不一定要放到数据库中存储。因为一般就两个维度。
那只股票,和那天的股票信息,然后使用模型进行分析预测。
所以数据可以存储为:/data/stock/yyyy/yyyMM/yyyyMMdd.hdf5
存储的数据是hdf5:
Hierarchical Data Format,可以存储不同类型的图像和数码数据的文件格式

2,安装hdf5库


#首先安装hdf5库
yum -y install hdf5 hdf5-devel
pip install unittest2
pip install --upgrade  tables

3,测试读写hdf5文件


参考pytables官方文档。
http://www.pytables.org/usersguide/tutorials.html
这里使用的是pandas封装的接口直接使用,而不是使用tables。

# python
Python 2.6.6 (r266:84292, Jul 23 2015, 15:22:56) 
[GCC 4.4.7 20120313 (Red Hat 4.4.7-11)] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>> import numpy as np
>>> import pandas as pd
###su
>>> a = np.random.standard_normal((9,4))
>>> b = pd.DataFrame(a)
>>> b.columns = [['num1','num2','num3','num4']]
>>> a
array([[-2.36198849, -1.27547933, -1.40351822, -0.6638619 ],
       [ 1.89159066, -0.31838519, -0.2065942 , -1.02327987],
       [-2.02771503, -0.81333254, -0.93644288, -0.91592467],
       [-1.3939496 ,  0.25899342,  1.11591841, -0.7423286 ],
       [-1.05104415, -0.79069151, -1.46536873, -0.01449547],
       [ 1.32483444,  0.32030117, -1.23575344,  0.51455106],
       [ 0.91297435,  0.43242834,  1.77235337,  1.14879289],
       [ 0.93476429,  0.18592698,  0.30198234, -0.61861642],
       [ 0.04462872, -0.99275411, -0.86382085, -1.53064223]])
>>> b
       num1      num2      num3      num4
0 -2.361988 -1.275479 -1.403518 -0.663862
1  1.891591 -0.318385 -0.206594 -1.023280
2 -2.027715 -0.813333 -0.936443 -0.915925
3 -1.393950  0.258993  1.115918 -0.742329
4 -1.051044 -0.790692 -1.465369 -0.014495
5  1.324834  0.320301 -1.235753  0.514551
6  0.912974  0.432428  1.772353  1.148793
7  0.934764  0.185927  0.301982 -0.618616
8  0.044629 -0.992754 -0.863821 -1.530642
>>> b.sum()
num1   -1.725905
num2   -2.992993
num3   -2.921244
num4   -3.845805
dtype: float64
>>> b.mean()
num1   -0.191767
num2   -0.332555
num3   -0.324583
num4   -0.427312
dtype: float64

###写hdf5文件:
>>> h5 = pd.HDFStore('/data/stock/test1.h5','w')
>>> h5['data'] = b
>>> h5.close()
>>> 
>>> b
       num1      num2      num3      num4
0 -2.361988 -1.275479 -1.403518 -0.663862
1  1.891591 -0.318385 -0.206594 -1.023280
2 -2.027715 -0.813333 -0.936443 -0.915925
3 -1.393950  0.258993  1.115918 -0.742329
4 -1.051044 -0.790692 -1.465369 -0.014495
5  1.324834  0.320301 -1.235753  0.514551
6  0.912974  0.432428  1.772353  1.148793
7  0.934764  0.185927  0.301982 -0.618616
8  0.044629 -0.992754 -0.863821 -1.530642

###读hdf5文件。
>>> h5 = pd.HDFStore('/data/stock/test1.h5','r')
>>> c = h5['data']
>>> c
       num1      num2      num3      num4
0 -2.361988 -1.275479 -1.403518 -0.663862
1  1.891591 -0.318385 -0.206594 -1.023280
2 -2.027715 -0.813333 -0.936443 -0.915925
3 -1.393950  0.258993  1.115918 -0.742329
4 -1.051044 -0.790692 -1.465369 -0.014495
5  1.324834  0.320301 -1.235753  0.514551
6  0.912974  0.432428  1.772353  1.148793
7  0.934764  0.185927  0.301982 -0.618616
8  0.044629 -0.992754 -0.863821 -1.530642
>>> h5.close()

4,TuShare读取股票数据存储


>>> import tushare as ts
>>> d = ts.get_tick_data('600848',date='2015-01-09')
>>> type(d)
<class 'pandas.core.frame.DataFrame'>
>>> len(d)
1212
###保存数据
>>> h5 = pd.HDFStore('/data/stock/test2.h5','w')
>>> h5['data'] = d
>>> h5.close()
>>> 
>>> 
###读取数据
>>> h5 = pd.HDFStore('/data/stock/test2.h5','r')
>>> e = h5['data']
>>> h5.close()
>>> 
>>> type(e)
<class 'pandas.core.frame.DataFrame'>
>>> len(e)
1212

5,总结


本文的原文连接是: http://blog.csdn.net/freewebsys/article/details/50904965 未经博主允许不得转载。
博主地址是:http://blog.csdn.net/freewebsys

使用文件直接存储到本地还是非常方便的。pandas直接封装的函数3行解决问题。
同时pandas封装的读出数据还是数组,可以直接进行操作。灰常方便。

目录
相关文章
|
存储 Oracle 关系型数据库
服务器数据恢复—光纤存储上oracle数据库数据恢复案例
一台光纤服务器存储上有16块FC硬盘,上层部署了Oracle数据库。服务器存储前面板2个硬盘指示灯显示异常,存储映射到linux操作系统上的卷挂载不上,业务中断。 通过storage manager查看存储状态,发现逻辑卷状态失败。再查看物理磁盘状态,发现其中一块盘报告“警告”,硬盘指示灯显示异常的2块盘报告“失败”。 将当前存储的完整日志状态备份下来,解析备份出来的存储日志并获得了关于逻辑卷结构的部分信息。
|
存储 JSON 关系型数据库
【干货满满】解密 API 数据解析:从 JSON 到数据库存储的完整流程
本文详解电商API开发中JSON数据解析与数据库存储的全流程,涵盖数据提取、清洗、转换及优化策略,结合Python实战代码与主流数据库方案,助开发者构建高效、可靠的数据处理管道。
|
存储 数据管理 数据库
数据字典是什么?和数据库、数据仓库有什么关系?
在数据处理中,你是否常困惑于字段含义、指标计算或数据来源?数据字典正是解答这些问题的关键工具,它清晰定义数据的名称、类型、来源、计算方式等,服务于开发者、分析师和数据管理者。本文详解数据字典的定义、组成及其与数据库、数据仓库的关系,助你夯实数据基础。
数据字典是什么?和数据库、数据仓库有什么关系?
|
数据采集 关系型数据库 MySQL
python爬取数据存入数据库
Python爬虫结合Scrapy与SQLAlchemy,实现高效数据采集并存入MySQL/PostgreSQL/SQLite。通过ORM映射、连接池优化与批量提交,支持百万级数据高速写入,具备良好的可扩展性与稳定性。
|
人工智能 Java 关系型数据库
使用数据连接池进行数据库操作
使用数据连接池进行数据库操作
321 11
|
存储 关系型数据库 数据库
【赵渝强老师】PostgreSQL数据库的WAL日志与数据写入的过程
PostgreSQL中的WAL(预写日志)是保证数据完整性的关键技术。在数据修改前,系统会先将日志写入WAL,确保宕机时可通过日志恢复数据。它减少了磁盘I/O,提升了性能,并支持手动切换日志文件。WAL文件默认存储在pg_wal目录下,采用16进制命名规则。此外,PostgreSQL提供pg_waldump工具解析日志内容。
1265 0
|
缓存 关系型数据库 BI
使用MYSQL Report分析数据库性能(下)
使用MYSQL Report分析数据库性能
768 158
|
关系型数据库 MySQL 数据库
自建数据库如何迁移至RDS MySQL实例
数据库迁移是一项复杂且耗时的工程,需考虑数据安全、完整性及业务中断影响。使用阿里云数据传输服务DTS,可快速、平滑完成迁移任务,将应用停机时间降至分钟级。您还可通过全量备份自建数据库并恢复至RDS MySQL实例,实现间接迁移上云。
|
关系型数据库 MySQL 数据库
阿里云数据库RDS费用价格:MySQL、SQL Server、PostgreSQL和MariaDB引擎收费标准
阿里云RDS数据库支持MySQL、SQL Server、PostgreSQL、MariaDB,多种引擎优惠上线!MySQL倚天版88元/年,SQL Server 2核4G仅299元/年,PostgreSQL 227元/年起。高可用、可弹性伸缩,安全稳定。详情见官网活动页。
1992 152

热门文章

最新文章