好假设你已安装了python+akshare等模块并且成功部署mysql数据库的话
那么接下来就会有很多难题等着你!
- 首先是无法连接的问题:MySQL错误:Access denied for user ‘root’@’%’ to database ‘mytest’
解决方法:新建一个账户注意:这里的主机一定填入%否则无法外网连接;其次插件选择“mysql_native_password”
并且注意密码长度要超过十个字符,并且他叫你有特殊字符(special character) 并不是那种“罕见”的如“@”等,否则就会引出第二个问题
sqlalchemy.exc.InterfaceError: (mysql.connector.errors.InterfaceError) 2003: Can’t connect to MySQL server on ‘Qq.com@192.168.1.9:3306’ (11003 getaddrinfo failed)
解决方法:密码换成简单一点的 尽量不包含特殊字符的
PYTHON抓取个股历史价格数据插入数据库并且自动创建表
使用AKSHARE + mysql 实现动态抓取个股的交易历史数据
同理外面再包一层循环就可以把所有的交易历史数据下载每个股票一个表。
#使用AKSHARE + mysql 实现动态抓取个股的交易历史数据
3同理外面再包一层循环就可以把所有的交易历史数据下载每个股票一个表。
import pandas as pd
import mysql.connector
from sqlalchemy import create_engine
import akshare as ak
stock_zh_a_hist_df = ak.stock_zh_a_hist(symbol="000001", period="daily", start_date="20170301", end_date='20210907', adjust="")
data = stock_zh_a_hist_df
engine = create_engine("mysql+mysqlconnector://root:123456@localhost:3306/stock?charset=utf8")
data.to_sql("test_table", engine, index=False)
参考资料:https://www.cnblogs.com/ddtrs/p/16950659.html PYTHON 动态抓取个股历史价格数据插入数据库并且自动创建表
后续:研究动态更新 更省流量
© 版权声明
文章版权归作者所有,未经允许请勿转载。
THE END
暂无评论内容