|
@@ -6,6 +6,7 @@ from sqlalchemy import create_engine
|
|
|
import multiprocessing as mp
|
|
import multiprocessing as mp
|
|
|
import os
|
|
import os
|
|
|
from apscheduler.schedulers.blocking import BlockingScheduler
|
|
from apscheduler.schedulers.blocking import BlockingScheduler
|
|
|
|
|
+import traceback
|
|
|
|
|
|
|
|
|
|
|
|
|
pd.set_option('display.max_columns', None) # 设置显示最大行
|
|
pd.set_option('display.max_columns', None) # 设置显示最大行
|
|
@@ -20,6 +21,7 @@ eng_w = create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/qmt_stoc
|
|
|
|
|
|
|
|
def err_call_back(err):
|
|
def err_call_back(err):
|
|
|
print(f'问题在这里~ error：{str(err)}')
|
|
print(f'问题在这里~ error：{str(err)}')
|
|
|
|
|
+ traceback.print_exc()
|
|
|
|
|
|
|
|
|
|
|
|
|
def to_sql(stock_list):
|
|
def to_sql(stock_list):
|
