python - Azure Functions 如何在脚本完成之前返回 HttpResponse 或显示消息

Question

我有一个 Python Azure 函数，它由一个文件和一个 main 函数组成:

def main(req: func.HttpRequest) -> func.HttpResponse:
    [bunch of code]

    return func.HttpResponse("the file will be deleted in 10 minutes", status_code=200)

它会在 Azure Blob 存储中为用户创建一个文件，并在 10 分钟内将其删除。我使用 time.sleep(600) 来执行此操作。但是，该消息仅在该计时器结束时(文件已被删除后)到达。

如何让 HttpResponse 在脚本结束之前显示消息，然后等待 10 分钟再删除消息？

我尝试在 time.sleep(600) 之前添加 func.HttpResponse('the file will be deleted in 10 分钟') 但没有成功返回任何内容。

Answer 1

对于像这样具有 http 输出绑定(bind)的函数，您必须在末尾返回 http 响应才能使响应正常工作。因此，使用单个函数是无法实现这一目标的。继续阅读替代解决方案。

这个问题通常是一个“异步”处理示例，您希望立即响应“好吧，我要这样做”，同时它“排队进一步处理”以便在后端继续。要在 Azure Function 中实现此目的，您将需要以下 2 个函数:

1. 功能 1:Http trigger, http output和 Queue output binding (为了简单起见，我将使用存储队列)。
2. 功能 2:Queue trigger (将由函数 1 排队的消息触发)。

功能1(根据您的需要更新):

JSON:

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "authLevel": "function",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": [
        "get",
        "post"
      ]
    },
    {
      "type": "http",
      "direction": "out",
      "name": "$return"
    },
    {
      "type": "queue",
      "direction": "out",
      "name": "msg",
      "queueName": "outqueue",
      "connection": "AzureStorageQueuesConnectionString"
    }
  ]
}

代码:

import azure.functions as func

def main(req: func.HttpRequest, msg: func.Out[str]) -> func.HttpResponse:
    [bunch of code]
    input_msg = "<create the message body required by function 2>"
    msg.set(input_msg)
    return func.HttpResponse("the file will be deleted in 10 minutes", status_code=201)

功能2(根据您的需要更新):

JSON:

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "name": "msg",
      "type": "queueTrigger",
      "direction": "in",
      "queueName": "messages",
      "connection": "AzureStorageQueuesConnectionString"
    }
  ]
}

代码:

import json
import azure.functions as func

def main(msg: func.QueueMessage):  
     # below is just an example of parsing the message, in your case it might be taking the blob info required for deleting
     message = json.dumps({
        'id': msg.id,
        'body': msg.get_body().decode('utf-8'),
        'expiration_time': (msg.expiration_time.isoformat()
                            if msg.expiration_time else None),
        'insertion_time': (msg.insertion_time.isoformat()
                           if msg.insertion_time else None),
        'time_next_visible': (msg.time_next_visible.isoformat()
                              if msg.time_next_visible else None),
        'pop_receipt': msg.pop_receipt,
        'dequeue_count': msg.dequeue_count
    })

    [bunch of code]

注意:您还可以查看 Durable Functions您可以在其中处理复杂的工作流程，而无需自己管理排队。但由于您在本例中的场景非常简单，所以我没有介绍它。