Azure Durable Functions 中的诊断

项目
09/20/2024

可以使用多个选项通过 Durable Functions 诊断问题。其中有些选项与适用于正则函数的选项相同，还有一些选项是 Durable Functions 特有的。

Application Insights

使用 Application Insights 是在 Azure Functions 中执行诊断和监视的建议方法。这同样适用于 Durable Functions。有关如何在函数应用中利用 Application Insights 的概述，请参阅监视 Azure Functions。

Azure Functions Durable 扩展还会发出跟踪事件，用于跟踪业务流程的端到端执行。可在 Azure 门户中使用 Application Insights Analytics 工具来查找和查询这些跟踪事件。

跟踪数据

业务流程实例的每个生命周期事件会导致将一个跟踪事件写入 Application Insights 中的跟踪集合。此事件包含带有多个字段的 customDimensions 有效负载。字段名称的前面都附有 prop__。

hubName：运行业务流程的任务中心的名称。
appName：函数应用的名称。当有多个函数应用共享同一个 Application Insights 实例时，此字段非常有用。
slotName：运行当前函数应用的部署槽位。使用部署槽位控制业务流程的版本时，此字段非常有用。
functionName：业务流程协调程序或活动函数的名称。
functionType：函数的类型，例如“业务流程协调程序”或“活动”。
instanceId：业务流程实例的唯一 ID。
state：实例的生命周期执行状态。有效值包括：
- Scheduled：函数已计划执行，但尚未开始运行。
- Started：函数已开始运行，但尚未进入等待或完成状态。
- Awaited：业务流程协调程序已计划某项工作，正在等待该工作完成。
- Listening：业务流程协调程序正在侦听外部事件通知。
- Completed：函数已成功完成。
- Failed：函数失败并出错。
reason：与跟踪事件关联的其他数据。例如，如果某个实例正在等待外部事件通知，则此字段指示该实例正在等待的事件的名称。如果函数失败，此字段会包含错误详细信息。
isReplay：指示跟踪事件是否用于重播执行的布尔值。
extensionVersion：持久任务扩展的版本。在报告扩展中可能存在的 bug 时，此版本信息是特别重要的数据。如果长时间运行的实例在运行时发生更新，它可能会报告多个版本。
sequenceNumber：事件的执行序列号。与时间戳组合使用可以帮助按执行时间对事件进行排序。 请注意，如果主机在实例正在运行时重新启动，则此数字将重置为零，因此始终先按时间戳然后按 sequenceNumber 排序很重要。

可以在 host.json 文件的 logger (Functions 1.x) 或 logging (Functions 2.0) 部分中对发出到 Application Insights 的跟踪数据的详细程度进行配置。

Functions 1.0

{
    "logger": {
        "categoryFilter": {
            "categoryLevels": {
                "Host.Triggers.DurableTask": "Information"
            }
        }
    }
}

Functions 2.0

{
    "logging": {
        "logLevel": {
            "Host.Triggers.DurableTask": "Information",
        },
    }
}

默认情况下，会发出所有非重播跟踪事件。可通过将 Host.Triggers.DurableTask 设置为 "Warning" 或 "Error" 来减少数据量，在这种情况下，只会在发生异常情况时发出跟踪事件。若要启用发出详细业务流程重播事件，请将 host.json 配置文件中的 logReplayEvents 设置为 true。

注意

默认情况下，Azure Functions 运行时会对 Application Insights 遥测数据采样，以免过度频繁地发出数据。如果在短时间内发生了许多的生命周期事件，此行为可能会导致跟踪信息丢失。 Azure Functions 监视文章介绍了如何配置此行为。

默认情况下，不记录业务流程协调程序、活动和实体函数的输入和输出。建议使用此默认行为，因为记录输入和输出可能会增加 Application Insights 成本。函数输入和输出有效负载也可能包含敏感信息。默认情况下，将记录函数输入和输出的字节数，而不记录实际有效负载。如果希望 Durable Functions 扩展记录完整的输入和输出有效负载，请将 host.json 配置文件中的 traceInputsAndOutputs 设置为 true。

单实例查询

以下查询显示 Hello Sequence 函数业务流程的单个实例的历史跟踪数据。它是使用 Kusto 查询语言编写的。它会筛选出重播执行，以便仅显示逻辑执行路径。可以通过按 timestamp 和 sequenceNumber 排序来安排事件顺序，如以下查询中所示：

let targetInstanceId = "ddd1aaa685034059b545eb004b15d4eb";
let start = datetime(2018-03-25T09:20:00);
traces
| where timestamp > start and timestamp < start + 30m
| where customDimensions.Category == "Host.Triggers.DurableTask"
| extend functionName = customDimensions["prop__functionName"]
| extend instanceId = customDimensions["prop__instanceId"]
| extend state = customDimensions["prop__state"]
| extend isReplay = tobool(tolower(customDimensions["prop__isReplay"]))
| extend sequenceNumber = tolong(customDimensions["prop__sequenceNumber"])
| where isReplay != true
| where instanceId == targetInstanceId
| sort by timestamp asc, sequenceNumber asc
| project timestamp, functionName, state, instanceId, sequenceNumber, appName = cloud_RoleName

结果是显示业务流程执行路径的跟踪事件的列表，包括所有活动函数，按执行时间以升序排序。

Application Insights 单实例已排序的查询

实例摘要查询

以下查询显示在指定时间范围中运行的所有业务流程实例的状态。

let start = datetime(2017-09-30T04:30:00);
traces
| where timestamp > start and timestamp < start + 1h
| where customDimensions.Category == "Host.Triggers.DurableTask"
| extend functionName = tostring(customDimensions["prop__functionName"])
| extend instanceId = tostring(customDimensions["prop__instanceId"])
| extend state = tostring(customDimensions["prop__state"])
| extend isReplay = tobool(tolower(customDimensions["prop__isReplay"]))
| extend output = tostring(customDimensions["prop__output"])
| where isReplay != true
| summarize arg_max(timestamp, *) by instanceId
| project timestamp, instanceId, functionName, state, output, appName = cloud_RoleName
| order by timestamp asc

结果是实例 ID 的列表及其当前运行时状态。

Application Insights 单实例查询

Durable Task Framework 日志记录

Durable 扩展日志对于了解业务流程逻辑的行为很有帮助。但这些日志并非始终包含足够的信息来调试框架级别的性能和可靠性问题。从 Durable 扩展 v2.3.0 开始，由基础 Durable Task Framework (DTFx) 发出的日志也可用于集合。

查看 DTFx 发出的日志时，请务必了解 DTFx 引擎由两个组件组成：核心调度引擎 (DurableTask.Core) 和众多受支持的存储提供程序之一（Durable Functions 默认使用 DurableTask.AzureStorage，但其他选项也可用）。

DurableTask.Core：核心业务流程执行和低级别计划日志和遥测。
DurableTask.AzureStorage：特定于 Azure 存储状态提供程序的后端日志。这些日志包括与用于存储和提取内部业务流程状态的内部队列、blob 和存储表的详细交互。
DurableTask.Netherite：特定于 Netherite 存储提供程序的后端日志（如果已启用）。
DurableTask.SqlServer：特定于 Microsoft SQL (MSSQL) 存储提供程序的后端日志（如果已启用）。

可通过更新函数应用的 host.json 文件的 logging/logLevel 部分来启用这些日志。下面的示例演示如何从 DurableTask.Core 和 DurableTask.AzureStorage 启用警告和错误日志：

{
  "version": "2.0",
  "logging": {
    "logLevel": {
      "DurableTask.AzureStorage": "Warning",
      "DurableTask.Core": "Warning"
    }
  }
}

如果已启用 Application Insights，这些日志会自动添加到 trace 集合。可使用 Kusto 查询像搜索其他 trace 日志一样搜索它们。

注意

对于生产应用程序，建议使用 "Warning" 筛选器来启用 DurableTask.Core 和适当的存储提供程序（例如 DurableTask.AzureStorage）日志。较高详细程度筛选器（如 "Information"）对于调试性能问题非常有用。但这些日志事件会占用很大容量，可能会大大增加 Application Insights 数据存储费用。

以下 Kusto 查询演示了如何查询 DTFx 日志。查询最重要的部分是 where customerDimensions.Category startswith "DurableTask"，因为它将结果筛选到 DurableTask.Core 和 DurableTask.AzureStorage 类别中的日志。

traces
| where customDimensions.Category startswith "DurableTask"
| project
    timestamp,
    severityLevel,
    Category = customDimensions.Category,
    EventId = customDimensions.EventId,
    message,
    customDimensions
| order by timestamp asc

结果为 Durable Task Framework 日志提供程序编写的一组日志。

Application Insights DTFx 查询结果

有关可用日志事件的详细信息，请参阅 GitHub 上的 Durable Task Framework 结构化日志记录文档。

应用日志记录

直接从业务流程协调程序函数写入日志时，必须注意业务流程协调程序的重播行为。例如，考虑以下业务流程协调程序函数：

[FunctionName("FunctionChain")]
public static async Task Run(
    [OrchestrationTrigger] IDurableOrchestrationContext context,
    ILogger log)
{
    log.LogInformation("Calling F1.");
    await context.CallActivityAsync("F1");
    log.LogInformation("Calling F2.");
    await context.CallActivityAsync("F2");
    log.LogInformation("Calling F3");
    await context.CallActivityAsync("F3");
    log.LogInformation("Done!");
}

[Function("FunctionChain")]
public static async Task Run(
    [OrchestrationTrigger] TaskOrchestrationContext context,
    FunctionContext executionContext)
{
    ILogger log = executionContext.GetLogger("FunctionChain");
    log.LogInformation("Calling F1.");
    await context.CallActivityAsync("F1");
    log.LogInformation("Calling F2.");
    await context.CallActivityAsync("F2");
    log.LogInformation("Calling F3");
    await context.CallActivityAsync("F3");
    log.LogInformation("Done!");
}

const df = require("durable-functions");

module.exports = df.orchestrator(function*(context){
    context.log("Calling F1.");
    yield context.df.callActivity("F1");
    context.log("Calling F2.");
    yield context.df.callActivity("F2");
    context.log("Calling F3.");
    yield context.df.callActivity("F3");
    context.log("Done!");
});

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

def orchestrator_function(context: df.DurableOrchestrationContext):
    logging.info("Calling F1.")
    yield context.call_activity("F1")
    logging.info("Calling F2.")
    yield context.call_activity("F2")
    logging.info("Calling F3.")
    yield context.call_activity("F3")
    return None

main = df.Orchestrator.create(orchestrator_function)

@FunctionName("FunctionChain")
public void functionChain(
        @DurableOrchestrationTrigger(name = "ctx") TaskOrchestrationContext ctx,
        ExecutionContext functionContext) {
    Logger log = functionContext.getLogger();
    log.info("Calling F1.");
    ctx.callActivity("F1").await();
    log.info("Calling F2.");
    ctx.callActivity("F2").await();
    log.info("Calling F3.");
    ctx.callActivity("F3").await();
    log.info("Done!");
}

生成的日志数据应如以下示例输出所示：

Calling F1.
Calling F1.
Calling F2.
Calling F1.
Calling F2.
Calling F3.
Calling F1.
Calling F2.
Calling F3.
Done!

注意

请记住，尽管日志声明要调用 F1、F2 和 F3，但实际上仅在首次遇到这些函数时才调用这些函数。在重播期间发生的后续调用将被跳过，输出将重播到业务流程协调程序逻辑。

如果只想针对非重播执行编写日志，可以编写一个条件表达式，规定仅当“is replaying”标志为 false 时才记录日志。沿用上面的示例，不过这一次要执行重播检查。

[FunctionName("FunctionChain")]
public static async Task Run(
    [OrchestrationTrigger] IDurableOrchestrationContext context,
    ILogger log)
{
    if (!context.IsReplaying) log.LogInformation("Calling F1.");
    await context.CallActivityAsync("F1");
    if (!context.IsReplaying) log.LogInformation("Calling F2.");
    await context.CallActivityAsync("F2");
    if (!context.IsReplaying) log.LogInformation("Calling F3");
    await context.CallActivityAsync("F3");
    log.LogInformation("Done!");
}

从 Durable Functions 2.0 开始，.NET 业务流程协调程序函数还可以选择创建在重播期间自动筛选掉日志语句的 ILogger。这种自动筛选是使用 IDurableOrchestrationContext.CreateReplaySafeLogger(ILogger) API 完成的。

[FunctionName("FunctionChain")]
public static async Task Run(
    [OrchestrationTrigger] IDurableOrchestrationContext context,
    ILogger log)
{
    log = context.CreateReplaySafeLogger(log);
    log.LogInformation("Calling F1.");
    await context.CallActivityAsync("F1");
    log.LogInformation("Calling F2.");
    await context.CallActivityAsync("F2");
    log.LogInformation("Calling F3");
    await context.CallActivityAsync("F3");
    log.LogInformation("Done!");
}

注意

前面的 C# 示例适用于 Durable Functions 2.x。对于 Durable Functions 1.x，必须使用 DurableOrchestrationContext 而不是 IDurableOrchestrationContext。有关版本之间差异的详细信息，请参阅 Durable Functions 版本一文。

在 Durable Functions（.NET 独立）中，可以创建一个在重播期间自动筛选出日志语句的 ILogger。与 Durable Functions（进程内）的主要区别在于你不提供现有的 ILogger。此记录器是通过 TaskOrchestrationContext.CreateReplaySafeLogger 重载创建的。

[Function("FunctionChain")]
public static async Task Run([OrchestrationTrigger] TaskOrchestrationContext context)
{
    ILogger log = context.CreateReplaySafeLogger("FunctionChain");
    log.LogInformation("Calling F1.");
    await context.CallActivityAsync("F1");
    log.LogInformation("Calling F2.");
    await context.CallActivityAsync("F2");
    log.LogInformation("Calling F3");
    await context.CallActivityAsync("F3");
    log.LogInformation("Done!");
}

注意

在 .NET 独立辅助角色的 Durable Functions 中，已删除将现有 ILogger 包装到重播安全记录器的功能。

const df = require("durable-functions");

module.exports = df.orchestrator(function*(context){
    if (!context.df.isReplaying) context.log("Calling F1.");
    yield context.df.callActivity("F1");
    if (!context.df.isReplaying) context.log("Calling F2.");
    yield context.df.callActivity("F2");
    if (!context.df.isReplaying) context.log("Calling F3.");
    yield context.df.callActivity("F3");
    context.log("Done!");
});

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

def orchestrator_function(context: df.DurableOrchestrationContext):
    if not context.is_replaying:
        logging.info("Calling F1.")
    yield context.call_activity("F1")
    if not context.is_replaying:
        logging.info("Calling F2.")
    yield context.call_activity("F2")
    if not context.is_replaying:
        logging.info("Calling F3.")
    yield context.call_activity("F3")
    logging.info("Done!")
    return None

main = df.Orchestrator.create(orchestrator_function)

@FunctionName("FunctionChain")
public void functionChain(
        @DurableOrchestrationTrigger(name = "ctx") TaskOrchestrationContext ctx,
        ExecutionContext functionContext) {
    Logger log = functionContext.getLogger();
    if (!ctx.getIsReplaying()) log.info("Calling F1.");
    ctx.callActivity("F1").await();
    if (!ctx.getIsReplaying()) log.info("Calling F2.");
    ctx.callActivity("F2").await();
    if (!ctx.getIsReplaying()) log.info("Calling F3.");
    ctx.callActivity("F3").await();
    log.info("Done!");
}

经过之前提到的更改，日志输出如下：

Calling F1.
Calling F2.
Calling F3.
Done!

自定义状态

使用自定义业务流程状态，可以为业务流程协调程序函数设置自定义状态值。然后可通过 HTTP 状态查询 API 或通过特定于语言的 API 调用，对外部客户端显示此自定义状态。自定义业务流程状态为业务流程协调程序函数实现了更丰富的监视。例如，业务流程协调程序函数代码可以调用“set custom status”API 来更新长时间运行的操作的进度。然后，客户端（例如网页或其他外部系统）可以定期查询 HTTP 状态查询 API 以获得更丰富的进度信息。下面提供用于在业务流程协调程序函数中设置自定义状态值的示例代码：

[FunctionName("SetStatusTest")]
public static async Task SetStatusTest([OrchestrationTrigger] IDurableOrchestrationContext context)
{
    // ...do work...

    // update the status of the orchestration with some arbitrary data
    var customStatus = new { completionPercentage = 90.0, status = "Updating database records" };
    context.SetCustomStatus(customStatus);

    // ...do more work...
}

注意

[Function("SetStatusTest")]
public static async Task SetStatusTest([OrchestrationTrigger] TaskOrchestrationContext context)
{
    // ...do work...

    // update the status of the orchestration with some arbitrary data
    var customStatus = new { completionPercentage = 90.0, status = "Updating database records" };
    context.SetCustomStatus(customStatus);

    // ...do more work...
}

const df = require("durable-functions");

module.exports = df.orchestrator(function*(context) {
    // ...do work...

    // update the status of the orchestration with some arbitrary data
    const customStatus = { completionPercentage: 90.0, status: "Updating database records", };
    context.df.setCustomStatus(customStatus);

    // ...do more work...
});

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

def orchestrator_function(context: df.DurableOrchestrationContext):
    # ...do work...

    # update the status of the orchestration with some arbitrary data
    custom_status = {'completionPercentage': 90.0, 'status': 'Updating database records'}
    context.set_custom_status(custom_status)
    # ...do more work...

    return None

main = df.Orchestrator.create(orchestrator_function)

@FunctionName("SetStatusTest")
public void setStatusTest(
        @DurableOrchestrationTrigger(name = "ctx") TaskOrchestrationContext ctx) {
    // ...do work...

    // update the status of the orchestration with some arbitrary data
    ctx.setCustomStatus(new Object() {
        public final double completionPercentage = 90.0;
        public final String status = "Updating database records";
    });

    // ...do more work...
}

在业务流程正在运行时，外部客户端可以提取此自定义状态：

GET /runtime/webhooks/durabletask/instances/instance123?code=XYZ

客户端将收到以下响应：

{
  "runtimeStatus": "Running",
  "input": null,
  "customStatus": { "completionPercentage": 90.0, "status": "Updating database records" },
  "output": null,
  "createdTime": "2017-10-06T18:30:24Z",
  "lastUpdatedTime": "2017-10-06T19:40:30Z"
}

警告

自定义状态有效负载限制为 16 KB 的 UTF-16 JSON 文本，因为它需要能够容纳在 Azure 表存储列中。如果需要更大的有效负载，可以使用外部存储。

布式跟踪

分布式跟踪会追踪请求，并显示不同的服务互相交互的方式。在 Durable Functions 中，它还将业务流程和活动关联在一起。这有助于了解业务流程的步骤相对于整个业务流程所需的时间。它还有助于了解应用程序遇到问题的位置或引发异常的位置。所有语言和存储提供程序都支持此功能。

注意

分布式跟踪 V2 需要 Durable Functions v2.12.0 或更高版本。此外，分布式跟踪 V2 处于预览状态，因此不会检测某些 Durable Functions 模式。例如，它不会检测 Durable Entities 操作，也不会在 Application Insights 中显示跟踪。

设置分布式跟踪

若要设置分布式跟踪，请更新 host.json 并设置 Application Insights 资源。

host.json

"durableTask": {
  "tracing": {
    "distributedTracingEnabled": true,
    "Version": "V2"
  }
}

Application Insights

如果未使用 Application Insights 资源来配置函数应用，请按照此处的说明对其进行配置。

检查跟踪

在 Azure Insights 资源中，导航到“事务搜索”。在结果中，检查以 Durable Functions 特定前缀（例如 orchestration:、activity: 等）开头的 Request 和 Dependency 事件。选择其中一个事件将打开一个甘特图，显示端到端分布式跟踪。

故障排除

如果在 Application Insights 中看不到跟踪，请务必在运行应用程序后等待约 5 分钟，以确保所有数据都传播到 Application Insights 资源。

调试

Azure Functions 支持直接调试函数代码，Durable Functions 承袭了这项支持，不管它是在 Azure 中还是在本地运行。但是，调试时需注意几种行为：

重播：收到新输入时，业务流程协调程序函数会定期重播。此行为意味着，业务流程协调程序函数的单次逻辑执行可能导致多次命中同一断点，尤其是事先已在函数代码中设置了该断点时。
等待：每当在业务流程协调程序函数中遇到 await，该函数就会将控制权出让回到 Durable Task Framework 调度程序。如果这是首次遇到特定的 await，则关联的任务永远不可恢复。因为任务永远不可恢复，所以无法单步跳过等待（在 Visual Studio 中按 F10）。仅当任务正在重播时，才能跳过。
消息超时：Durable Functions 在内部使用队列消息来驱动业务流程协调程序函数、活动函数和实体函数的执行。在多 VM 环境中，长时间中断调试可能会使另一个 VM 拾取消息，从而导致重复执行。正则队列触发器函数也存在此行为，但必须在此上下文中指出，因为队列属于实现细节。
停止和启动：Durable Functions 中的消息在调试会话之间保持不变。如果在执行持久函数时停止调试并终止本地主机进程，则该函数可能会在将来的调试会话中自动重新执行。如果不需要，则此行为可能会造成混淆。要避免此行为，可以使用新的任务中心或在调试会话之间清除任务中心内容。

提示

在业务流程协调程序函数中设置断点时，如果只想中断非重播执行，可以设置一个条件断点，规定仅当“is replaying”为 false 时才中断。

存储

默认情况下，Durable Functions 在 Azure 存储中存储状态。此行为意味着，可以使用 Azure 存储资源管理器等工具检查业务流程的状态。

Azure 存储资源管理器屏幕截图

此工具非常适合用于调试，因为可以看到业务流程所处的确切状态。此外，还可以检查队列中的消息，了解哪项工作处于挂起状态（或停滞在某种状态）。

警告

尽管可以在表存储中方便查看执行历史记录，但不要对此表有任何依赖。它可能会随着 Durable Functions 扩展的演变而变化。

注意

可以配置其他存储提供程序，而不是默认的 Azure 存储提供程序。可能需要使用不同的工具来检查基础状态，具体取决于为应用配置的存储提供程序。有关详细信息，请参阅 Durable Functions 存储提供程序文档。

Durable Functions 监视器

Durable Functions 监视器是用于监视、管理和调试业务流程和实体实例的图形工具。它可作为 Visual Studio Code 扩展提供，也可作为一个独立应用。有关设置和功能列表的信息，请参阅此 Wiki。

Durable Functions 故障排除指南

要对常见问题症状进行故障排除，如业务流程停滞、无法启用，运行缓慢等，请参阅此故障排除指南。

后续步骤

了解有关在 Azure Functions 中进行监视的详细信息

通过

Azure Durable Functions 中的诊断

Application Insights

跟踪数据

Functions 1.0

Functions 2.0

单实例查询

实例摘要查询

Durable Task Framework 日志记录

应用日志记录

自定义状态

布式跟踪

设置分布式跟踪

host.json

Application Insights

检查跟踪

故障排除

调试

存储

Durable Functions 监视器

Durable Functions 故障排除指南

后续步骤

其他资源