ds3.py

from threading import local


class Bucket(object):
    def __init__(self, bucket, s3=None):
        if s3 is None:
            s3 = s3_storage
        self.bucket = bucket
        self.s3 = s3


class Ducket(object):
    """
    Based on Django's DB connections
    """

    DEFAULT_ALIAS = 'default'

    def __init__(self, settings, default_config):
        self.settings = settings
        self.default_config = default_config
        self._buckets = local()

    def _ensure_defaults(self, alias):
        cfg = self.settings[alias]
        for k, v in slef.default_config.items():
            cfg.setdefault(k, v)

    def __getitem__(self, alias):
        if hasattr(self._buckets, alias):
            return getattr(self._buckets, alias)

        self._ensure_defaults(alias)
        cfg = self.settings[alias]
        bucket = Bucket(cfg['bucket'])
        setattr(self._buckets, alias, bucket)
        return bucket

    def __getattr__(self, attr):
        return getattr(self[self.DEFAULT_ALIAS], attr)

ducket = Ducket(settings.STORAGE_S3, settings.STORAGE_S3_CONFIG)

ds3_settings.py

STORAGE_S3_CONFIG = {
    'host': '',
    'port': '',
    'secure': True,
    'access_key_id': '',
    'secret_access_key': '',
}
STORAGE_S3 = {
    'default': {
        'bucket': ''',
    },
    'abc': {
        'bucket': '',
    },
}