Files
2026-08-11 13:32:21 +08:00

1.2 KiB

实施计划

  1. 先补失败测试:worker 上限、完成顺序、单股隔离、共享频控和集合覆盖率。
  2. 在 domain/application 定义 SyncItemOutcome,把 _process_bar 重构为无共享可变状态的返回式流程。
  3. 在 Tushare adapter 增加 coordinated client/request coordinator,设置 SDK retry_count=1,补错误分类测试。
  4. 把 market_data_max_workers 默认改为 8 并完成正整数校验;CLI 注入同步用例。
  5. 引入 Psycopg connection pool,保持 advisory lock 与单股事务的独立连接语义。
  6. 增加 record_items 和 count_valid_stocks,删除编排中的逐股覆盖率查询。
  7. 用固定线程池执行 bar futures,主线程聚合、分批审计和记录有界进度。
  8. 更新 .env.example、Compose 参数传递、市场同步文档和依赖锁文件。
  9. 运行 uv lock --check、Ruff format/check、Pyright、pytest;有测试数据库时运行 market_data integration tests。
  10. 运行 5002 fake 股票无网络基准,记录最大并发、耗时和 repository 调用次数。

回滚点:连接池改造和并发编排分别保持独立变更;出现供应商问题时配置 worker=1。