From 9b568704143dcd9b84e5a43d756cffd07d408507 Mon Sep 17 00:00:00 2001 From: Matthias Bisping Date: Thu, 24 Feb 2022 07:29:43 +0100 Subject: [PATCH] faster purge operation --- pyinfra/storage/adapters/azure.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/pyinfra/storage/adapters/azure.py b/pyinfra/storage/adapters/azure.py index 3ced009..5fe34ce 100644 --- a/pyinfra/storage/adapters/azure.py +++ b/pyinfra/storage/adapters/azure.py @@ -33,10 +33,9 @@ class AzureStorageAdapter(StorageAdapter): return container_client if container_client.exists() else self.__client.create_container(container_name) def put(self, bucket_name, object_name, data): - pass - # container_client = self.__provide_container_client(bucket_name) - # blob_client = container_client.get_blob_client(object_name) - # blob_client.upload_blob(data, overwrite=True) + container_client = self.__provide_container_client(bucket_name) + blob_client = container_client.get_blob_client(object_name) + blob_client.upload_blob(data, overwrite=True) def get(self, bucket_name, object_name): pass @@ -55,5 +54,6 @@ class AzureStorageAdapter(StorageAdapter): @_retry(ResourceExistsError) def purge(self, bucket_name): logging.debug(f"Purging Azure container '{bucket_name}'") - self.__client.delete_container(bucket_name) - self.__provide_container_client(bucket_name) + container_client = self.__client.get_container_client(bucket_name) + blobs = container_client.list_blobs() + container_client.delete_blobs(*blobs)