-
Notifications
You must be signed in to change notification settings - Fork 363
/
__init__.py
60 lines (43 loc) · 2.32 KB
/
__init__.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
__version__ = '2.6.2'
from . import models, exceptions
from .api import Service, Bucket, CryptoBucket
from .auth import Auth, AuthV2, AnonymousAuth, StsAuth, AUTH_VERSION_1, AUTH_VERSION_2, make_auth
from .http import Session, CaseInsensitiveDict
from .iterators import (BucketIterator, ObjectIterator,
MultipartUploadIterator, ObjectUploadIterator,
PartIterator, LiveChannelIterator)
from .resumable import resumable_upload, resumable_download, ResumableStore, ResumableDownloadStore, determine_part_size
from .resumable import make_upload_store, make_download_store
from .compat import to_bytes, to_string, to_unicode, urlparse, urlquote, urlunquote
from .utils import SizedFileAdapter, make_progress_adapter
from .utils import content_type_by_name, is_valid_bucket_name
from .utils import http_date, http_to_unixtime, iso8601_to_unixtime, date_to_iso8601, iso8601_to_date
from .models import BUCKET_ACL_PRIVATE, BUCKET_ACL_PUBLIC_READ, BUCKET_ACL_PUBLIC_READ_WRITE, SERVER_SIDE_ENCRYPTION_AES256, SERVER_SIDE_ENCRYPTION_KMS
from .models import OBJECT_ACL_DEFAULT, OBJECT_ACL_PRIVATE, OBJECT_ACL_PUBLIC_READ, OBJECT_ACL_PUBLIC_READ_WRITE
from .models import BUCKET_STORAGE_CLASS_STANDARD, BUCKET_STORAGE_CLASS_IA, BUCKET_STORAGE_CLASS_ARCHIVE
from .models import BUCKET_VERSIONING_ENABLE, BUCKET_VERSIONING_SUSPEND
from .crypto import LocalRsaProvider, AliKMSProvider
import logging
logger = logging.getLogger('oss2')
def set_file_logger(file_path, name="oss2", level=logging.INFO, format_string=None):
global logger
if not format_string:
format_string = "%(asctime)s %(name)s [%(levelname)s] %(thread)d : %(message)s"
logger = logging.getLogger(name)
logger.setLevel(level)
fh = logging.FileHandler(file_path)
fh.setLevel(level)
formatter = logging.Formatter(format_string)
fh.setFormatter(formatter)
logger.addHandler(fh)
def set_stream_logger(name='oss2', level=logging.DEBUG, format_string=None):
global logger
if not format_string:
format_string = "%(asctime)s %(name)s [%(levelname)s] %(thread)d : %(message)s"
logger = logging.getLogger(name)
logger.setLevel(level)
fh = logging.StreamHandler()
fh.setLevel(level)
formatter = logging.Formatter(format_string)
fh.setFormatter(formatter)
logger.addHandler(fh)