api.py 1.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. # -*- coding: utf-8 -*-
  2. r"""观澜 · 数据接入管理 —— **对外公开面**(P0 阶段:接口先立,实现仍在既有路径)。
  3. 用户令 2026-09-22:按模块重构源代码目录,**每模块只许经 `api.py` 被别的模块调用**。
  4. 本文件当前把公开名**惰性转发**到既有实现(src/windscada/{data,scada_source,slim,mdb_names}.py + scripts/{rebuild_*,scada_*,raw_scan,raw_data_check,place_raw_data,pitch_face_build,baseline_38_build,component_history_build,csv_to_mdb}.py),因此:
  5. * 调用的行为与重构前完全一致(零行为变化);
  6. * 后续阶段(见 `docs/重构方案_模块化_v0.1.md`)把实现搬到本模块目录后,**只改这里的目标映射**,
  7. 调用方一行都不用动;
  8. * 惰性转发(PEP 562)保证 import 本文件不会连带 import 重依赖。
  9. """
  10. from __future__ import annotations
  11. import importlib
  12. # 模块(按名惰性转发)—— P2 起实现就在本模块目录内
  13. _TARGETS: dict[str, str] = {
  14. 'data': 'app_ETL.app_ETL_guanlan.data',
  15. 'scada_source': 'app_ETL.app_ETL_guanlan.scada_source',
  16. 'slim': 'app_ETL.app_ETL_guanlan.slim',
  17. 'mdb_names': 'app_ETL.app_ETL_guanlan.mdb_names',
  18. }
  19. # ★2026-09-22 P3 增设: 常用的**函数级**公开名(算法层经本公开面取数,不再直接 import 本模块内部实现)。
  20. # `from app_ETL.app_ETL_guanlan.api import load_10min` 这类写法由此成立。
  21. from app_ETL.app_ETL_guanlan.data import contracted_cols, load_10min # noqa: E402,F401
  22. from app_ETL.app_ETL_guanlan import slim # noqa: E402,F401
  23. __all__ = list(_TARGETS) + ['load_10min', 'contracted_cols']
  24. def __getattr__(name: str):
  25. target = _TARGETS.get(name)
  26. if target is None:
  27. raise AttributeError(
  28. f'{__name__} 未公开 {name!r};公开面见 __all__ —— 模块间调用只许走 api.py'
  29. )
  30. mod = importlib.import_module(target)
  31. globals()[name] = mod
  32. return mod