是否可以使用 Python SDK 检查特定 Azure blob 是否有租约？

Question

我有一段代码经常被多个进程运行处理，其中某个 blob 文件必须使用一些新信息进行更新。因为我不希望这些进程同时写入这个文件——这会导致冲突错误——我在一个进程开始修改它时在文件上放置了一个租约，并希望在它完成修改后打破这个租约。

现在的问题是，我必须检查每个进程是否已经有 blobfile 上的租约，如果没有，则继续等待直到租约被破坏，然后为当前进程获取租约。我现在意识到这一点的方法是运行宁下面的代码：

stream = io.BytesIO()
if self.blob_service.exists(self.container, self.changelog):
   while True:
       try:
          self.blob_service.acquire_blob_lease(self.container, self.changelog,
                                                         lease_duration=-1)
          break
       except AzureConflictHttpError:
          pass
   self.blob_service.get_blob_to_stream(self.container, self.changelog, stream)
   stream.seek(0)

   .... do some processing and write to blobfile
   self.blob_service.break_blob_lease(self.container, self.changelog)

blob_service 这里是 BlockBlobService 的一个实例。但是，这会导致连续记录 2020-04-19 16:19:51,517 ERROR Client-Request-ID=d53b7e6e-8248-11ea-a073-dca90492a6b8 Retry policy did not allow for a retry: Server-Timestamp=Sun, 19 Apr 2020 14:19:50 GMT, Server-Request-ID=c339439f-e01e-0058-1d55-16e3bc000000, HTTP status code=409, Exception=There is already a lease present. ErrorCode: LeaseAlreadyPresent<?xml version="1.0" encoding="utf-8"?><Error><Code>LeaseAlreadyPresent</Code><Message>There is already a lease present.RequestId:c339439f-e01e-0058-1d55-16e3bc000000Time:2020-04-19T14:19:51.5047575Z</Message></Error>. 这将一直持续到进程 1 中断租约并且进程 2 可以获得租约。

现在当然有办法抑制这种记录，但我更愿意能够做这样的事情。

while True:
    if self.blob_service.blob_has_lease(self.container, self.changelog):
        continue
    else:
        self.blob_service.acquire_blob_lease(self.container, self.changelog,
                                                         lease_duration=-1)

if self.blob_service.blob_has_lease(self.container, self.changelog)里面是我自己编的东西。但是，我无法以任何方式找到这样的方法或属性来检查某个 blob 当前是否有租约。是否有任何这样的方法或解决方法可以让我像上面提供的示例一样编写代码？

Answer 1

您可以打电话给 get_blob_properties method to get the properties of a blob. If a blob is leased, then you should get some value in lease variable under blob's properties。

是否可以使用 Python SDK 检查特定 Azure blob 是否有租约？

Is it possible to check if there is a lease on a specific Azure blob, using the Python SDK?

python

azure

azure-blob-storage

azure-sdk-python