abupy.AlphaBu package¶
Submodules¶
abupy.AlphaBu.ABuAlpha module¶
abupy.AlphaBu.ABuPickBase module¶
择时与选股抽象基类
abupy.AlphaBu.ABuPickStockExecute module¶
包装选股worker进行,完善前后工作
abupy.AlphaBu.ABuPickStockMaster module¶
选股并行多任务调度模块
-
class
abupy.AlphaBu.ABuPickStockMaster.
AbuPickStockMaster
[源代码]¶ Bases:
object
选股并行多任务调度类
-
classmethod
do_pick_stock_with_process
(capital, benchmark, stock_pickers, choice_symbols=None, n_process_pick_stock=4, callback=None)[源代码]¶ 选股并行多任务对外接口 :param capital: 资金类AbuCapital实例化对象 :param benchmark: 交易基准对象,AbuBenchmark实例对象 :param stock_pickers: 选股因子序列 :param choice_symbols: 初始备选交易对象序列 :param n_process_pick_stock: 控制启动多少进程并行选股操作 :param callback: 并行选股工作函数 :return: 最终选股结果序列
-
classmethod
do_pick_stock_with_process_mix_thread
(*args, **kwargs)¶ Deprecated: hdf5 store mode will crash or dead! Deprecated不应该使用,因为默认hdf5多线程读取会有问题
-
classmethod
abupy.AlphaBu.ABuPickStockWorker module¶
选股具体工作者,整合金融时间序列,选股因子,资金类进行 选股操作,在择时金融时间序列之前一段时间上迭代初始交易对象 进行选股因子的拟合操作
-
class
abupy.AlphaBu.ABuPickStockWorker.
AbuPickStockWorker
(capital, benchmark, kl_pd_manager, choice_symbols=None, stock_pickers=None)[源代码]¶ Bases:
abupy.AlphaBu.ABuPickBase.AbuPickStockWorkBase
选股类
abupy.AlphaBu.ABuPickTimeExecute module¶
多支交易对象进行择时操作封装模块,内部通过AbuPickTimeWorker进行 择时,包装完善前后工作,包括多进程下的进度显示,错误处理捕获,结果 处理等事务
-
class
abupy.AlphaBu.ABuPickTimeExecute.
EFitError
[源代码]¶ Bases:
enum.Enum
择时操作的错误码
-
DATE_ERROR
= 2¶
-
FIT_OK
= 0¶
-
NET_ERROR
= 1¶
-
NO_ORDER_GEN
= 3¶
-
OTHER_ERROR
= 4¶
-
-
abupy.AlphaBu.ABuPickTimeExecute.
do_symbols_with_diff_factors
(target_symbols, benchmark, factor_dict, capital, apply_capital=True, kl_pd_manager=None, show=False, back_target_symbols=None)[源代码]¶ 输入为多个择时交易对象,每个交易对象有属于自己的买入,卖出因子, 在factor_dict中通过对象唯一标识进行提取
-
abupy.AlphaBu.ABuPickTimeExecute.
do_symbols_with_same_factors
(target_symbols, benchmark, buy_factors, sell_factors, capital, apply_capital=True, kl_pd_manager=None, show=False, back_target_symbols=None, func_factors=None)[源代码]¶ 输入为多个择时交易对象,以及相同的择时买入,卖出因子序列,对多个交易对象上实施相同的因子 :param target_symbols: 多个择时交易对象序列 :param benchmark: 交易基准对象,AbuBenchmark实例对象 :param buy_factors: 买入因子序列 :param sell_factors: 卖出因子序列 :param capital: AbuCapital实例对象 :param apply_capital: 是否进行资金对象的融合,多进程环境下将是False :param kl_pd_manager: 金融时间序列管理对象,AbuKLManager实例 :param show: 是否显示每个交易对象的交易细节 :param back_target_symbols: 补位targetSymbols为了忽略网络问题及数据不足导致的问题 :param func_factors: funcFactors在内层解开factors dicts为了do_symbols_with_diff_factors :return:
abupy.AlphaBu.ABuPickTimeMaster module¶
择时并行多任务调度模块
-
class
abupy.AlphaBu.ABuPickTimeMaster.
AbuPickTimeMaster
[源代码]¶ Bases:
object
择时并行多任务调度类
-
classmethod
do_symbols_with_same_factors_process
(target_symbols, benchmark, buy_factors, sell_factors, capital, kl_pd_manager=None, n_process_kl=8, n_process_pick_time=4)[源代码]¶ 将多个交易对象拆解为多份交易对象序列,多任务并行完成择时工作 :param target_symbols: 多个择时交易对象序列 :param benchmark: 交易基准对象,AbuBenchmark实例对象 :param buy_factors: 买入因子序列 :param sell_factors: 卖出因子序列 :param capital: AbuCapital实例对象 :param kl_pd_manager: 金融时间序列管理对象,AbuKLManager实例 :param n_process_kl: 控制金融时间序列管理对象内部启动n_process_kl进程获取金融序列数据 :param n_process_pick_time: 控制择时操作并行任务数量 :return:
-
classmethod
abupy.AlphaBu.ABuPickTimeWorker module¶
择时具体工作者,整合金融时间序列,买入因子,卖出因子,资金类进行 择时操作,以时间驱动择时事件的发生
-
class
abupy.AlphaBu.ABuPickTimeWorker.
AbuPickTimeWorker
(cap, kl_pd, benchmark, buy_factors, sell_factors)[源代码]¶ Bases:
abupy.AlphaBu.ABuPickBase.AbuPickTimeWorkBase
择时类
-
filter_long_task_factors
()[源代码]¶ 根据每一个因子是否有fit_week筛选周任务因子 根据每一个因子是否有fit_month筛选月任务因子 在初始化时完成筛选工作,避免在时间序列中迭代 不断的进行hasattr判断是否支持
-
Module contents¶
-
class
abupy.AlphaBu.
AbuPickStockMaster
[源代码]¶ Bases:
object
选股并行多任务调度类
-
classmethod
do_pick_stock_with_process
(capital, benchmark, stock_pickers, choice_symbols=None, n_process_pick_stock=4, callback=None)[源代码]¶ 选股并行多任务对外接口 :param capital: 资金类AbuCapital实例化对象 :param benchmark: 交易基准对象,AbuBenchmark实例对象 :param stock_pickers: 选股因子序列 :param choice_symbols: 初始备选交易对象序列 :param n_process_pick_stock: 控制启动多少进程并行选股操作 :param callback: 并行选股工作函数 :return: 最终选股结果序列
-
classmethod
do_pick_stock_with_process_mix_thread
(*args, **kwargs)¶ Deprecated: hdf5 store mode will crash or dead! Deprecated不应该使用,因为默认hdf5多线程读取会有问题
-
classmethod
-
class
abupy.AlphaBu.
AbuPickStockWorker
(capital, benchmark, kl_pd_manager, choice_symbols=None, stock_pickers=None)[源代码]¶ Bases:
abupy.AlphaBu.ABuPickBase.AbuPickStockWorkBase
选股类
-
class
abupy.AlphaBu.
AbuPickTimeWorker
(cap, kl_pd, benchmark, buy_factors, sell_factors)[源代码]¶ Bases:
abupy.AlphaBu.ABuPickBase.AbuPickTimeWorkBase
择时类
-
filter_long_task_factors
()[源代码]¶ 根据每一个因子是否有fit_week筛选周任务因子 根据每一个因子是否有fit_month筛选月任务因子 在初始化时完成筛选工作,避免在时间序列中迭代 不断的进行hasattr判断是否支持
-
-
class
abupy.AlphaBu.
AbuPickTimeMaster
[源代码]¶ Bases:
object
择时并行多任务调度类
-
classmethod
do_symbols_with_same_factors_process
(target_symbols, benchmark, buy_factors, sell_factors, capital, kl_pd_manager=None, n_process_kl=8, n_process_pick_time=4)[源代码]¶ 将多个交易对象拆解为多份交易对象序列,多任务并行完成择时工作 :param target_symbols: 多个择时交易对象序列 :param benchmark: 交易基准对象,AbuBenchmark实例对象 :param buy_factors: 买入因子序列 :param sell_factors: 卖出因子序列 :param capital: AbuCapital实例对象 :param kl_pd_manager: 金融时间序列管理对象,AbuKLManager实例 :param n_process_kl: 控制金融时间序列管理对象内部启动n_process_kl进程获取金融序列数据 :param n_process_pick_time: 控制择时操作并行任务数量 :return:
-
classmethod