__init__.py 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
  1. __version__ = '2.13.0'
  2. from . import models, exceptions, defaults
  3. from .api import Service, Bucket
  4. from .auth import Auth, AuthV2, AnonymousAuth, StsAuth, AUTH_VERSION_1, AUTH_VERSION_2, make_auth
  5. from .http import Session, CaseInsensitiveDict
  6. from .iterators import (BucketIterator, ObjectIterator, ObjectIteratorV2,
  7. MultipartUploadIterator, ObjectUploadIterator,
  8. PartIterator, LiveChannelIterator)
  9. from .resumable import resumable_upload, resumable_download, ResumableStore, ResumableDownloadStore, determine_part_size
  10. from .resumable import make_upload_store, make_download_store
  11. from .compat import to_bytes, to_string, to_unicode, urlparse, urlquote, urlunquote
  12. from .utils import SizedFileAdapter, make_progress_adapter
  13. from .utils import content_type_by_name, is_valid_bucket_name, is_valid_endpoint
  14. from .utils import http_date, http_to_unixtime, iso8601_to_unixtime, date_to_iso8601, iso8601_to_date
  15. from .models import BUCKET_ACL_PRIVATE, BUCKET_ACL_PUBLIC_READ, BUCKET_ACL_PUBLIC_READ_WRITE
  16. from .models import SERVER_SIDE_ENCRYPTION_AES256, SERVER_SIDE_ENCRYPTION_KMS, SERVER_SIDE_ENCRYPTION_SM4, KMS_DATA_ENCRYPTION_SM4
  17. from .models import OBJECT_ACL_DEFAULT, OBJECT_ACL_PRIVATE, OBJECT_ACL_PUBLIC_READ, OBJECT_ACL_PUBLIC_READ_WRITE
  18. from .models import BUCKET_STORAGE_CLASS_STANDARD, BUCKET_STORAGE_CLASS_IA, BUCKET_STORAGE_CLASS_ARCHIVE, BUCKET_STORAGE_CLASS_COLD_ARCHIVE
  19. from .models import BUCKET_VERSIONING_ENABLE, BUCKET_VERSIONING_SUSPEND
  20. from .models import BUCKET_DATA_REDUNDANCY_TYPE_LRS, BUCKET_DATA_REDUNDANCY_TYPE_ZRS
  21. from .crypto import LocalRsaProvider, AliKMSProvider, RsaProvider,EncryptionMaterials
  22. from .crypto_bucket import CryptoBucket
  23. import logging
  24. logger = logging.getLogger('oss2')
  25. def set_file_logger(file_path, name="oss2", level=logging.INFO, format_string=None):
  26. global logger
  27. if not format_string:
  28. format_string = "%(asctime)s %(name)s [%(levelname)s] %(thread)d : %(message)s"
  29. logger = logging.getLogger(name)
  30. logger.setLevel(level)
  31. fh = logging.FileHandler(file_path)
  32. fh.setLevel(level)
  33. formatter = logging.Formatter(format_string)
  34. fh.setFormatter(formatter)
  35. logger.addHandler(fh)
  36. def set_stream_logger(name='oss2', level=logging.DEBUG, format_string=None):
  37. global logger
  38. if not format_string:
  39. format_string = "%(asctime)s %(name)s [%(levelname)s] %(thread)d : %(message)s"
  40. logger = logging.getLogger(name)
  41. logger.setLevel(level)
  42. fh = logging.StreamHandler()
  43. fh.setLevel(level)
  44. formatter = logging.Formatter(format_string)
  45. fh.setFormatter(formatter)
  46. logger.addHandler(fh)