使用 Python 创建和管理 Blob 租用

本文介绍如何使用适用于 Python 的 Azure 存储客户端库创建和管理 Blob 租用。 可使用客户端库来获取、续订、释放和中断 Blob 租用。

要了解如何使用异步 API 租用 Blob，请参阅异步租用 Blob。

先决条件

• Azure 订阅 - 创建试用订阅。
• Azure 存储帐户 - 创建存储帐户
• Python 3.8+

设置你的环境

如果没有现有项目，请查看本部分，其中介绍如何设置项目来使用适用于 Python 的 Azure Blob 存储客户端库。 有关更多详细信息，请参阅 Azure Blob 存储和 Python 入门。

要使用本文中的代码示例，请按照以下步骤设置项目。

安装包

使用 pip install 安装以下包：

pip install azure-storage-blob azure-identity

添加 import 语句

添加以下 import 语句：

from azure.identity import DefaultAzureCredential
from azure.storage.blob import BlobServiceClient, BlobLeaseClient

授权

授权机制必须具有使用 blob 租用所需的权限。 若要使用 Microsoft Entra ID 进行授权（建议），需要 Azure RBAC 内置角色“存储 Blob 数据参与者”或更高级别的角色。 若要了解详细信息，请参阅租用 Blob (REST API) 的授权指南。

创建客户端对象

若要将应用连接到 Blob 存储，请创建 BlobServiceClient 的实例。 以下示例演示如何使用 DefaultAzureCredential 创建客户端对象进行授权：

# TODO: Replace <storage-account-name> with your actual storage account name
account_url = "https://<storage-account-name>.blob.core.chinacloudapi.cn"
credential = DefaultAzureCredential()

# Create the BlobServiceClient object
blob_service_client = BlobServiceClient(account_url, credential=credential)

还可以为特定容器或 Blob 创建客户端对象，不管是直接创建还是通过 BlobServiceClient 对象创建。 要详细了解如何创建和管理客户端对象，请参阅 创建和管理与数据资源交互的客户端对象。

关于 blob 租用

租用为写入和删除操作创建和管理 Blob 上的锁定。 锁的持续时间可以是 15 到 60 秒，也可以是无限期。 Blob 上的租约提供对 Blob 的排他写入和删除访问。 要写入到具有活动租约的 Blob 中，客户端必须在写入请求中包含活动租约 ID。

若要详细了解租用状态以及何时可以对租用执行给定操作，请参阅租用状态和操作。

允许在包含具有活动租用的 Blob 的容器上执行所有容器操作，包括删除容器。 因此，即使容器中的 Blob 具有活动租用，也可以删除容器。 使用租用容器操作控制删除容器的权限。

租用操作由 BlobLeaseClient 类处理，该类提供包含 Blob 和容器的所有租用操作的客户端。 若要详细了解使用客户端库的容器租用，请参阅使用 Python 创建和管理容器租用。

获取租用

获取 blob 租用后，你将获得一个租用 ID，代码可使用该 ID 对 blob 进行操作。 如果 blob 已具有活动租用，则你只能使用活动租用 ID 请求新租用。 但是，你可以指定新的租用持续时间。

若要获取租用，请创建 BlobLeaseClient 类的实例，然后使用以下方法：

• BlobLeaseClient.acquire

还可以通过创建 BlobClient 实例并使用以下方法获取 Blob 上的租约：

• BlobClient.acquire_lease

以下示例为 Blob 获取 30 秒的租用时间：

def acquire_blob_lease(self, blob_service_client: BlobServiceClient, container_name):
    # Instantiate a BlobClient
    blob_client = blob_service_client.get_blob_client(container=container_name, blob="sample-blob.txt")

    # Acquire a 30-second lease on the blob
    lease_client = blob_client.acquire_lease(30)

    return lease_client

续订租用

如果请求中指定的租用 ID 与和 blob 关联的租用 ID 匹配，则可以续订 blob 租用。 只要自租用过期以来没有修改或再次租用 blob，则即使租用已过期，也可以对其进行续订。 在续订租用时，租用持续时间会重置。

若要续订租用，请使用以下方法：

• BlobLeaseClient.renew

以下示例为 Blob 续订租用：

def renew_blob_lease(self, lease_client: BlobLeaseClient):
    # Renew a lease on a blob
    lease_client.renew()

释放租用

如果请求中指定的租用 ID 与和 blob 关联的租用 ID 匹配，则可以释放 blob 租用。 通过释放租用，其他客户端可以在释放完成时立即获取该 blob 的租用。

可以使用以下方法释放租用：

• BlobLeaseClient.release

以下示例释放 Blob 上的租用：

def release_blob_lease(self, lease_client: BlobLeaseClient):
    # Release a lease on a blob
    lease_client.release()

中断租用

如果 blob 具有活动租用，则可以中断该 blob 的租用。 任何授权的请求都可以中断租用；请求不需要指定匹配的租用 ID。 租用在中断后无法续订，中断租用时会阻止在原始租用过期或释放之前一段时间内获取新租用。

可以使用以下方法中断租用：

• BlobLeaseClient.break_lease

以下示例中断 Blob 上的租用：

def break_blob_lease(self, lease_client: BlobLeaseClient):
    # Break a lease on a blob
    lease_client.break_lease()

异步租用 blob

适用于 Python 的 Azure Blob 存储客户端库支持异步租用 blob。 要详细了解项目设置要求，请参阅异步编程。

按照以下步骤使用异步 API 租用 blob：

1. 添加以下 import 语句：

import asyncio

from azure.identity.aio import DefaultAzureCredential
from azure.storage.blob.aio import BlobServiceClient, BlobLeaseClient

1. 添加代码以使用asyncio.run运行程序。 此函数运行传递的协同例程（我们示例中的main()），并管理asyncio事件循环。 使用 async/await 语法声明协同例程。 在此示例中，main() 协同例程先使用 async with 创建顶级 BlobServiceClient，然后调用获取 blob 租约的方法。 请注意，只有顶级客户端需要使用async with，因为基于它创建的其他客户端会共享同一连接池。

async def main():
    sample = BlobSamples()

    # TODO: Replace <storage-account-name> with your actual storage account name
    account_url = "https://<storage-account-name>.blob.core.chinacloudapi.cn"
    credential = DefaultAzureCredential()

    async with BlobServiceClient(account_url, credential=credential) as blob_service_client:
        lease_client = await sample.acquire_blob_lease(blob_service_client, "sample-container")

if __name__ == '__main__':
    asyncio.run(main())

1. 添加代码以获取 blob 租约。 该代码与同步示例相同，除了该方法使用async关键字声明，await关键字在调用acquire_lease方法时使用。

async def acquire_blob_lease(self, blob_service_client: BlobServiceClient, container_name):
    # Instantiate a BlobClient
    blob_client = blob_service_client.get_blob_client(container=container_name, blob="sample-blob.txt")

    # Acquire a 30-second lease on the blob
    lease_client = await blob_client.acquire_lease(30)

    return lease_client

有了此基本设置，即可使用 async/await 语法将本文中的其他示例实现为协同例程。

租用状态和操作

下图说明了租约的五种状态，以及导致租约状态发生变化的命令或事件。

下表列出了五种租用状态，对每种状态进行了简要说明，并列出了在给定状态下允许的租用操作。 这些租用操作会导致状态转换，如示意图中所示。

租用状态	说明	允许的租用操作
可用	租用已解锁且可以获取。	acquire
已租用	租用已锁定。	acquire（仅相同租用 ID）、renew、change、release 和 break
已过期	租用期限已过期。	acquire、renew、release 和 break
重大	租用已中断，但租用将保持锁定，直到中断期已过期。	release 和 break
已损坏	租用已中断，并且中断期已过期。	acquire、release 和 break

在租用过期后，Blob 服务将保留租用 ID，直到已修改或再次租用 Blob。 客户端可能会尝试使用过期的租用 ID 续订或释放租用。 如果此操作成功，则客户端知道自租用 ID 最后一次有效以来，Blob 未发生更改。 如果该请求失败，则客户端知道 Blob 已被修改，或者自租用最后一次处于活动状态以来 Blob 已被再次租用。 然后，客户端必须在 Blob 上获取新的租约。

如果租约过期而不是显式将其释放，客户端可能需要最多等待 1 分钟，然后才能获取新的 Blob 租约。 不过，如果尚未修改 Blob，则客户端可以使用其租用 ID 立即续订租约。

无法为 Blob 快照授予租用，因为快照是只读的。 针对快照请求租用会导致返回状态代码 400 (Bad Request)。

资源

若要详细了解如何使用适用于 Python 的 Azure Blob 存储客户端库来管理租用，请参阅以下资源。

代码示例

• 查看本文中的同步或异步代码示例 (GitHub)

REST API 操作

Azure SDK for Python 包含基于 Azure REST API 而生成的库，允许你通过熟悉的 Python 范例与 REST API 操作进行交互。 用于管理 blob 租用的客户端库方法使用以下 REST API 操作：

• 租用 Blob

客户端库资源

• 客户端库参考文档
• 客户端库源代码
• 包 (PyPi)

另请参阅

• 在 Blob 存储中管理并发

相关内容

• 本文是 Python 版 Blob 存储开发人员指南的一部分。 若要了解详细信息，请参阅生成 Python 应用中的开发人员指南文章的完整列表。