如何在持久函数中中止 [活动触发器] 函数

Question

我有一个[DurableOrchestrationClient]，它启动了一个[OrchestrationTrigger]，它启动了一个长时间运行的[ActivityTrigger]函数。
我知道如何使用 TerminateAsync(( 来终止 [OrchestrationTrigger] 的运行。

问题是当我终止 [OrchestrationTrigger] 函数时，[活动触发器] 没有中止。[活动触发器] 一直运行，直到完成。
我需要一种方法在调用 TerminateAsync(( 时中止长时间运行的 [ActivityTrigger]。

我的猜测是，我可以将 CancelToken 传递给 [ActivityTrigger] 函数，然后检查 cancelToken.IsCancelRequest 以中止。
但是如何做到这一点呢？

这是一个测试代码

[FunctionName("A_ProcessPayment")]
public static async Task<processTracker> A_ProcessPayment(
[ActivityTrigger] DurableActivityContext context, 
TraceWriter log,
CancellationToken cancellationToken)
{
processTracker p = context.GetInput<processTracker>();
try
{
for (int i = 0; i < 5; i++){
if (cancellationToken.IsCancellationRequested) // This is always false! 
{
break;  
}
Trace.WriteLine("Long task loop: " + i);
await Task.Delay(10000);
}
}
catch (OperationCanceledException) {
log.Warning("C# HTTP trigger function canceled.");
return p;
}
Trace.WriteLine("Long task DONE");
return p;
}

Answer 1

更新：

可以选择将令牌作为对象传递给活动触发器，如下所示：

using System.Collections.Generic;
using System.Net.Http;
using System.Threading.Tasks;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.Azure.WebJobs.Host;
using Microsoft.Extensions.Logging;
namespace OrchesterTrigger
{
public static class Function1
{
[FunctionName("Function1")]
public static async Task<List<string>> RunOrchestrator(
[OrchestrationTrigger] DurableOrchestrationContext context)
{
var outputs = new List<string>();
string mytoken = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx";
outputs.Add(await context.CallActivityAsync<string>("Function1", mytoken));
return outputs;
}
[FunctionName("Function1")]
public static string SayHello([ActivityTrigger] string mytoken, ILogger log)
{
log.LogInformation($"Mytoken is {mytoken}.=======================================");
return $"Mytoken is {mytoken}!";
}
[FunctionName("Function1_HttpStart")]
public static async Task<HttpResponseMessage> HttpStart(
[HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")]HttpRequestMessage req,
[OrchestrationClient]DurableOrchestrationClient starter,
ILogger log)
{
// Function input comes from the request content.
string instanceId = await starter.StartNewAsync("Function1", null);
log.LogInformation($"================================Started orchestration with ID = '{instanceId}'.");
return starter.CreateCheckStatusResponse(req, instanceId);
}
}
}

我展示的是传入字符串类型的值，您可以将其替换为所需的类型，它是类型兼容的。

原答案：

活动触发器启动后无法停止。 您可以选择将这些步骤分解为更多步骤。

查看官方文档。 活动函数和子业务流程将运行完成，无论您是否已终止调用它们的业务流程实例。