client.py 483 B

123456789101112131415161718192021
  1. from functools import lru_cache
  2. from odps import ODPS
  3. from app.core.config import settings
  4. @lru_cache
  5. def get_odps_client() -> ODPS:
  6. return ODPS(
  7. access_id=settings.odps_access_id,
  8. secret_access_key=settings.odps_access_key,
  9. project=settings.odps_project,
  10. endpoint=settings.odps_endpoint,
  11. )
  12. def odps_check_project_access() -> bool:
  13. odps_client = get_odps_client()
  14. odps_client.exist_project(settings.odps_project)
  15. return True