HttpTrigger 使用python依次执行

Question

我使用 python 创建了一个 HttpTrigger Azure 函数。但我想在同一个项目中使用 python 创建另一个 HttpTrigger Azure Functions。在这个应用程序中，我想在执行第二个 HttpTrigger Azure 函数之后执行第一个 HttpTrigger Azure 函数。我该如何实现？

因为在 Python Azure Functions 中没有 Durable Functions。这就是为什么我无法理解如何在另一个 azure 函数执行后执行。

Answer 1

假设有两个HttpTrigger函数HttpTriggerA和HttpTriggerB，我想到的直接解决方案是使用requests通过HTTP客户端请求从HttpTriggerB函数请求HttpTriggerA的公共url，作为下面是我第一个版本的HttpTriggerB 代码中的代码。

import logging

import azure.functions as func
import requests
from urllib.parse import urlparse

def main(req: func.HttpRequest) -> func.HttpResponse:
    logging.info('Python HTTP trigger function processed a request.')

    name = req.params.get('name') or 'Peter Pan'
    codeA = req.params.get('codeA') or ''
    o = urlparse(req.url)
    if not name:
        try:
            req_body = req.get_json()
        except ValueError:
            pass
        else:
            name = req_body.get('name')

    if name:
        print("B be invoked.")
        resp = requests.get(f"{o.scheme}://{o.netloc}/api/HttpTriggerA?name={name}&code={codeA}")
        return func.HttpResponse(f"Hello {name}! from B {resp.status_code == 200 and resp.text or ''}")
    else:
        return func.HttpResponse(
             "Please pass a name on the query string or in the request body",
             status_code=400
        )

但是，在我在本地或 Azure 上测试上述代码后，它将无法正常工作。当我访问 url http(s)://<the host of local or Azure>:<7071 or 80>/api/HttpTriggerB?name=Peter%20Pan&code=<code for HttpTriggerB>&codeA=<code for HttpTriggerA> 时，它将挂在代码行 resp = requests.get(f"{o.scheme}://{o.netloc}/api/HttpTriggerA?name={name}&code={codeA}")。挂起问题的原因似乎是由单例或单线程中运行的函数引起的。

所以我切换到另一个解决方案，使用来自HttpTriggerB 的html 内容的Ajax 请求。如下图所示。

这是我的HttpTriggerB函数代码，HttpTriggerA函数只是由func new生成的。

import logging

import azure.functions as func
#import requests
from urllib.parse import urlparse

def main(req: func.HttpRequest) -> func.HttpResponse:
    logging.info('Python HTTP trigger function processed a request.')

    name = req.params.get('name') or 'Peter Pan'
    codeA = req.params.get('codeA') or ''
    o = urlparse(req.url)
    if not name:
        try:
            req_body = req.get_json()
        except ValueError:
            pass
        else:
            name = req_body.get('name')

    if name:
        print("B be invoked.")
        #resp = requests.get(f"{o.scheme}://{o.netloc}/api/httptriggera?name={name}&code={req.params.get('codeA')}")
        html = """
<script src="https://code.jquery.com/jquery-3.4.1.min.js"></script>

Hello """+name+"""! from B<br/>
<span id="A"></span>

<script>
$.when( 
  $.get('"""+o.scheme+'://'+o.netloc+'/api/HttpTriggerA?name='+name+'&code='+codeA+"""'),
  $.ready
).done(function( data ) {
  $( "#A" ).html( data[0] );
});
</script>
"""
        return func.HttpResponse(html, mimetype="text/html")
    else:
        return func.HttpResponse(
             "Please pass a name on the query string or in the request body",
             status_code=400
        )

希望对你有帮助。