45 lines
1.1 KiB
Python
45 lines
1.1 KiB
Python
"""Definition of get function."""
|
|
|
|
import logging
|
|
from io import BytesIO
|
|
from traceback import print_exc
|
|
|
|
from minio import Minio
|
|
|
|
|
|
def get(
|
|
client: Minio,
|
|
bucket_name: str,
|
|
object_name: str,
|
|
) -> BytesIO:
|
|
"""Get buffer from bucket in MinIO."""
|
|
assert isinstance(client, Minio)
|
|
assert isinstance(bucket_name, str)
|
|
assert len(bucket_name) > 0
|
|
assert isinstance(object_name, str)
|
|
assert len(object_name) > 0
|
|
try:
|
|
# make request
|
|
response = client.get_object(
|
|
bucket_name=bucket_name,
|
|
object_name=object_name,
|
|
)
|
|
assert response.status == 200
|
|
# get buffer
|
|
buffer = BytesIO()
|
|
chunk_size = 2**14
|
|
while chunk := response.read(chunk_size):
|
|
buffer.write(chunk)
|
|
buffer.seek(0)
|
|
logging.debug('got %s', object_name)
|
|
return buffer
|
|
except Exception as exc:
|
|
logging.error('failed getting data from MinIO')
|
|
print_exc()
|
|
raise exc
|
|
finally:
|
|
# close connection if established
|
|
if 'response' in locals():
|
|
response.close()
|
|
response.release_conn()
|