需要 Azure 持久功能活动触发器吗？

Question

我有一个简单的持久函数，我的目标是执行一些后台工作（在这种情况下启动 Azure 数据库）。

我有以下代码正在运行，但是我想知道需要 ActivityTrigger 函数的目的是什么。

如果我不包含它并尝试在 CreateDB 本身中工作，则持久功能永远不会正确完成并保持运行状态。

public static class CreateDBFn
{
    private const string CreateDBConstant = "CreateDB";
    private const string CreateDBTaskConstant = CreateDBConstant + "Task";

    [FunctionName(CreateDBConstant + "Start")]
    public static async Task<HttpResponseMessage> Run(
   [HttpTrigger(AuthorizationLevel.Function, methods: "post", Route = CreateDBConstant + "/{Name}")] HttpRequestMessage req,
   [OrchestrationClient] DurableOrchestrationClientBase starter,
   string Name,
   ILogger log)
    {
        string instanceId = await starter.StartNewAsync(CreateDBConstant, Name);

        log.LogInformation($"Started orchestration with ID = '{instanceId}'.");

        var res = starter.CreateCheckStatusResponse(req, instanceId);
        res.Headers.RetryAfter = new RetryConditionHeaderValue(TimeSpan.FromSeconds(10));
        return res;
    }

    [FunctionName(CreateDBConstant)]
    public static async Task<bool> CreateDB([OrchestrationTrigger] DurableOrchestrationContextBase context)
    {
        var Name = context.GetInput<string>();

        // I'd like to just do work here
        await Task.Delay(30000);

        // Why is it required to call out to an Activity?
        var success = await context.CallActivityAsync<bool>(CreateDBTaskConstant, Name);

        return true;
    }

    [FunctionName(CreateDBTaskConstant)]
    public static async Task<bool> CreateDBTask([ActivityTrigger] string Name)
    {
        // preform work
        await Task.Delay(30000);

        return true;
    }
}

Answer 1

不鼓励在编排器代码中启动异步操作，唯一的例外是由持久编排上下文启动的代码，例如 CallActivityAsync()。这是由于协调器函数的检查点重放行为。

来自the documentation的相关摘录

除非使用 DurableOrchestrationContext API，否则Orchestrator 代码不得启动任何异步操作。例如，没有 Task.Run、Task.Delay 或 HttpClient.SendAsync。持久任务框架在单个线程上执行编排器代码，并且无法与其他异步 API 可以调度的任何其他线程交互。

可以在协调器函数中安全等待的任务有时称为持久任务。这些是由 Durable Task Framework 创建和管理的任务。例如 CallActivityAsync、WaitForExternalEvent 和 CreateTimer 返回的任务。