增加并行数量

admin

2025-04-08 70b51a2636858fb8cfbf39d3764d88d07286d8ad

 strategy/all_fundamentals.py

@@ -1,8 +1,8 @@
'''
获取所有股票基本面数据
'''

# 引入掘金API
# todo  解决掘金api 数据 的引入问题
from gm.api import *
# 引入基础方法
import basic_methods
@@ -10,13 +10,13 @@
import data_cache

# 调用推算前N日交易日期的函数
start_time_data = basic_methods.pre_num_trading_day(data_cache.DataCache.today_date, 90)
start_time_data = basic_methods.pre_num_trading_day(data_cache.DataCache().today_date, 90)
'''
股票交易衍生表
'''
# trading_derivative_indicator = get_fundamentals(table='trading_derivative_indicator', symbols='SHSE.601777', start_date=start_time_data, end_date=data_cache.today_date, fields='DY,EV,EVEBITDA,EVPS,LYDY,NEGOTIABLEMV,PB,PELFYNPAAEI,PETTMNPAAEI,TURNRATE', df=True)
# print(f"trading_derivative_indicator===\n{trading_derivative_indicator}")
trading_derivative_indicator_1 = get_fundamentals(table='trading_derivative_indicator', symbols='SZSE.000890', start_date=start_time_data, end_date=data_cache.DataCache.today_date, fields='NEGOTIABLEMV', df=False)
trading_derivative_indicator_1 = get_fundamentals(table='trading_derivative_indicator', symbols='SZSE.000890', start_date=start_time_data, end_date=data_cache.DataCache().today_date, fields='NEGOTIABLEMV', df=False)
# print(f"trading_derivative_indicator_1===\n{trading_derivative_indicator_1[0]}")
for i in trading_derivative_indicator_1:
    # 流通市值
@@ -26,7 +26,7 @@
'''
衍生财务指标
'''
deriv_finance_indicator = get_fundamentals(table='deriv_finance_indicator', symbols='SZSE.000890', start_date=start_time_data, end_date=data_cache.DataCache.today_date, fields='FCFE, FCFF', df=False)
deriv_finance_indicator = get_fundamentals(table='deriv_finance_indicator', symbols='SZSE.000890', start_date=start_time_data, end_date=data_cache.DataCache().today_date, fields='FCFE, FCFF', df=False)
# print(f"deriv_finance_indicator===\n{deriv_finance_indicator[0]}")
for i in deriv_finance_indicator: