c# - 正确使用Azure Durable Function - 序列化复杂对象

因此，我正在对一些Azure Durable Functions进行原型(prototype)设计，尝试了解它们是否适合我们内部 API 系统的建议解决方案。

根据示例，我创建了一个Orchestrator 客户端 ( HelloOrchestratorClient.cs )，它响应 HttpTrigger 。该客户端从原始请求中提取一些信息，然后继续触发协调器功能 (HelloOrchestrator.cs)，传入提取的一些信息:

复杂的HelloOrchestratorClient.cs:

[FunctionName("HttpSyncStart")]
public static async Task<HttpResponseMessage> Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, methods: "get", Route = "orchestrators/{functionName}/wait")]
    HttpRequestMessage req,
    [OrchestrationClient] DurableOrchestrationClient starter,
    string functionName,
    ILogger log)
{       
    HttpReq originalRequest = new HttpReq() {
            DeveloperId = GetDevKey(req,apiHeaderKey),
            QueryString = req.RequestUri.Query,
            APIName = GetQueryStringValue(req,APIName),
            APIVersion = GetQueryStringValue(req,APIVersion)

    };
    string instanceId =   await starter.StartNewAsync(functionName, originalRequest);

    TimeSpan timeout = GetTimeSpan(req, Timeout) ?? TimeSpan.FromSeconds(30);
    TimeSpan retryInterval = GetTimeSpan(req, RetryInterval) ?? TimeSpan.FromSeconds(1);

    return  await starter.WaitForCompletionOrCreateCheckStatusResponseAsync(
        req,
        instanceId,
        timeout,
        retryInterval);

}

HelloOrchestrator.cs现在只是调用我们的内部 API 之一并返回 JsonProduct有效负载(简单的 POCO 描述，你猜对了，一个标题)，使用 ActivityTigger命名HelloOrchestrator.APICall进行 API 调用本身。

复杂的HelloOrchestrator.cs:

  [FunctionName("E1_JsonProduct")]
        public static async Task<List<JsonProduct>> Run(
            [OrchestrationTrigger] DurableOrchestrationContextBase context,
            ILogger log)
        {
            List<JsonProduct> output = new List<JsonProduct>();
            HttpReq r = context.GetInput<HttpReq>();
            if(r != null)
            {
                if(r.DeveloperId == null)
                {
                    return output;
                }
                output.Add(await context.CallActivityAsync<JsonProduct>("E1_CallAPI",r));
                return output;
            }
            return output;
        } 

[FunctionName("E1_CallAPI")]
public async static Task<JsonProduct> APICall([ActivityTrigger] HttpReq req,
    ILogger log)
{

    JsonProduct products  = null;
    string u = $"{baseAddress}{req.APIVersion}/{req.APIName}{req.QueryString}";  

    var request = new HttpRequestMessage(HttpMethod.Get, u);
    request.Headers.Accept.Add(
        new MediaTypeWithQualityHeaderValue("application/json")
    );
    request.Headers.Add("x-apikey",req.DeveloperId);
     log.LogInformation($"URL calling = '{request.RequestUri.AbsoluteUri}'.");
    HttpResponseMessage response = await client.SendAsync(request);
    // return await response.Content.ReadAsStringAsync();
    if(response.IsSuccessStatusCode)
    {
        var formatter = new JsonMediaTypeFormatter
        {
            SerializerSettings = HelloProj.CosmosDB.Models.Products.Converter.Settings
        };

        products = await response.Content.ReadAsAsync<JsonProduct>(new [] {formatter});
    }
    return products;
}

旁注: 如果我能让这个工作正常，计划是将一堆进程扇出到不同的 API，然后再次扇入，合并 JSON 有效负载并将其返回到发起者。

我遇到的问题

所以，当我的 List<JsonProduct>从 HelloOrchestrator.Run 返回，我收到以下 NullReferenceException在此找到Gist (大堆栈跟踪)，我收到来自 Orchestrator 客户端 的 500 响应。

下面证明output返回的实际上在运行时有一个对象:

是否是因为 JsonProduct 的复杂性(再次找到模型类 here )？我问，因为当我将我的Orchestrator Function换成更简单的模型结构时，我没有收到 500，我收到了 JSON有效负载。

此示例显示了简单的 Orchestrator 功能 HelloOrchestrator.cs ，返回一个简单的TestToDo.cs ( Gist for model ) 不会出错的平面对象:

简单的HelloOrchestrator.cs:

   [FunctionName("E1_Todo")]
    public static async Task<TestToDo> RunToDo(
    [OrchestrationTrigger] DurableOrchestrationContextBase context,
        ILogger log)
    {
        HttpReq r = context.GetInput<HttpReq>();
        TestToDo todo = new TestToDo();
        if(r != null)
        {
            todo = await context.CallActivityAsync<TestToDo>("E1_CallAPITodo",r);
        }
        return todo;
    }

[FunctionName("E1_CallAPITodo")]
public async static Task<TestToDo> APITodoCall([ActivityTrigger] HttpReq req,
    ILogger log)
{

    var request = new HttpRequestMessage(HttpMethod.Get, "https://jsonplaceholder.typicode.com/todos/1");
    request.Headers.Accept.Add(
        new MediaTypeWithQualityHeaderValue("application/json")
    );
     log.LogInformation($"URL calling = '{request.RequestUri.AbsoluteUri}'. for {req.QueryString}");
    HttpResponseMessage response = await client.SendAsync(request);
    return await response.Content.ReadAsAsync<TestToDo>();
}

c# - 正确使用Azure Durable Function - 序列化复杂对象

复杂的HelloOrchestratorClient.cs:

复杂的HelloOrchestrator.cs:

我遇到的问题

简单的HelloOrchestrator.cs:

更多信息

上一篇：c# - C# 中的 Azure 托管服务标识连接到 Azure SQL Server

下一篇：Azure 上的 Git 使用常见工具(例如 SourceTree)