in connectors/blob.py [0:0]
def __init__(self, storage_account_base_url, container_name, credential=None):
"""
Initialize BlobContainerClient with the storage account base URL and container name.
:param storage_account_base_url: Base URL of the storage account (e.g., "https://mystorage.blob.core.windows.net")
:param container_name: Name of the container
:param credential: Credential for authentication (optional)
"""
try:
self.credential = self._get_credential(credential)
self.container_client = ContainerClient(
account_url=storage_account_base_url,
container_name=container_name,
credential=self.credential
)
# Verify the container exists
self.container_client.get_container_properties()
logging.debug(f"[blob] Connected to container '{container_name}'.")
except ResourceNotFoundError:
logging.error(f"[blob] Container '{container_name}' does not exist.")
raise
except AzureError as e:
logging.error(f"[blob] Failed to connect to container: {e}")
raise