多进程更新Azure Blob时，如何用Python SDK检查Blob租赁状态？

首先，你提到的blob_has_lease方法确实不存在于BlockBlobService中，但我们可以通过获取Blob属性间接判断租赁状态，同时优化重试逻辑来减少冗余日志。下面是具体的解决方案：

1. 通过Blob属性检查租赁状态 #

你可以调用get_blob_properties方法获取Blob元数据，其中的lease_status字段会明确标记Blob的租赁状态：值为'locked'表示已被租赁，'unlocked'表示无租赁。我们可以基于这个字段封装一个自定义检查方法：

from azure.storage.blob.models import BlobProperties
import time

def blob_has_lease(self, container_name, blob_name):
    try:
        props: BlobProperties = self.blob_service.get_blob_properties(container_name, blob_name)
        return props.lease_status == 'locked'
    except Exception as e:
        # 处理Blob不存在等异常，根据业务需求调整逻辑
        return False

然后你可以按照设想的逻辑实现，同时注意添加短睡眠避免高频轮询：

stream = io.BytesIO()
if self.blob_service.exists(self.container, self.changelog):
    while True:
        if self.blob_has_lease(self.container, self.changelog):
            time.sleep(1)
            continue
        try:
            # 依然需要捕获冲突异常：检查和获取租赁之间存在竞态条件
            lease_id = self.blob_service.acquire_blob_lease(self.container, self.changelog, lease_duration=-1)
            break
        except AzureConflictHttpError:
            pass

⚠️ 重要提示：即使先检查租赁状态，依然可能在检查完成后、获取租赁前被其他进程抢占，所以必须保留异常捕获，但这样可以大幅减少不必要的错误日志输出。

2. 优化原有重试逻辑，抑制冗余日志 #

如果不想额外封装检查方法，也可以直接调整Azure SDK的日志级别，让它不再输出大量LeaseAlreadyPresent错误日志：

import logging
# 将Azure Blob模块的日志级别设为WARNING，只记录严重问题
logging.getLogger('azure.storage.blob').setLevel(logging.WARNING)

3. 修复租赁释放的关键错误 #

你的代码中使用break_blob_lease是不合适的！break_blob_lease是强制打破Blob上的任何租赁，而你应该使用release_blob_lease主动释放自己持有的租赁，且必须传入获取到的租赁ID。修正后的完整流程如下：

stream = io.BytesIO()
lease_id = None
if self.blob_service.exists(self.container, self.changelog):
    while True:
        if self.blob_has_lease(self.container, self.changelog):
            time.sleep(1)
            continue
        try:
            lease_id = self.blob_service.acquire_blob_lease(self.container, self.changelog, lease_duration=-1)
            break
        except AzureConflictHttpError:
            pass

try:
    self.blob_service.get_blob_to_stream(self.container, self.changelog, stream)
    stream.seek(0)
    # ... 执行处理并写入Blob文件
finally:
    if lease_id:
        # 确保无论是否发生异常，都释放租赁
        self.blob_service.release_blob_lease(self.container, self.changelog, lease_id=lease_id)

这样既避免了租赁被意外强制打破，也能确保租赁在任何场景下都能被正确释放。

内容的提问来源于stack exchange，提问作者Josh