1

我有一个 Azure DevOps 发布管道，它部署了一个 Python Azure 函数，然后调用它。Python 函数做了一些繁重的工作，因此需要几分钟才能执行。

Invoke Azure Function 任务的完成事件有两个选项： Api Response和Callback .0

使用Api Response时的最大响应时间是 20 秒，所以我需要使用Callback。好的。使用此文档，我实现了一个 Azure 函数，该函数立即返回一个 HTTPResponse，然后将完成数据发布到指定的端点。这是我的 Azure 函数的完整代码：

import logging
import time
import threading

import azure.functions as func

def main(req: func.HttpRequest) -> func.HttpResponse:

    t = threading.Thread(target=do_work, args=(req,))
    t.start()

    return func.HttpResponse("Succeeded", status_code=200)

def do_work(req: func.HttpRequest):

    logging.info ("Starting asynchronous worker task")

    #time.sleep(21)

    try:
        planUrl = req.headers["PlanUrl"]
        projectId = req.headers["ProjectId"]
        hubName = req.headers["HubName"]
        planId = req.headers["PlanId"]
        taskInstanceId = req.headers["TaskInstanceId"]
        jobId = req.headers["JobId"]

        endpoint = f"{planUrl}/{projectId}/_apis/distributedtask/hubs/{hubName}/plans/{planId}/events?api-version=2.0-preview.1"
        body = {
            "name": "TaskCompleted",
            "taskId": taskInstanceId,
            "jobId": jobId,
            "result": "succeeded"
        }
        logging.info(endpoint)
        logging.info(body)
        requests.post(endpoint, data=body)

    except:
        pass

    finally:
        logging.info ("Completed asynchronous worker task")

现在，Invoke Azure Function 任务不会超时，但也不会完成。看起来它正在等待其他事情发生：

等死

不知道我应该在这里做什么。我也在GitHub 上关注这个线程，但它并没有导致解决方案。

4

2 回答 2

0

除非您使用的是 Durable 函数（此处不需要），否则 Azure Functions 不支持将后台作业作为此类函数执行的一部分。

一旦函数返回响应，该通道就会以任何后台操作都无法按预期工作的方式关闭（异常 - 持久函数）。

如果您需要像这样异步工作并且您可以不等待响应，推荐的方法是使用多个函数。

在这种情况下，您的 HttpTrigger 可以将消息放入队列（或任何其他消息传递服务）并立即返回响应。然后，您将有一个队列触发器（或其他基于事件的触发器）来从队列（或任何此类消息传递服务）中获取事件并进行繁重的工作，一旦完成，就可以在您的示例中发布到该端点。

如果您只想使用一个功能来实现这一点，那么从您的 devops 管道中，您可以直接将消息发送到消息传递服务并让您的功能触发该功能。

希望这可以帮助！

于 2019-11-21T08:30:51.560 回答
0

我在任何地方都找不到明确记录，但似乎您需要添加授权标头（至少在本地运行时）

调试我的（非常相似的 C#）函数，当我包含标头时，回调响应给我一个带有空正文的 204 状态代码，当我不包含标头时，它给我一个带有 Azure DevOps 登录页面的 203 响应。

不记名令牌的传递方式与其他系统变量相同，AuthToken因此您需要添加Authorization值为"Bearer " + req.headers["AuthToken"]

于 2022-01-24T13:05:23.350 回答