def get_hist_data(code, name, start_data):
try:
# start_data = datetime.datetime.strptime(str(start_data), '%Y%m%d').strftime('%Y-%m-%d')
df = ts.bar(code, conn=conn, start_date=start_data, adj='qfq')
except Exception, e:
print e
return
hist_con = get_engine('history')
df.insert(1, 'name', name)
df = df.reset_index()
#print df
df2=pd.read_sql_table(code,hist_con,index_col='index')
try:
new_df = pd.concat([df,df2])
new_df = new_df.reset_index(drop=True)
new_df.to_sql(code, engine, if_exists='replace')
except Exception, e:
print e
return
评论列表
文章目录