如果Azure Service Bus队列触发器Func失败，如何将队列消息返回Azure Service Bus队列

Question

我使用VisualStudio代码创建了一个Azure Service Bus Queue Trigger Python函数，如果代码失败，我希望将消息返回到Service Bus队列。

import requests
import azure.functions as func
from requests.exceptions import HTTPError

def main(msg: func.ServiceBusMessage):
    message = msg.get_body().decode("utf-8")

    url = "http://..."

    # My code
    try: 
         requests.post(url=url, params=message)
    except Exception as error:
         logging.error(error)
         # RETURN MESSAGE TO QUEUE HERE

我找到了一些关于一个名为unlock（）和discard（）的方法的信息，但我不知道如何实现它。以下是这些文档的链接：

• 解锁：https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-python-how-to-use-queues#handle-应用程序崩溃和无法读取的消息

我还发现，如果函数失败，队列会自动将消息发送到队列，但是，我应该写一个加薪吗？

还有，有没有办法将此消息返回队列并设置稍后重试的计划？

Answer 1

服务总线触发器python函数以PeekLock模式运行。您不必调用unlock（）和放弃（）方法。检查PeekLock行为描述：

函数运行时以PeekLock模式接收消息。如果函数成功完成，它将在消息中调用完成，如果函数失败，它将调用放弃。如果函数运行时间长于PeekLock超时，则只要函数运行，锁就会自动更新。