#-*-coding:utf-8-*-"""第一步：更新股票池和日历"""importakshareasak#删除本地数据----------------------------------------------------------------------defdele:importpymysqlconnection=pymysql.connectdriver=connection.cursorsql="DELETEFROMdays"driver.executeconnection.commitprintconnection.closedefone:#dele#交易日历，全量更新index_zh_a_hist_df=ak.index_zh_a_histindex_zh_a_hist_df["last_day"]=index_zh_a_hist_df["日期"].shifttemp=index_zh_a_hist_dfforindein["涨跌幅"]:foriin[5,10,20,40]:temp[inde+str]=temp[inde].rolling.sumforindein["换手率"]:foriin[5,10,20,40]:temp[inde+str]=temp[inde].rolling.meantemp.to_sqlprint)stock_comment_em_df=ak.stock_comment_emcodes=stock_comment_em_df[["代码","名称"]]codes.to_sqlprint)
文章为作者独立观点，不代表股票配资公司观点
相关文章
股民评论