|
@@ -95,7 +95,7 @@ def err_call_back(err):
|
|
|
def hlfx(data, stocks, pool_list):
|
|
def hlfx(data, stocks, pool_list):
|
|
|
engine_stock = create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/qmt_stocks_tech?charset=utf8')
|
|
engine_stock = create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/qmt_stocks_tech?charset=utf8')
|
|
|
print(stocks)
|
|
print(stocks)
|
|
|
- for qmt_stock in stocks[0:2]:
|
|
|
|
|
|
|
+ for qmt_stock in stocks:
|
|
|
stock = qmt_stock.replace('SH', 'XSHG').replace('SZ', 'XSHE')
|
|
stock = qmt_stock.replace('SH', 'XSHG').replace('SZ', 'XSHE')
|
|
|
# 读取qmt_stocks_whole表-前复权-信息
|
|
# 读取qmt_stocks_whole表-前复权-信息
|
|
|
try:
|
|
try:
|
|
@@ -275,9 +275,7 @@ def bridge(data):
|
|
|
password='r6kEwqWU9!v3',
|
|
password='r6kEwqWU9!v3',
|
|
|
database='hlfx_pool')
|
|
database='hlfx_pool')
|
|
|
cursor_pool = db_pool.cursor()
|
|
cursor_pool = db_pool.cursor()
|
|
|
- print('建立-HLFX-池链接')
|
|
|
|
|
|
|
|
|
|
- print(results)
|
|
|
|
|
print(set(results))
|
|
print(set(results))
|
|
|
results_list = ','.join(set(results))
|
|
results_list = ','.join(set(results))
|
|
|
sql = "INSERT INTO %s (date,value) VALUES('%s','%s')" % (fre, dt.now().strftime('%Y-%m-%d %H:%M:%S'), results_list)
|
|
sql = "INSERT INTO %s (date,value) VALUES('%s','%s')" % (fre, dt.now().strftime('%Y-%m-%d %H:%M:%S'), results_list)
|
