Upload 2 files

requirements.txt

@@ -7,3 +7,4 @@ python-dotenv>=1.0.0
 yfinance>=0.2.0
 pytz>=2023.3
 schedule>=1.2.0  # 定时任务调度
+pyarrow>=14.0.0  # Parquet 文件支持

sync_data.py

@@ -37,13 +37,23 @@ def get_stock_list() -> pd.DataFrame:
     """获取全市场标的列表"""
     logger.info("Fetching all-market target list...")
     all_lists = []
-    try:
-        df_a = ak.stock_zh_a_spot_em()[['代码', '名称']]
-        df_a.columns = ['code', 'name']
-        df_a['market'] = df_a['code'].apply(lambda x: '主板' if x.startswith(('60', '00')) else ('创业板' if x.startswith('30') else ('科创板' if x.startswith('68') else ('北交所' if x.startswith(('8', '4', '920')) else '其他'))))
-        all_lists.append(df_a)
+    
+    max_retries = 3
+    for attempt in range(max_retries):
+        try:
+            df_a = ak.stock_zh_a_spot_em()[['代码', '名称']]
+            df_a.columns = ['code', 'name']
+            df_a['market'] = df_a['code'].apply(lambda x: '主板' if x.startswith(('60', '00')) else ('创业板' if x.startswith('30') else ('科创板' if x.startswith('68') else ('北交所' if x.startswith(('8', '4', '920')) else '其他'))))
+            all_lists.append(df_a)
+            break  # 成功则退出重试循环
+        except Exception as e:
+            if attempt == max_retries - 1:
+                logger.error(f"Failed to fetch A-stock list after {max_retries} attempts: {e}")
+            else:
+                logger.warning(f"Attempt {attempt + 1} failed, retrying... Error: {e}")
+                time.sleep(5)  # 重试前等待 5 秒
         
-        # ETF / LOF / REITs
+        # ETF / LOF / REITs (增加容错)
         try:
             df_etf = ak.fund_etf_spot_em()[['代码', '名称']]
             df_etf.columns = ['code', 'name']
@@ -73,7 +83,8 @@ def get_stock_list() -> pd.DataFrame:
             c_code = '代码' if '代码' in df_cb.columns else 'symbol'
             c_name = '名称' if '名称' in df_cb.columns else 'name'
             df_cb = df_cb[[c_code, c_name]]; df_cb.columns = ['code', 'name']; df_cb['market'] = '可转债'; all_lists.append(df_cb)
-        except: pass
+        except Exception as e:
+            logger.warning(f"Convertible bond list fetch failed: {e}")
 
     except Exception as e:
         logger.error(f"List fetching error: {e}")