Azure 函数 CancellationToken

Question

我对 AzureFunctions 还很陌生，所以请原谅我问一个简单的问题......

我有以下代码，当队列中有一个项目时会触发该代码

[FunctionName("ProcessCompanies")]
    public async Task ProcessCompaniesAsync([ActivityTrigger] IDurableOrchestrationContext context,
        [Queue("outqueue"), StorageAccount("AzureWebJobsStorage")] ICollector<myCompanyData> msg,
        ILogger log)
    {
        
        log.LogInformation("Getting companies");
        var companies = await _myService.GetCompaniesAsync(); //here how to pass cancellation token?
        log.LogInformation($"Found {companies.companies.Count} companies.");

        companies.companies.ForEach(msg.Add);

        log.LogInformation($"{companies.companies.Count} companies added to queue.");
    }

如何将 CancellationToken 传递给异步调用？主要是我应该通过吗？在本例中，我执行 HTTP API 请求

Answer 1

您可以将 CancellationToken 注入(inject)到函数方法中。这是一种获取函数正常关闭通知的方法。请参阅https://learn.microsoft.com/en-us/azure/azure-functions/functions-dotnet-class-library?tabs=v4%2Ccmd#cancellation-tokens

注入(inject)后，您可以将其传递给下游调用。是否应该将其传递给该 API 由您决定。进程终止之前有一段很短的时间，因此如果调用时间不长，您可以尝试完成它。