|
@@ -38,6 +38,7 @@ for stock in stocks:
|
|
index_len = pd.read_sql_table('stk%s_%s' % (stock, fre), con=engine2).iloc[-1, 0]
|
|
index_len = pd.read_sql_table('stk%s_%s' % (stock, fre), con=engine2).iloc[-1, 0]
|
|
# 注意修改time delta
|
|
# 注意修改time delta
|
|
startdate = pd.read_sql_table('stk%s_%s' % (stock, fre), con=engine2).iloc[-1, 1]
|
|
startdate = pd.read_sql_table('stk%s_%s' % (stock, fre), con=engine2).iloc[-1, 1]
|
|
|
|
+ # startdate = pd.read_sql_table('stk%s_%s' % (stock, fre), con=engine2).iloc[-1, 1] + datetime.timedelta(minutes= 5)
|
|
thd.get_price = pd.read_sql_query(
|
|
thd.get_price = pd.read_sql_query(
|
|
'select date,open,close,high,low,volume,money from `stk%s_%s`' % (stock, fre), engine)
|
|
'select date,open,close,high,low,volume,money from `stk%s_%s`' % (stock, fre), engine)
|
|
thd.get_price = thd.get_price.loc[thd.get_price['date'] > startdate]
|
|
thd.get_price = thd.get_price.loc[thd.get_price['date'] > startdate]
|