我想在服务总线队列接收到新消息时调用一个持久函数，并且需要将相同的消息传递给持久函数

I want to invoke one durable function when new message received to service bus queue and need to pass same message to durable function

我想在服务总线队列接收到新消息时调用一个持久函数，并且需要将同一消息传递给持久函数。

并且整个过程应该在 python 堆栈中完成

您可以使用 Azure Functions 的 Azure 服务总线触发器来响应来自服务总线队列或主题的消息。

服务总线绑定在 function.json 中定义，其中 type 设置为 serviceBusTrigger。

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "msg",
      "type": "serviceBusTrigger",
      "direction": "in",
      "queueName": "inputqueue",
      "connection": "AzureServiceBusConnectionString"
    }
  ]
}

init.py中的代码声明了一个参数为func.ServiceBusMessage，可以让你读取队列消息你的功能。

有关完整信息，请参阅此 document。