simplified code
This commit is contained in:
@@ -5,23 +5,19 @@ import os
|
|||||||
|
|
||||||
from minio import Minio
|
from minio import Minio
|
||||||
|
|
||||||
|
from shared.utils import check_env
|
||||||
|
|
||||||
|
|
||||||
def connect_minio() -> Minio:
|
def connect_minio() -> Minio:
|
||||||
"""Connect to MinIO server."""
|
"""Connect to MinIO server."""
|
||||||
# ensure necessary env vars available
|
# ensure necessary env vars available
|
||||||
env_var_list = [
|
var_list = {
|
||||||
'MINIO_ENDPOINT',
|
'MINIO_ENDPOINT',
|
||||||
'MINIO_ACCESS_KEY',
|
'MINIO_ACCESS_KEY',
|
||||||
'MINIO_SECRET_KEY',
|
'MINIO_SECRET_KEY',
|
||||||
'MINIO_BUCKET_NAME',
|
'MINIO_BUCKET_NAME',
|
||||||
]
|
}
|
||||||
for env_var in env_var_list:
|
check_env(var_list)
|
||||||
# ensure env var set
|
|
||||||
assert (
|
|
||||||
env_var in os.environ
|
|
||||||
), f"environment variable not set: {
|
|
||||||
env_var
|
|
||||||
}"
|
|
||||||
# prepare arguments
|
# prepare arguments
|
||||||
minio_endpoint = os.getenv('MINIO_ENDPOINT', default='')
|
minio_endpoint = os.getenv('MINIO_ENDPOINT', default='')
|
||||||
minio_access_key = os.getenv('MINIO_ACCESS_KEY', default='')
|
minio_access_key = os.getenv('MINIO_ACCESS_KEY', default='')
|
||||||
|
|||||||
Reference in New Issue
Block a user