Azure Durable Orchestrator子Orchestrator任务从未解决

Question

我正在尝试使用子编排器构建一个简单的编排器func附加调用。问题出现在主编排器中，并调用以等待ctx。CallSubOrchestratorAsync（“sub orchestration”，someInput）-如果我将sub Orchistrator中的代码从await Send_SomeData（）更改，则任务永远不会解析/完成；发送_SomeData（）。等待（）；那就行了，但这不是我想要的。据我所知，编排功能支持异步/等待

谢谢！

代码如下：

主编曲

[FunctionName("main-orchestration")]
public static async Task MainOrchestrationAsync(
     [OrchestrationTrigger] IDurableOrchestrationContext ctx, 
     ILogger log)
{
     var someInput = "my msg";
     await ctx.CallSubOrchestratorAsync("sub-orchestration", someInput);
     log.LogWarning("finish");
}

副指挥

[FunctionName("sub-orchestration")]
public static async Task SubOrchestrationAsync(
     [OrchestrationTrigger] IDurableOrchestrationContext ctx, 
     ILogger log)
{
     log.LogWarning("Sub Start");
     await Send_SomeData(some_url, some_message);
     log.LogWarning("Sub End");
}

发送_一些数据

public static async Task<string> ConnectAsync(string url, string message)
{
     using var request = new HttpRequestMessage
     {
          RequestUri = new Uri(url),
          Method = HttpMethod.Post, 
          Content = new FormUrlEncodedContent(new[]
          {
                    ...message...
          })
     };

     var response = await _httpClient.SendAsync(request);
     response.EnsureSuccessStatusCode();

     return await response.Content.ReadAsStringAsync();
}

更新：我决定从头开始创建一个示例，以避免遗漏某些内容，并获得可以复制/粘贴以进行调试的内容。下面是另一个例子。日志消息的主端从未出现，因此.CallSubOrchestratorAsync中的任务从未解析。

我错过了什么？再次感谢！

using System;
using System.Collections.Generic;
using System.Net.Http;
using System.Threading.Tasks;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.DurableTask;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.Azure.WebJobs.Host;
using Microsoft.Extensions.Logging;

namespace _Await_Issue
{
    public static class Function1
    {
        [FunctionName("Main")]
        public static async Task RunOrchestrator(
            [OrchestrationTrigger] IDurableOrchestrationContext context,
            ILogger log)
        {
            log.LogWarning("Main Start");

            try
            {
                await context.CallSubOrchestratorAsync("Sub", null);
            }
            catch (Exception e)
            {
                Console.WriteLine(e);
                throw;
            }
            
            log.LogWarning("Main End");
        }

        [FunctionName("Sub")]
        public static async Task RunSubOrchestrator(
            [OrchestrationTrigger] IDurableOrchestrationContext context,
            ILogger log)
        {
            log.LogWarning("Sub Start");

            var data = await GetDataAsync("https://www.google.com");

            log.LogWarning("Sub End");
        }

        [FunctionName("Start")]
        public static async Task<HttpResponseMessage> HttpStart(
            [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")]
            HttpRequestMessage req,
            [DurableClient] IDurableOrchestrationClient starter,
            ILogger log)
        {
            // Function input comes from the request content.
            string instanceId = await starter.StartNewAsync("Main", null);

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

            return starter.CreateCheckStatusResponse(req, instanceId);
        }

        public static async Task<string> GetDataAsync(string url)
        {
            var httpClient = new HttpClient();

            using var request = new HttpRequestMessage
            {
                RequestUri = new Uri(url),
                Method = HttpMethod.Get,
            };

            var response = await httpClient.SendAsync(request);
            response.EnsureSuccessStatusCode();

            return await response.Content.ReadAsStringAsync();
        }
    }
}

Answer 1

我在这里找到了光））回答我自己的问题，因为它可能会帮助别人。

正如彼得·邦斯（Peter Bons）所指出的那样Send_SomeData方法受到怀疑））

一般来说，问题出在“确定性 Api”中，因为 Azure 团队在文档确定性 API 说明中调用

在我的例子中，Send_SomeData inside使用HttpClient与外部endpoint通信。不建议这样做，因为这可能会导致意外的行为，就像我使用await的情况一样...

如果有这样的代码部分（例如，在我的例子中是Send_SomeData），则将其放在活动中，并使用上下文调用它。CallActivityAsync（）-（请注意，Activity funcs的执行时间有限）