From 2c13304f9e1b0473ac87a5796964f7dd92ea2ea3 Mon Sep 17 00:00:00 2001 From: Ivan Ivanov Date: Tue, 10 Dec 2024 00:49:47 +0200 Subject: [PATCH] Kill `create_storage_bucket` script as it was never actually used --- scripts/create_storage_bucket.py | 83 -------------------------------- 1 file changed, 83 deletions(-) delete mode 100644 scripts/create_storage_bucket.py diff --git a/scripts/create_storage_bucket.py b/scripts/create_storage_bucket.py deleted file mode 100644 index 4dfde10bc..000000000 --- a/scripts/create_storage_bucket.py +++ /dev/null @@ -1,83 +0,0 @@ -import boto3 - -# TODO: add cli params -# TODO: add non-delete bucket policy - - -def load_env_file(): - """Read env file and return a dict with the variables""" - - environment = {} - with open("../.env") as f: - for line in f: - if line.strip(): - splitted = line.rstrip().split("=", maxsplit=1) - if len(splitted) == 2: - environment[splitted[0]] = splitted[1] - - return environment - - -def _get_s3_bucket(env, bucket_name): - """Get S3 Bucket according to the env variable - STORAGE_BUCKET_NAME""" - - # Create session - session = boto3.Session( - aws_access_key_id=env["STORAGE_ACCESS_KEY_ID"], - aws_secret_access_key=env["STORAGE_SECRET_ACCESS_KEY"], - region_name=env["STORAGE_REGION_NAME"], - ) - - # Get the bucket objects - s3 = session.resource("s3", endpoint_url=env["STORAGE_ENDPOINT_URL"]) - return s3.Bucket(bucket_name) - - -def _get_s3_client(env): - s3_client = boto3.client( - "s3", - region_name=env["STORAGE_REGION_NAME"], - aws_access_key_id=env["STORAGE_ACCESS_KEY_ID"], - aws_secret_access_key=env["STORAGE_SECRET_ACCESS_KEY"], - endpoint_url=env["STORAGE_ENDPOINT_URL"], - ) - return s3_client - - -def _create_bucket(env, bucket_name): - client = _get_s3_client(env) - - client.create_bucket( - Bucket=bucket_name, - ) - - -def _enable_versioning(env, bucket_name): - client = _get_s3_client(env) - - client.put_bucket_versioning( - Bucket=bucket_name, VersioningConfiguration={"Status": "Enabled"} - ) - - -def _print_access_control_list(env, bucket_name): - # Retrieve a bucket's ACL - s3 = _get_s3_client(env) - result = s3.get_bucket_acl(Bucket=bucket_name) - from pprint import pprint - - pprint(result) - - -env = load_env_file() - -# _print_access_control_list(env, 'qfieldcloud-test') -# _create_bucket(env, 'qfieldcloud-dev') - -# bucket.objects.all().delete() -# bucket.object_versions.all().delete() - -# client.delete_bucket( -# Bucket='test-bucket', -# )