当将HTTP函数触发到查询实体状态时，程序崩溃了吗？

Question

我是Azure功能和耐用实体的首发。我想做以下操作：

1. 创建一个耐用的实体，它具有称为SystemList的状态;

2. 创建一个队列触发函数以在我的队列中消耗消息并将其存储在我刚创建的实体状态中。

3. 创建一个HTTP触发函数以获取实体的当前状态;

我在第三步中遇到了一些问题。

该代码如下：

//HttpTriggerFunction.cs:
using System.Threading.Tasks;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.Azure.WebJobs.Extensions.DurableTask;
using System.Net.Http;
using System.Net;
using Newtonsoft.Json.Linq;

namespace **.Function
{
    public static class HttpTriggerQueryEntity
    {
        [FunctionName("QueryEntity")]
        public static async Task<HttpResponseMessage> Run(
            [HttpTrigger(AuthorizationLevel.Function)] HttpRequestMessage req,
            [DurableClient] IDurableEntityClient client)
        {
            var entityId = new EntityId(nameof(ProcessingListEntity), "processing_message_total");
            EntityStateResponse<JObject> stateResponse = await client.ReadEntityStateAsync<JObject>(entityId);
           
            //await client.SignalEntityAsync(entityId, "Empty");

            return req.CreateResponse(HttpStatusCode.OK,stateResponse.EntityState);
        }
    }
}

//blockData.cs
#nullable enable
using System;

namespace **.Function
{
    public class BlockData
    {
        public string? id { get; set; }
        public string? SessionId { get; set; }
        public string? MachineId { get; set; }
        public DateTime? Start { get; set; }
        public DateTime? End { get; set; }
        public string? Activity {get; set;}
        public string? BlobId { get; set; }
    }
}

//Entity.cs
using System.Threading.Tasks;
using Microsoft.Azure.WebJobs;
using Newtonsoft.Json;
using Microsoft.Azure.WebJobs.Extensions.DurableTask;
using System.Collections.Generic;
namespace **.Function
{
    [JsonObject(MemberSerialization.OptIn)]
    public class ProcessingListEntity
    {
        public ProcessingListEntity(){
            systemList = new Dictionary<string, BlockData>();
        }

        [JsonProperty("systemList")]
        public Dictionary<string, BlockData> systemList {get; set;}

        public void Add(BlockData blockData) {

            if (!this.systemList.ContainsKey(blockData.MachineId)) {
                this.systemList.Add(blockData.MachineId, blockData);
                return;
            }
            else {
                this.systemList[blockData.MachineId].Start = blockData.Start;
                this.systemList[blockData.MachineId].End = blockData.End;
            }
            
        }

        public void Empty() => this.systemList = new Dictionary<string, BlockData>();

        public Dictionary<string, BlockData> Get() => this.systemList;

        [FunctionName(nameof(ProcessingListEntity))]
        public static Task Run([EntityTrigger] IDurableEntityContext ctx)
            => ctx.DispatchAsync<ProcessingListEntity>();
    }
}

但是，当我在本地环境中运行它并将HTTP查询发送到程序中时。但是，当我更改httptriggerfunction.cs中的以下行时：

return req.CreateResponse(HttpStatusCode.OK,stateResponse.EntityState);

可以运行

 return req.CreateResponse(HttpStatusCode.OK,stateResponse.EntityState + "");

并返回所需的字符串。但是我想返回的是JSON字符串。

那么我该怎么办来修复我的代码？谢谢你！

Answer 1

您可以做到序列化对象并进行编码，然后发送。

因此，代替createresponse返回httpresponsemessage。

首先，您需要添加诸如：

using system.text;

using NewtonSoft.Json;

然后您可以返回的软件包：

return new HttpResponseMessage(HttpStatusCode.OK){Content = new StringContent(JsonConvert.SerializeOject(stateResponse.EntityState , Formating.Indented),Encoding.UTF8,"Response.json")}:

请参阅以下文章 callon campbell

参考以下文档。