| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
|
|
|
|
|
|
| import os |
| import logging |
|
|
| |
| API_KEY = os.environ.get('API_KEY','321') |
| if not API_KEY: |
| raise ValueError("API_KEY environment variable is not set") |
|
|
| |
| LOCAL_STORAGE_PATH = os.environ.get('LOCAL_STORAGE_PATH', '/tmp') |
|
|
| |
| GCP_SA_CREDENTIALS = os.environ.get('GCP_SA_CREDENTIALS', '') |
| GCP_BUCKET_NAME = os.environ.get('GCP_BUCKET_NAME', '') |
|
|
| def validate_env_vars(provider): |
|
|
| """ Validate the necessary environment variables for the selected storage provider """ |
| required_vars = { |
| 'GCP': ['GCP_BUCKET_NAME', 'GCP_SA_CREDENTIALS'], |
| 'S3': ['S3_ENDPOINT_URL', 'S3_ACCESS_KEY', 'S3_SECRET_KEY', 'S3_BUCKET_NAME', 'S3_REGION'], |
| 'S3_DO': ['S3_ENDPOINT_URL', 'S3_ACCESS_KEY', 'S3_SECRET_KEY'] |
| } |
| |
| missing_vars = [var for var in required_vars[provider] if not os.getenv(var)] |
| if missing_vars: |
| raise ValueError(f"Missing environment variables for {provider} storage: {', '.join(missing_vars)}") |
|
|