|
|
@@ -96,7 +96,6 @@ def hlfx(data, stocks, pool_list):
|
|
|
engine_stock = create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/qmt_stocks_tech?charset=utf8')
|
|
|
print(stocks)
|
|
|
for qmt_stock in stocks:
|
|
|
- stock = qmt_stock.replace('SH', 'XSHG').replace('SZ', 'XSHE')
|
|
|
# 读取qmt_stocks_whole表-前复权-信息
|
|
|
try:
|
|
|
df_day = pd.read_sql_query(
|
|
|
@@ -104,7 +103,7 @@ def hlfx(data, stocks, pool_list):
|
|
|
% (qmt_stock, fre), engine_stock)
|
|
|
df_day.columns=['time', 'open', 'close', 'high', 'low', 'volume', 'amount', 'dif', 'dea', 'macd','HL']
|
|
|
except BaseException:
|
|
|
- print(stock)
|
|
|
+ print(qmt_stock)
|
|
|
pass
|
|
|
else:
|
|
|
# 获得最新价格信息
|
