oss.py 529 B

123456789101112131415161718
  1. import oss2
  2. from app.core.config.settings import AliyunOssConfig
  3. class OssUtils:
  4. def __init__(self, config: AliyunOssConfig):
  5. self.bucket = oss2.Bucket(
  6. oss2.Auth(config.access_key_id, config.access_key_secret),
  7. config.endpoint,
  8. config.bucket_name,
  9. )
  10. def fetch_oss_file(self, oss_key):
  11. return self.bucket.get_object(oss_key)
  12. def save_from_file(self, file_path, oss_key):
  13. return self.bucket.put_object_from_file(key=oss_key, filename=file_path)