MCPcopy Create free account

hub / github.com/SebastienZh/StockTradebyZ / functions

Functions141 in github.com/SebastienZh/StockTradebyZ

Method__call__
(self, hist: pd.DataFrame)
pipeline/Selector.py:467
Method__call__
(self, hist: pd.DataFrame)
pipeline/Selector.py:502
Method__call__
(self, hist: pd.DataFrame)
pipeline/Selector.py:582
Method__call__
(self, hist: pd.DataFrame)
pipeline/Selector.py:658
Method__init__
( self, *, start_date=None, end_date=None, warmup_bars: int = 250,
pipeline/pipeline_core.py:119
Method__init__
(self, top_m: int)
pipeline/pipeline_core.py:278
Method__init__
( self, *, selector: AnySelector, start_date=None, end_date=None,
pipeline/pipeline_core.py:306
Method__init__
( self, filters: Sequence[StockFilter], *, date_col: str = "date", min
pipeline/Selector.py:264
Method__init__
( self, *, # ── 砖型图形态参数 ── daily_return_threshold: float = 0.05, brick
pipeline/Selector.py:794
Method__init__
(self, config)
agent/gemini_review.py:79
Method__init__
(self, config: Dict[str, Any])
agent/base_reviewer.py:20
Method_apply_one
(item)
pipeline/pipeline_core.py:188
Function_patched_fillna
(self, value=None, *, method=None, axis=None, inplace=False, limit=None, **kwargs)
pipeline/fetch_kline.py:28
Function_patched_series_fillna
(self, value=None, *, method=None, axis=None, inplace=False, limit=None, **kwargs)
pipeline/fetch_kline.py:43
Function_prepare_worker
单只股票的数据清洗 + 特征计算(turnover_n + selector.prepare_df)。
pipeline/pipeline_core.py:32
Function_selector_worker
( args: tuple[ str, pd.DataFrame, AnySelector, Optional[pd.Timestamp],
pipeline/pipeline_core.py:80
Function_tdx_sma
通达信 SMA(X,N,M),alpha = weight/period。
pipeline/Selector.py:151
Methodapply_brick_features_only
在已含 zxdq / zxdkx / wma_bull 的数据上,仅重新计算 brick 相关列。 就地写入(不 copy),超参搜索内层循环专用,速度快 3-5×。
pipeline/pipeline_core.py:239
Methodapply_zx_wma_features
仅叠加 zxdq / zxdkx / wma_bull 列(这些列不随砖型图超参变化, 可在 trial 间复用,只需计算一次)。
pipeline/pipeline_core.py:202
Methodbuild_all_dates
(prepared: Dict[str, pd.DataFrame])
pipeline/pipeline_core.py:264
Methodcompute
返回砖高 Series(index 同 df)。
pipeline/Selector.py:540
Functionfetch_one
( code: str, start: str, end: str, out_dir: Path, )
pipeline/fetch_kline.py:192
Methodget_hist
(self, df: pd.DataFrame, date: pd.Timestamp)
pipeline/Selector.py:296
Functionload_by_date
读取指定日期的存档文件。
pipeline/pipeline_io.py:104
Functionload_latest
读取 candidates_latest.json,返回 CandidateRun。 供 dashboard 或外部脚本调用。
pipeline/pipeline_io.py:87
Methodprecompute
use_threads=True → ThreadPoolExecutor(超参搜索内层循环推荐) use_threads=False → ProcessPoolExecutor(独立运行默认) 若 df 含 _vec_pick 列,走向量化快速
pipeline/pipeline_core.py:319
Methodprepare_base_only
仅做通用预处理(切片、turnover_n、set_index),跳过 selector.prepare_df()。 结果可在多个 trial 间共享;每个 trial 再单独调 apply_selector_features()。
pipeline/pipeline_core.py:153
Functionprepare_daily_indicators
在完整日线 DataFrame 上预计算所有指标列,返回带指标列的 df。 需在截断 bars 之前调用,保证指标预热期足够。 新增列: _zxdq — 知行短期线 _zxdkx — 知行多空线 _brick — 砖型图值
dashboard/components/charts.py:143
Methodprepare_df
子类重写:预计算所有中间列及 ``_vec_pick``。
pipeline/Selector.py:317
Methodprepare_df
(self, df: pd.DataFrame)
pipeline/Selector.py:943
Methodreview_stock
调用 Gemini API,对单支股票进行图表分析,返回解析后的 JSON 结果。
agent/gemini_review.py:98
Methodselect
(self, date: pd.Timestamp, data: Dict[str, pd.DataFrame])
pipeline/Selector.py:309
Functionset_api
由外部(比如GUI)注入已创建好的 ts.pro_api() 会话
pipeline/fetch_kline.py:112
Functiontest
简单测试函数,验证 CLI 逻辑(不依赖外部数据)。
pipeline/cli.py:139
Methodto_dict
(self)
pipeline/schemas.py:40
Methodvec_mask
向量化:expanding 历史分位(无未来泄漏)。
pipeline/Selector.py:374
Methodvec_mask
(self, df: pd.DataFrame)
pipeline/Selector.py:433
Methodvec_mask
(self, df: pd.DataFrame)
pipeline/Selector.py:479
Methodvec_mask
(self, df: pd.DataFrame)
pipeline/Selector.py:510
Methodvec_mask
向量化:O(N),使用预计算 'brick' 列(优先)或实时计算。
pipeline/Selector.py:607
Methodvec_picks_from_prepared
从已 prepare_df 的 df 快速获取通过日期列表(比逐日调用快 10-50×)。
pipeline/Selector.py:321
← previous101–141 of 141, ranked by callers