Python Azure服务总线锁已过期

Question

我正在使用azure服务总线，我得到的锁已过期。

如何我已经实现了锁定1天，但我仍然得到错误

我的代码：

import json
from typing import Any, Dict, Generator, List, Optional


from azure.servicebus import (AutoLockRenewer, ServiceBusClient,
                              ServiceBusMessage)


class Queue():
    def __init__(
                self,
                connection_string: Optional[str] = None,
                queue_name: Optional[str] = None,
                max_lock_renewal_duration: Optional[int] = 86400,
                logging_enable: Optional[bool] = True
            ):
        

        self.queue_name = queue_name
        self.connection_string = connection_string
        self.logging_enable = logging_enable
        self.max_lock_renewal_duration = max_lock_renewal_duration
        self.client = ServiceBusClient.from_connection_string(
            conn_str=self.connection_string, logging_enable=logging_enable)
        self.sender = self.client.get_queue_sender(queue_name=self.queue_name)
        self.renewer = AutoLockRenewer(
                max_lock_renewal_duration=max_lock_renewal_duration)
        self.receiver = self.client.get_queue_receiver(
            queue_name=self.queue_name, auto_lock_renewer=self.renewer)

 
    def get_msgs(
                self,
                max_message_count: Optional[int] = 1,
                max_wait_time: Optional[int] = 5
            ) -> Generator[ServiceBusMessage, None, None]:
        

        for msg in self.receiver.receive_messages(
                    max_message_count=max_message_count,
                    max_wait_time=max_wait_time
                ):
            yield msg

     def abandon_msg(self, msg: ServiceBusMessage) -> None:
    

          self.receiver.abandon_message(msg)

q = Queue(connection_string="secret",
          queue_name="my_queue",
          logging_enable=True
        )
for msg in q.get_msgs(max_message_count=100, max_wait_time=5):
    print("process my messages")
    print("some reason abondan")

错误：

---日志记录错误---回溯（最近一次通话最后一次）：

文件“/test/.env/lib64/python3.6/site packages/azure/servicebus/_servicebus_receiver.py”，第782行，在放弃消息self中_在第415行，用重试（消息，消息放弃）文件“/test/.env/lib64/python3.6/site packages/azure/servicebus/_servicebus_receiver.py”结算消息。自动更新错误，azure。服务巴士。例外。ServiceBusError:消息锁上的锁已过期。

我的目标是放弃消息，这样它就会重试，还有一种方法，我们可以增加重试时间，而不是像每abandon_msg延迟300秒那样无休止地排队？

Answer 1

默认情况下，锁定时间将设置为30秒，我们可以将其增加到5分钟。

设置锁定期为1天将被拒绝从控制台本身，如下截图：

更新到最大锁定时间后的屏幕截图：

但是，锁可以更新，直到功能完成。因为我们可以使用自动锁更新功能，您可以指定想要继续更新锁的时间长度。

下面的代码将帮助我们自动更新会话锁100秒

renewer.register(receiver, receiver.session, max_lock_renewal_duration=100)
print('Register session into AutoLockRenewer.')

received_msgs = receiver.receive_messages(max_message_count=10, max_wait_time=5)
time.sleep(100)  # message handling for long period (E.g. application logic)
for msg in received_msgs:
    receiver.complete_message(msg)

要了解有关每个参数的更多信息，请参阅auto_lock_renew。py来自azure sdk for python。

从这里还可以查看_auto_lock_renew_task的定义。

建议：尽量增加锁定期，减少更新锁定期。