azure - 持久函数 - 带状态的无限执行不起作用

Question

我正在设置一个持久的函数，该函数应该通过每小时调用自身并保持状态来无限运行。该函数编译，总线在运行时失败，并出现以下错误:

2017-07-12T07:04:05.614 Exception while executing function: Functions.DurableTimer. Microsoft.Azure.WebJobs.Host: Exception binding parameter 'context'. Microsoft.Azure.WebJobs.Extensions.DurableTask: Cannot convert to DurableOrchestrationContext.

函数代码

#r "Microsoft.Azure.WebJobs.Extensions.DurableTask"

using System;
using System.Threading;

public static async Task Run(DurableOrchestrationContext context, TraceWriter log)
{
    log.Info($"Durable function executed at: {context.CurrentUtcDateTime}");

    // sleep for one hour between calls
    DateTime nextExecution = context.CurrentUtcDateTime.AddHours(1);
    await context.CreateTimer(nextExecution, CancellationToken.None);

    int counterState = context.GetInput<int>();
    log.Info($"Counter state: {counterState}");

    counterState++;

    context.ContinueAsNew(counterState); 
}

function.json

{
  "bindings": [
    {
      "name": "context",
      "type": "orchestrationTrigger",
      "direction": "in"
    }
  ],
  "disabled": false
}

Answer 1

我的猜测是您正在尝试在门户 UI 中手动触发编排功能，但遗憾的是目前尚不支持该功能。我通过尝试重现您的确切场景并单击门户中的运行按钮进行了验证。我打开了一个错误来跟踪此问题:https://github.com/Azure/azure-functions-durable-extension/issues/10

假设是这种情况，您可以通过创建一个知道如何触发协调器功能的单独函数来解决这个问题。这是我在 GitHub 问题中发布的示例:

代码

#r "Microsoft.Azure.WebJobs.Extensions.DurableTask"

using System;

public static async Task Run(string functionName, DurableOrchestrationClient starter, TraceWriter log)
{
    log.Info($"Starting orchestration named: {functionName}");
    string instanceId = await starter.StartNewAsync(functionName, null);
    log.Info($"Started orchestration with ID = '{instanceId}'.");   
}

function.json

{
  "bindings": [
    {
      "type": "manualTrigger",
      "direction": "in",
      "name": "functionName"
    },
    {
      "name": "starter",
      "type": "orchestrationClient",
      "direction": "in"
    }
  ],
  "disabled": false
}

这是一个通用函数，可以按名称启动任何协调器函数。在您的情况下，您可以将 DurableTimer 作为输入。

很抱歉，这不是显而易见的问题，感谢您在我们平滑体验过程中的耐心等待。 :)