批量行情请求后，如何把失败的股票从正常数据中分离出来

import pandas as pd
from quantdash import QuantDash

qd = QuantDash()

symbols = ["600519.SH", "000001.SZ", "INVALID.CODE", "300750.SZ"]

dfs = qd.klines.batch(
    symbols,
    period="1d",
    count=100,
    adjust="forward",
    to_dataframe=True,
    show_progress=True,
)

# 分离成功与失败
success = {}
failed = []

for sym in symbols:
    df = dfs.get(sym)
    if df is not None and isinstance(df, pd.DataFrame) and not df.empty:
        success[sym] = df
    else:
        failed.append(sym)

print(f"成功获取: {len(success)} 只")
print(f"失败标的: {failed}")

{
  "data": {
    "600519.SH": {...},
    "000001.SZ": null,
    "INVALID.CODE": {"error": "symbol not found"}
  }
}

response = response.get("data", {})

for sym in requested_symbols:
    item = response.get(sym)
    if item and not isinstance(item, dict) or "error" in item:
        failed.append(sym)
    else:
        success.append(sym)

from requests.exceptions import RequestException, Timeout, HTTPError

symbols = ["600519.SH", "000001.SZ", "300750.SZ", "688981.SH"]
success = {}
failed = []

for sym in symbols:
    try:
        df = fetch_single_kline(sym)  # 自定义的单个标的获取函数
        if df is not None and not df.empty:
            success[sym] = df
        else:
            failed.append((sym, "empty_result"))
    except Timeout:
        failed.append((sym, "timeout"))
    except HTTPError as e:
        if e.response.status_code == 429:
            failed.append((sym, "rate_limited"))
        elif e.response.status_code == 403:
            failed.append((sym, "no_permission"))
        else:
            failed.append((sym, f"http_{e.response.status_code}"))
    except RequestException as e:
        failed.append((sym, "network_error"))

try:
    data = get_batch_data(symbols)
    return data
except Exception:
    return None

import logging
from datetime import datetime, timezone

logger = logging.getLogger("market_data")

def fetch_and_track(symbols, batch_id=None):
    if batch_id is None:
        batch_id = datetime.now(timezone.utc).strftime("%Y%m%d%H%M%S%f")

    logger.info(
        "BATCH_START id=%s symbols=%d first5=%s",
        batch_id, len(symbols), symbols[:5]
    )

    result = batch_request(symbols)
    returned_symbols = set(result.keys())
    requested_set = set(symbols)

    missing = requested_set - returned_symbols
    extra = returned_symbols - requested_set

    if missing:
        logger.warning(
            "BATCH_MISSING id=%s count=%d symbols=%s",
            batch_id, len(missing), sorted(missing)
        )

    if extra:
        logger.warning(
            "BATCH_EXTRA id=%s count=%d symbols=%s",
            batch_id, len(extra), sorted(extra)
        )

    return result, list(missing)