Skip to content
Snippets Groups Projects
Select Git revision
  • master default protected
  • 1.2.3
  • 1.2.2
  • 1.2.1
  • 1.2.0
  • 1.1.8
  • 1.1.5
  • 1.1.7
  • 1.15
  • v0.1.0
10 results
Blame Permalink
azure_storage_upload.py 1.01 KiB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28 






from azure.storage.blob import BlobServiceClient


def main(args, settings):
    azure_storage_container_name = settings.get('AZURE_STORAGE_CONTAINER_NAME')
    azure_storage_connection_string = settings.get('AZURE_STORAGE_CONNECTION_STRING')

    backup_dir = settings.get('BACKUP_DIR')
    timestamp = settings.get('TIMESTAMP')

    azure_file_name = '{0}.tar.gz'.format(timestamp)
    archive_file = '{0}/{1}'.format(backup_dir, azure_file_name)

    try:
        blob_service_client = BlobServiceClient.from_connection_string(azure_storage_connection_string)
        container_client = blob_service_client.get_blob_client(container=azure_storage_container_name, blob=azure_file_name)
        with open(archive_file, 'rb') as data:
            container_client.upload_blob(data)
        print("Upload to Azure Storage was successful")
    except FileNotFoundError:  # noqa: F821
        print("The file was not found")
        return False
    except Exception as e:
        print(str(e))
        return False

    return True