in connectors/blob.py [0:0]
def upload_blob(self, blob_name, file_path, overwrite=False):
"""
Upload a local file to a blob within the container.
:param blob_name: Name of the blob
:param file_path: Path to the local file to upload
:param overwrite: Whether to overwrite the blob if it already exists
"""
try:
blob_client = self.container_client.get_blob_client(blob_name)
with open(file_path, "rb") as data:
blob_client.upload_blob(data, overwrite=overwrite)
logging.info(f"[blob] Uploaded '{file_path}' as blob '{blob_name}'.")
except AzureError as e:
logging.info(f"[blob] Failed to upload blob '{blob_name}': {e}")