快速入门：创建 Python Durable Functions 应用

3. 根据提示提供以下信息：

   Prompt	操作	说明
   选择函数应用项目的语言	选择“Python”。	创建本地 Python Functions 项目。
   选择版本	选择“Azure Functions v4”。	只有在尚未安装 Core Tools 的情况下，才会出现此选项。 在本例中，当你首次运行应用时，即已安装 Core Tools。
   Python 版本	选择 Python 3.7、Python 3.8、Python 3.9 或 Python 3.10。	Visual Studio Code 使用所选版本创建虚拟环境。
   为项目的第一个函数选择模板	选择“暂时跳过”。
   选择打开项目的方式	选择“在当前窗口中打开”。	在所选的文件夹中打开 Visual Studio Code。

3. 根据提示提供以下信息：

   Prompt	值	说明
   选择一种语言	选择“Python（编程模型 V2）”。	使用 V2 编程模型创建本地 Python Functions 项目。
   选择版本	选择“Azure Functions v4”。	只有在尚未安装 Core Tools 的情况下，才会出现此选项。 在本例中，当你首次运行应用时，即已安装 Core Tools。
   Python 版本	选择 Python 3.7、Python 3.8、Python 3.9 或 Python 3.10。	Visual Studio Code 使用所选版本创建虚拟环境。
   选择打开项目的方式	选择“在当前窗口中打开”。	在所选的文件夹中打开 Visual Studio Code。

业务流程协调程序函数

使用一个模板在项目中创建 Durable Functions 应用代码。

1. 在命令面板中，输入内容，然后选择“Azure Functions: 创建函数”。

2. 根据提示提供以下信息：

   Prompt	操作	说明
   选择函数的模板	选择“Durable Functions 业务流程协调程序”。	创建 Durable Functions 应用业务流程。
   提供函数名称	选择“HelloOrchestrator”。	持久函数的名称。

你已添加了一个业务流程协调程序来协调活动函数。 打开 HelloOrchestrator/__init__.py 查看业务流程协调程序函数。 每次调用 context.call_activity 都会调用名为 Hello 的活动函数。

接下来，请添加引用的 Hello 活动函数。

活动函数

1. 在命令面板中，输入内容，然后选择“Azure Functions: 创建函数”。

2. 根据提示提供以下信息：

   Prompt	操作	说明
   选择函数的模板	选择“Durable Functions 活动”。	创建活动函数。
   提供函数名称	输入“Hello”。	活动函数的名称。

现已添加业务流程协调程序调用的 Hello 活动函数。 打开 Hello/__init__.py，可以看到，该函数采用某个名称作为输入，并返回一句问候语。 在活动函数中执行操作，例如，发出数据库调用或执行计算。

最后，添加一个启动业务流程的 HTTP 触发的函数。

客户端函数（HTTP 启动器）

1. 在命令面板中，输入内容，然后选择“Azure Functions: 创建函数”。

2. 根据提示提供以下信息：

   Prompt	操作	说明
   选择函数的模板	选择“Durable Functions HTTP 启动器”。	创建 HTTP 启动器函数。
   提供函数名称	输入“DurableFunctionsHttpStart”。	客户端函数的名称
   授权级别	选择“匿名”。	出于演示目的，该值允许在不使用身份验证的情况下调用函数。

现已添加一个启动业务流程的 HTTP 触发的函数。 打开 DurableFunctionsHttpStart/__init__.py，可以看到，该函数使用 client.start_new 启动新的业务流程。 然后，它使用 client.create_check_status_response 返回 HTTP 响应，其中包含可用于监视和管理新业务流程的 URL。

现已创建一个可在本地运行并可部署到 Azure 的 Durable Functions 应用。

要求

Python 编程模型的版本 2 需要以下最低版本：

• Azure Functions 运行时 v4.16+
• Azure Functions Core Tools v4.0.5095+（如果在本地运行）
• azure-functions-durable v1.2.4+

启用 v2 编程模型

运行 v2 编程模型需要以下应用程序设置：

• 名称：AzureWebJobsFeatureFlags
• 值：EnableWorkerIndexing

如果使用 Azure Functions Core Tools 在本地运行，则应将此设置添加到 local.settings.json 文件中。 如果要在 Azure 中运行，请使用相关工具完成这些步骤：

az functionapp config appsettings set --name <FUNCTION_APP_NAME> --resource-group <RESOURCE_GROUP_NAME> --settings AzureWebJobsFeatureFlags=EnableWorkerIndexing

Update-AzFunctionAppSetting -Name <FUNCTION_APP_NAME> -ResourceGroupName <RESOURCE_GROUP_NAME> -AppSetting @{"AzureWebJobsFeatureFlags" = "EnableWorkerIndexing"}

若要使用这 3 种函数类型创建基本的 Durable Functions 应用程序，请将 function_app.py 的内容替换为以下 Python 代码：

import azure.functions as func
import azure.durable_functions as df

myApp = df.DFApp(http_auth_level=func.AuthLevel.ANONYMOUS)

# An HTTP-triggered function with a Durable Functions client binding
@myApp.route(route="orchestrators/{functionName}")
@myApp.durable_client_input(client_name="client")
async def http_start(req: func.HttpRequest, client):
    function_name = req.route_params.get('functionName')
    instance_id = await client.start_new(function_name)
    response = client.create_check_status_response(req, instance_id)
    return response

# Orchestrator
@myApp.orchestration_trigger(context_name="context")
def hello_orchestrator(context):
    result1 = yield context.call_activity("hello", "Seattle")
    result2 = yield context.call_activity("hello", "Tokyo")
    result3 = yield context.call_activity("hello", "London")

    return [result1, result2, result3]

# Activity
@myApp.activity_trigger(input_name="city")
def hello(city: str):
    return f"Hello {city}"

请查看下表，了解每个函数及其在示例中的用途的说明：

1. 若要测试函数，请在 Hello 活动函数代码中（在 Hello/__init__.py 中）设置断点。 按 F5 或者在命令面板中选择“调试: 开始调试”启动函数应用项目。 Core Tools 的输出会显示在终端面板中。

   注意

   有关调试的详细信息，请参阅 Durable Functions 诊断。

1. 若要测试函数，请在 hello 活动函数代码中设置一个断点。 按 F5 或者在命令面板中选择“调试: 开始调试”启动函数应用项目。 Core Tools 的输出会显示在终端面板中。

   注意

   有关调试的详细信息，请参阅 Durable Functions 诊断。

5. 使用浏览器或 HTTP 测试工具向 URL 终结点发送 HTTP POST 请求。

   将最后一个段替换为业务流程协调程序函数的名称 (HelloOrchestrator)。 URL 应类似于 http://localhost:7071/api/orchestrators/HelloOrchestrator。

   响应是 HTTP 函数的初始结果。 它让你知道持久业务流程已成功启动。 它尚未显示业务流程的最终结果。 响应中包括了几个有用的 URL。 现在，查询业务流程的状态。

6. 复制 statusQueryGetUri 的 URL 值，将其粘贴到浏览器的地址栏中，然后执行请求。 还可以继续使用 HTTP 测试工具发出 GET 请求。

   请求将查询业务流程实例的状态。 应该会看到实例已完成，并且它包含持久函数的输出或结果。 它如以下示例所示：

   {
       "name": "HelloOrchestrator",
       "instanceId": "9a528a9e926f4b46b7d3deaa134b7e8a",
       "runtimeStatus": "Completed",
       "input": null,
       "customStatus": null,
       "output": [
           "Hello Tokyo!",
           "Hello Seattle!",
           "Hello London!"
       ],
       "createdTime": "2020-03-18T21:54:49Z",
       "lastUpdatedTime": "2020-03-18T21:54:54Z"
   }
   

5. 使用浏览器或 HTTP 测试工具向 URL 终结点发送 HTTP POST 请求。

   将最后一个段替换为业务流程协调程序函数的名称 (HelloOrchestrator)。 URL 应类似于 http://localhost:7071/api/orchestrators/HelloOrchestrator。

   响应是 HTTP 函数的初始结果。 它让你知道持久业务流程已成功启动。 它尚未显示业务流程的最终结果。 响应中包括了几个有用的 URL。 现在，查询业务流程的状态。

6. 复制 statusQueryGetUri 的 URL 值，将其粘贴到浏览器的地址栏中，然后执行请求。 还可以继续使用 HTTP 测试工具发出 GET 请求。

   请求将查询业务流程实例的状态。 应该会看到实例已完成，并且它包含持久函数的输出或结果。 它如以下示例所示：

   {
       "name": "hello_orchestrator",
       "instanceId": "9a528a9e926f4b46b7d3deaa134b7e8a",
       "runtimeStatus": "Completed",
       "input": null,
       "customStatus": null,
       "output": [
           "Hello Tokyo!",
           "Hello Seattle!",
           "Hello London!"
       ],
       "createdTime": "2020-03-18T21:54:49Z",
       "lastUpdatedTime": "2020-03-18T21:54:54Z"
   }
   

1. 从输出面板复制 HTTP 触发器的 URL。 调用 HTTP 触发的函数的 URL 必须采用此格式：

   https://<functionappname>.chinacloudsites.cn/api/orchestrators/HelloOrchestrator

1. 从输出面板复制 HTTP 触发器的 URL。 调用 HTTP 触发的函数的 URL 必须采用此格式：

   https://<functionappname>.chinacloudsites.cn/api/orchestrators/hello_orchestrator