# -*-編碼:UTF-8 -*-
將tushare作為ts導入
從sqlalchemy導入創建引擎
code_list = []
#數據庫鏈接參數
host = '10.0.0.5 '
端口= 3306
user = 'root '
密碼= 'qweqwe '
數據庫= '股票'
charset = "utf8 "
table = "stock_data "
# create table stock _ data(id int auto _ increment,code int(6) zerofill,date date not null,open decimal(10,2) not null,high decimal(10,2) not null,close decimal(10,2) not null,low decimal(10,2) not null,volume decimal(10,2),營業額decimal(10,2),主鍵(id
def get_data(代碼):
df = ts.get_hist_data(代碼)
data = df.iloc[::-1,[0,1,2,3,4,13]]
數據["代碼"] =代碼
返回數據
def save_data_to_mysql (data,user = 'root ',password = 'qweqwe ',database = 'stock ',charset = "utf8 ",table = "stock_data "):
engine = create _ engine(' MySQL://'+用戶+ ':' +密碼+ '@' +主機+ '/' +數據庫+'?charset=' + charset)
data.to_sql(表,引擎,if_exists='append ')
返回
對於code_list中的代碼:
嘗試:
數據=獲取數據(代碼)
保存數據到mysql(數據)
打印字符串(代碼)+“MySQL導入成功”
除了:
打印字符串(代碼)+“無法獲取數據”