Skip to content

Commit

Permalink
Upgrade django-s3-file-field
Browse files Browse the repository at this point in the history
This completes #1717, to use the latest django-storages version.
  • Loading branch information
brianhelba committed Nov 3, 2023
1 parent 40498ec commit 9f81e32
Show file tree
Hide file tree
Showing 3 changed files with 28 additions and 30 deletions.
17 changes: 10 additions & 7 deletions dandiapi/api/storage.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,10 +12,10 @@
from dandischema.digests.dandietag import PartGenerator
from django.conf import settings
from django.core.files.storage import Storage, get_storage_class
from minio.error import NoSuchKey
from minio import S3Error
from minio_storage.policy import Policy
from minio_storage.storage import MinioStorage, create_minio_client_from_settings
from s3_file_field._multipart_boto3 import Boto3MultipartManager
from s3_file_field._multipart_s3 import S3MultipartManager
from s3_file_field._multipart_minio import MinioMultipartManager
from storages.backends.s3 import S3Storage

Expand Down Expand Up @@ -44,7 +44,7 @@ def _iter_part_sizes(file_size: int) -> Iterator[tuple[int, int]]:
_url_expiration = timedelta(days=7)


class DandiBoto3MultipartManager(DandiMultipartMixin, Boto3MultipartManager):
class DandiS3MultipartManager(DandiMultipartMixin, S3MultipartManager):
"""A custom multipart manager for passing ACL information."""

def _create_upload_id(self, object_key: str, content_type: str | None = None) -> str:
Expand Down Expand Up @@ -124,7 +124,7 @@ def __init__(self, **settings):
class VerbatimNameS3Storage(VerbatimNameStorageMixin, TimeoutS3Storage):
@property
def multipart_manager(self):
return DandiBoto3MultipartManager(self)
return DandiS3MultipartManager(self)

def etag_from_blob_name(self, blob_name) -> str | None:
client = self.connection.meta.client
Expand Down Expand Up @@ -197,8 +197,11 @@ def multipart_manager(self):
def etag_from_blob_name(self, blob_name) -> str | None:
try:
response = self.client.stat_object(self.bucket_name, blob_name)
except NoSuchKey:
return None
except S3Error as e:
if e.code == 'NoSuchKey':
return None
else:
raise
else:
return response.etag

Expand All @@ -215,7 +218,7 @@ def generate_presigned_put_object_url(self, blob_name: str, _: str) -> str:
)

def generate_presigned_head_object_url(self, key: str) -> str:
return self.base_url_client.presigned_url('HEAD', self.bucket_name, key)
return self.base_url_client.get_presigned_url('HEAD', self.bucket_name, key)

def generate_presigned_download_url(self, key: str, path: str) -> str:
return self.base_url_client.presigned_get_object(
Expand Down
30 changes: 15 additions & 15 deletions dandiapi/conftest.py
Original file line number Diff line number Diff line change
Expand Up @@ -84,16 +84,16 @@ def authenticated_api_client(user) -> APIClient:
# storage fixtures are copied from django-s3-file-field test fixtures


def base_s3boto3_storage_factory(bucket_name: str) -> 'S3Storage':
def base_s3_storage_factory(bucket_name: str) -> 'S3Storage':
return create_s3_storage(bucket_name)


def s3boto3_storage_factory():
return base_s3boto3_storage_factory(settings.DANDI_DANDISETS_BUCKET_NAME)
def s3_storage_factory():
return base_s3_storage_factory(settings.DANDI_DANDISETS_BUCKET_NAME)


def embargoed_s3boto3_storage_factory():
return base_s3boto3_storage_factory(settings.DANDI_DANDISETS_EMBARGO_BUCKET_NAME)
def embargoed_s3_storage_factory():
return base_s3_storage_factory(settings.DANDI_DANDISETS_EMBARGO_BUCKET_NAME)


def base_minio_storage_factory(bucket_name: str) -> MinioStorage:
Expand All @@ -109,13 +109,13 @@ def embargoed_minio_storage_factory() -> MinioStorage:


@pytest.fixture
def s3boto3_storage() -> 'S3Storage':
return s3boto3_storage_factory()
def s3_storage() -> 'S3Storage':
return s3_storage_factory()


@pytest.fixture
def embargoed_s3boto3_storage() -> 'S3Storage':
return s3boto3_storage_factory()
def embargoed_s3_storage() -> 'S3Storage':
return s3_storage_factory()


@pytest.fixture
Expand All @@ -128,10 +128,10 @@ def embargoed_minio_storage() -> MinioStorage:
return minio_storage_factory()


@pytest.fixture(params=[s3boto3_storage_factory, minio_storage_factory], ids=['s3boto3', 'minio'])
@pytest.fixture(params=[s3_storage_factory, minio_storage_factory], ids=['s3', 'minio'])
def storage(request, settings) -> Storage:
storage_factory = request.param
if storage_factory == s3boto3_storage_factory:
if storage_factory == s3_storage_factory:
settings.DEFAULT_FILE_STORAGE = 'storages.backends.s3.S3Storage'
settings.AWS_S3_ACCESS_KEY_ID = settings.MINIO_STORAGE_ACCESS_KEY
settings.AWS_S3_SECRET_ACCESS_KEY = settings.MINIO_STORAGE_SECRET_KEY
Expand All @@ -153,8 +153,8 @@ def storage(request, settings) -> Storage:


@pytest.fixture(
params=[embargoed_s3boto3_storage_factory, embargoed_minio_storage_factory],
ids=['s3boto3', 'minio'],
params=[embargoed_s3_storage_factory, embargoed_minio_storage_factory],
ids=['s3', 'minio'],
)
def embargoed_storage(request) -> Storage:
storage_factory = request.param
Expand All @@ -163,10 +163,10 @@ def embargoed_storage(request) -> Storage:

@pytest.fixture(
params=[
(s3boto3_storage_factory, embargoed_s3boto3_storage_factory),
(s3_storage_factory, embargoed_s3_storage_factory),
(minio_storage_factory, embargoed_minio_storage_factory),
],
ids=['s3boto3', 'minio'],
ids=['s3', 'minio'],
)
def storage_tuple(request) -> tuple[Storage, Storage]:
storage_factory, embargoed_storage_factory = request.param
Expand Down
11 changes: 3 additions & 8 deletions setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -62,17 +62,12 @@
'zarr-checksum>=0.2.8',
# Production-only
'django-composed-configuration[prod]>=0.23.0',
# pin directly to a version since we're extending the private multipart interface
'django-s3-file-field[boto3]==0.3.2',
'django-s3-file-field[s3]>=1.0.0',
'django-storages[s3]>=1.14.2',
'gunicorn',
# Development-only, but required
# TODO: starting with v0.5.0, django-minio-storage requires v7
# of the minio-py library. minio-py 7 introduces several
# breaking changes to the API, and django-s3-file-field is also
# incompatible with it since it has minio<7 as a dependency.
# Until these issues are resolved, we pin it to an older version.
'django-minio-storage<0.5.0',
'django-minio-storage',
'minio',
'tqdm',
],
extras_require={
Expand Down

0 comments on commit 9f81e32

Please sign in to comment.